不使用Schema Registry的Kafka Connect
创始人
2024-12-29 08:00:34
0

不使用Schema Registry的Kafka Connect可以通过以下步骤来实现:

  1. 创建一个Kafka Connect配置文件,例如connect.properties,并设置以下属性:
bootstrap.servers=
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter

这里我们使用了StringConverter作为键和值的转换器,因为我们不需要使用Schema Registry来处理数据的Schema。

  1. 创建一个Kafka Connect任务配置文件,例如my-source.properties,并设置以下属性:
name=my-source
connector.class=org.apache.kafka.connect.file.FileStreamSourceConnector
tasks.max=1
file=
topic=

在这里,我们使用FileStreamSourceConnector作为连接器类,它可以从一个文件中读取数据并将数据写入指定的Kafka主题。

  1. 运行Kafka Connect,执行以下命令:
bin/connect-standalone.sh connect.properties my-source.properties

这将使用前面创建的配置文件来启动Kafka Connect,并将数据从输入文件写入到指定的Kafka主题中。

以下是一个完整的示例:

  1. 创建connect.properties文件:
bootstrap.servers=localhost:9092
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
  1. 创建my-source.properties文件:
name=my-source
connector.class=org.apache.kafka.connect.file.FileStreamSourceConnector
tasks.max=1
file=/path/to/input/file.txt
topic=my-topic
  1. 运行Kafka Connect:
bin/connect-standalone.sh connect.properties my-source.properties

这将启动Kafka Connect并将文件/path/to/input/file.txt的内容写入到my-topic主题中。

相关内容

热门资讯

发现透视"WePok... 发现透视"WePoker透视挂怎么用"开挂(透视)辅助神器(热点推荐wpk教程)《发现透视"WePo...
五分钟透视!时光互娱房卡辅助,... 【亲,时光互娱房卡辅助 这款游戏可以开挂的,确实是有挂的,很多玩家在这款时光互娱房卡辅助中打牌都会发...
科技透视"WePoK... 科技透视"WePoKer到底有透视挂吗"开挂(透视)辅助脚本(最新研发黑科技教程)科技透视"WePo...
3分钟开挂!雀神广东插件智能解... 雀神广东插件智能解码是一款可以让一直输的玩家,快速成为一个“必胜”的ai辅助神器,有需要的用户可以加...
一分钟辅助!雀友会广东潮汕苹果... 雀友会广东潮汕苹果开挂 无需打开直接搜索微信:136704302本司针对手游进行,选择我们的四大理由...
关于透视"手机微扑克... 关于透视"手机微扑克辅助器"开挂(透视)辅助神器(解密关于安装教程)关于透视"手机微扑克辅助器"开挂...
7分钟辅助!功夫川辅助,越乡游... 7分钟辅助!功夫川辅助,越乡游义乌辅助(揭秘攻略开挂辅助工具);打开点击测试直接进入微信(13670...
必看透视"wepok... 必看透视"wepoker微透视挂方法"开挂(透视)辅助平台(玩家必备教程必胜教程)必看透视"wepo...
第3分钟辅助!微信小程序边锋辅... 您好:这款微信小程序边锋辅助游戏是可以开挂的,确实是有挂的,很多玩家在这款微信小程序边锋辅助游戏中打...
实测透视"手机微扑克... 实测透视"手机微扑克辅助器"开挂(透视)辅助下载(玩家必看科普大神讲解)实测透视"手机微扑克辅助器"...