fyyq0628
fyyq0628
- Kafka10: encoding: "utf-8" codec: "plain" topics: "yunyun" groupId: "test2" bootstrapServers: "*.*.*.*:9092" consumerSettings: {zookeeper.connect: "*.*.*.*:2181",auto.commit.interval.ms: "1000",auto.offset.reset: "smallest"} 我使用这个配置去采集kafka的数据无法采集到，也没有任何报错，我在后台服务器是可以使用命令生产和消费的，能帮忙看下配置是否正确吗，kafka的版本的是1.0.0，由于隐私性，IP我用”*"代替了
另一个kafka的input插件采集成功了，但是二者的配置参数似乎有比较大的区别
input插件选择tcp，启动无报错，配置如下： - Tcp: codec: "plain" prot: 52192 host: "127.0.0.1" encoding: "utf8" bufSize: 30 maxLineLength: 10 当我模拟往端口发送数据的时候一直提示那个连接失败，但是我用别的代码模拟tcp的server和client的时候能发送和接收数据，我是菜鸟，刚刚接触，可能问题比较多，希望不要被骂
也就是说目前kafka10没办法消费，是么
好的，谢谢，我改下配置看看是否能消费到