守护轻鸟

想问下，问题解决了么，我也遇到了同样的问题

请问这个问题解决了吗？ 我也遇到了这个问题

过滤（正则），logstash 和 filebeat 都可以的。
logstash的我整理的太少了
https://www.orchome.com/471

我的业务场景是接收kafka消息，然后做一些数据清洗，最后存到es中。logstash 和 filebeat 是用来发送消息到kafka吧？

root@qdjc-zbjg3:/usr/local/kafka_2.12-0.11.0.1# bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.16.37.70:9092 --describe --group ctsv-compress-group-id
Note: This will only show information about consumers that use the Java consumer API (non-ZooKeeper-based consumers).

Error: Executing consumer group command failed due to The consumer group command timed out while waiting for group to initialize: 
root@qdjc-zbjg3:/usr/local/kafka_2.12-0.11.0.1# bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group ctsv-comress-group-id
Note: This will only show information about consumers that use ZooKeeper (not those using the Java consumer API).

Error: The consumer group 'ctsv-comress-group-id' does not exist.