如何在不知道用户组信息的情况下获取kafka主题的分区信息和偏移量

drkbr07n  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(227)

我完全是个懒汉 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的工具都可以防止我发疯

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题