我完全是个懒汉 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 info,我如何只搜索特定的分区和偏移量或其他方式来获取主题中的最后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的工具都可以防止我发疯
暂无答案!
目前还没有任何答案,快来回答吧!