kafka2.4.0+zookeeper+kafka-connect集成安装包
2023-04-19 14:23:19
74.6MB
1
kafka-connect-jdbc-4.1.1.zip包含了kafka-connect-jdbc-4.1.1.jar包。 欢迎大家下载，大家也可关注我的博客，欢迎一起交流，如有疑问请留言！
2023-01-17 10:27:26
130KB
1
kafka-connect-mqtt
此仓库包含用于Apache Kafka的MQTT源和接收器连接器。 已通过Kafka 2+进行了测试。
使用源连接器，您可以订阅MQTT主题，并将这些消息写到Kafka主题。
接收器连接器以相反的方式工作。
笔记：
目前不支持SSL连接
该连接器仅适用于单个任务。 设置maxTasks> 1无效。
建立连接器
要构建连接器，必须安装以下组件：
Java 8或更高版本
玛文
GIT
使用以下命令克隆存储库：
git clone https://github.com/johanvandevenne/kafka-connect-mqtt.git
将目录更改为kafka-connect-mqtt目录
cd kafka-connect-mqtt
使用Maven构建连接器
mvn clean install
安装连接器
先决条件
您必须已安装K
2022-11-14 10:50:07
16KB
1
kafka-connect-ui
这是Kafka Connect的网络工具，用于设置和管理多个连接集群的连接器。
现场演示
与Docker独立运行
docker run --rm -it -p 8000:8000 \
-e "CONNECT_URL=http://connect.distributed.url" \
landoop/kafka-connect-ui
CONNECT_URL可以是逗号分隔的Connect worker端点数组。 例如：CONNECT_URL = “
另外，您可以通过在端点URL后面附加分号和群集名称来为Connec
2021-12-27 16:45:11
687KB
1
REST接口的Java客户端库
目录
建立项目
./mvnw -B clean verify
程式码范例
列出所有活动的连接器
ApiClient client = Config . defaultClient();
Configuration . setDefaultApiClient(client);
ConnectApi api new ConnectApi ();
final List connectors = api . listConnectors();
部署新的连接器
ApiClient apiClient = Config . defaultClient();
Configuration . setDefaultApiClient(apiClient);
KafkaConnectRestClient client = new KafkaCo
2021-12-27 15:59:48
103KB
1
kafka-connect-oracle-1.0.jar，把https://github.com/erdemcer/kafka-connect-oracle项目打成的jar包
2021-11-26 16:44:40
431KB
1
可配置化shell脚本监控kafka-connect集群节点，节点异常发送邮件通知管理员，亲自整理无坑。
2021-09-13 14:50:14
2KB
1
kafka-connect-elasticsearch-5.4.1.zip包含了kafka-connect-elasticsearch-5.4.1.jar包。 欢迎大家下载，大家也可关注我的博客，欢迎一起交流，如有疑问请留言！
2021-09-13 13:12:11
73KB
1
2021年6.29号打包，最新版本：kafka-connect-oracle-1.0.71.jar，用于根据oracle binglog日志同步数据到kafka
2021-06-29 14:00:14
447KB
1