使用说明

[fyyq0628]

能否更新使用说明呢，最好有示例，我无法使用大部分的input插件采集到数据，总是提示这样或者那样的问题

[yangsishu]

有什么问题，可以在github上提

[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我用”*"代替了

[fyyq0628]

另一个kafka的input插件采集成功了，但是二者的配置参数似乎有比较大的区别

[fyyq0628]

input插件选择tcp，启动无报错，配置如下：

• Tcp: codec: "plain" prot: 52192 host: "127.0.0.1" encoding: "utf8" bufSize: 30 maxLineLength: 10 当我模拟往端口发送数据的时候一直提示那个连接失败，但是我用别的代码模拟tcp的server和client的时候能发送和接收数据，我是菜鸟，刚刚接触，可能问题比较多，希望不要被骂

[yangsishu]

Kafka10 这个参数配置后面会加下，现在的是kafka09版本的

[yangsishu]

你要是报错，发下报错信息，不让我没法给你排查问题

[fyyq0628]

也就是说目前kafka10没办法消费，是么

[yangsishu]

kafka10 可以消费的，我是说github上的kafka配置说明是09版本的，现在已经加上kafka10的配置说明了

[fyyq0628]

好的，谢谢，我改下配置看看是否能消费到

[jffree]

@yangsishu 请问配置文件中 OUTPUT 里面的 if 语句应该如何写？