用于获取偏移量和消费者组详细信息的ConFluent CLI命令
嗨，我在寻找一个汇合的cli命令来使用GetOffsetShell获得最早和最新的偏移，并获得消费者团体的细节。
寻找以下kafka命令的汇合cli命令，
获取偏移详细信息
/opt/kafka/bin/kafka-run-class.sh kafka.tools.GetOffsetShell \
--broker-list localhost:9092 \
--topic my_topic \
--time -1
正在获取消费者组列表
kafka-consumer-groups.bat --bootstrap-server localhost:9092 --list
描述消费群体
kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe group <group_name>
有人能帮助我使用融合cli命令获得这些命令的功能吗？
共有1个答案
Confluent Cloud CLIccloud不是那些Kafka CLI命令的替代品，Confluent命令用于管理平台的本地临时集群。
您仍然应该在任何kafka安装中使用kafka运行类，无论是托管的还是其他的。但是，出于身份验证目的，您可能需要传递选项，例如--command-config或其他属性
-
试图理解消费者补偿和消费者群体补偿之间的关系。 下面的堆栈溢出链接提供了对消费群体补偿管理的极好理解<什么决定Kafka消费补偿？现在问题来了， 情节： 我们在一个消费者组组1中有消费者（c1）。 偏移值是否将存储在消费者（c1）和组（group1）两个级别？或者如果消费者属于任何消费者组，偏移量将存储在仅消费者组级别？ 如果偏移值将存储在两个级别中，它是否是消费者级别偏移值将覆盖消费者组级别偏移
-
我有多个Kafka消费者和制作人，主题不同。使用独立应用程序，我想监控Kafka消费者的延迟。 我使用Kafka0.10.0.1，因为Kafka现在存储消费者偏移Kafka本身，所以我怎么能读到相同的。 我能够读取每个分区的主题偏移量。
-
我正在探索ChronicleQueue来保存我的一个应用程序中生成的事件。我想在经过一些处理后，将保存的事件按其原始发生顺序发布到不同的系统。我有多个应用程序实例，每个实例都可以运行一个单线程appender来将事件添加到ChronicleQueue。尽管跨实例排序是必要的，但我想理解以下两个问题。 2）还需要一些建议，如果有一种方法来保持跨实例的事件顺序。
-
问题内容： 现在，Golang Kafka库（sarama）提供了使用者组功能，而kafka 10没有任何外部库帮助。如何在任何给定时间获得使用者组正在处理的当前消息偏移量？ 以前，我使用kazoo-go（https://github.com/wvanbergen/kazoo- go ）来获取我的消费者组消息偏移量，因为它存储在Zookeeper中。现在，我使用sarama- cluster（ht
-
null 当侦听器处理记录后返回时提交偏移量。 如果侦听器方法抛出异常，我会认为偏移量不会增加。但是，当我使用下面的code/config/command组合对其进行测试时，情况并非如此。偏移量仍然会得到更新，并且继续处理下一条消息。 我的配置： 验证偏移量的命令： 我使用的是kafka2.12-0.10.2.0和org.springframework.kafka:spring-kafka:1.1
-
我正在使用Kafka2.0版和java消费者API来消费来自一个主题的消息。我们使用的是一个单节点Kafka服务器，每个分区有一个使用者。我注意到消费者正在丢失一些消息。场景是：消费者投票主题。我为每个线程创建了一个消费者。获取消息并将其交给处理程序来处理消息。然后使用“至少一次”的Kafka消费者语义来提交Kafka偏移量来提交偏移量。同时，我有另一个消费者使用不同的group-id运行。在这个