【文件属性】:
文件名称:Kafka-Connect:Kafka Connect自定义连接器
文件大小:15KB
文件格式:ZIP
更新时间:2021-05-15 10:31:20
Java
欢迎使用新的Kafka Connect连接器!
在开发中运行
此存储库中包含基于Confluent Platform Docker映像。 查看Docker映像的。
主机名confluent的主机名必须是可解析的。 您将需要使用docker-machine ip confluent确定docker-machine的IP地址,并将其添加到您的/etc/hosts文件中。 例如,如果docker-machine ip confluent返回192.168.99.100添加以下内容:
192.168.99.100 confluent
docker-compose up -d
在启用调试的情况下启动连接器。
./bin/debug.sh
在启用调试的情况下启动连接器。 这将等待调试器附加。
export SUSPEND='y'
./bin/debug.sh
【文件预览】:
Kafka-Connect-master
----.gitignore(45B)
----src()
--------main()
--------test()
----docker-compose.yml(673B)
----pom.xml(3KB)
----README.md(911B)
----config()
--------connect-avro-docker.properties(2KB)
--------MySinkConnector.properties(102B)
--------MySourceConnector.properties(90B)