如果我运行命令,我完全是一个蹲在Kafka
土地上的人
/cfintools/confluent-4.0.0/bin/kafka-avro-console-consumer --topic $t --bootstrap-server $bt --consumer.config /cfintools/avro_consumer_ssl_cfin_prod.properties --property schema.registry.url=$regd --from-beginning
这东西只需要永远回来。没有错误,但也没有数据。
我想要的只是该主题中的最新 10 条消息,并且我阅读了partition
和offsets
. 现在我不知道我应该如何去获取这个信息我在其他地方读到过这个命令
./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group count_errors --describe
但我不知道我的消费群体。我只知道topic
第一个命令中提到的名称和其他参数因此使用此 ltd 信息如何获取主题中的最后 10 条奇数消息,仅搜索特定分区和偏移量或任何其他方式
我尝试使用该kt
工具
$ ./kt topic -brokers $bk -filter $t -partitions -leaders -replicas
failed to create client err=kafka: client has run out of available brokers to talk to (Is your cluster reachable?)
我知道经纪人是有效的,因为我正在使用他们
我最想要的是:
- 以最直接的方式获取
partition
和偏移,无需任何附加信息,例如消费者组 - 自动搜索最后 10 个的任何其他方法
messages
- 分区、偏移和获取 - 任何可以防止我发疯的基于 GUI 的工具