使用说明 about jlogstash HOT 10 OPEN

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

from jlogstash.

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

from jlogstash.

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

from jlogstash.

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

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

from jlogstash.

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

from jlogstash.

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

from jlogstash.

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

from jlogstash.

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

from jlogstash.

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

from jlogstash.

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

from jlogstash.