apache kafka的新版本在内部存储消费者组数据，而不是使用zookeeper你能告诉我：
如何在使用新的消费者API时删除属于主题T的消费者组C
浏览 6提问于2017-11-10得票数 0
我正在使用Kafka 0.9消费者API。我需要检查给定的使用者组和主题的当前使用者偏移量，并且还没有找到任何命令行工具来列出这些信息。我尝试了以下命令但这并没有列出消费者，即使我有消费者在运行/投票。基于，
浏览 4提问于2016-05-13得票数 1
2回答
我使用当前的服务(Producer)将消息发送到Kafka主题(events)。该服务使用的是用Java语言编写的kafka_2.12 v1.0.0。我正在尝试将它与spark-streaming的示例项目集成为Consumer服务(使用Scalav0.10.0的，用kafka_2.11编写)Exception in thread "main" org.apache.
浏览 1提问于2018-07-24得票数 8
当我运行卡夫卡-控制台-消费者像这样默认的消费者群体是什么如果我没有在命令行中指定使用者组或链接到使用者属性，那么它会使用随机的使用者组吗？如何检查使用了哪些消费者组？
谢谢!
浏览 0提问于2018-08-03得票数 2
回答已采纳
我有Nifi集群，Kafka也安装在那里。
创建了一个带有5个分区的主题，开始使用带有一个gourp-id的主题。这样每个分区都会得到唯一的消息。现在，我创建了5个ConsumeKafka_1_0处理器，目的是在每个消费者端获得唯一的消息。但只有2个ConsumeKafka_1_0正在使用rest设置为理想的所有消息。现在我所做的是启动5个命令行Kafka使用者，所发生的是，我能够看到所有的分区正在获取消息，并且能够以循环方式从<em
浏览 2提问于2018-08-14得票数 0
我是kafka的新手，我正面临着一个消费者组的问题我有一个logstash消费者组，它是很久以前创建的，当我创建一个新的Kafka主题以solr*开始*它会自动添加到kafta消费者组"logstash“如果我创建任何其他名称的主题，它没有添加到该消费者组，所以我想知道我如何才能找到一个消费者组的配置
浏览 3提问于2020-07-08得票数 1
然后，我在config/consumer.properties中定义了我的使用者组配置，以便我的使用者可以从定义的group.id中挑选消息bin/kafka-consumer-groups.shvia kafka-console-consumer.sh
我能够通过一个基于python的消费者连接到kafka，该消费者被配置为使用provide group.id，即test-consumer-gr
浏览 1提问于2020-05-13得票数 5
回答已采纳
1回答
因此，我有一个消费者组在运行并侦听来自某个主题的消息。如何将更多的消费者实例添加到消费组中？(message) { }); 我尝试创建消费者并在选项中包含相同的组名， new kafka.Consumer( ], groupId:
浏览 33提问于2020-10-07得票数 1
我通过新的消费API创造了卡夫卡消费者。我们有一个使用者组，每个组中有一个使用者实例。Kafka脚本“kafka- old groups.sh”提供了删除用户的方法，但这只适用于运行命令的旧使用者组：给出
--删除：警告:
浏览 2提问于2016-06-10得票数 7
我执行了这会导致显示一个组: console-consumer-961然后我尝试删除这个群：
kafka-consumer-groups --bootstrap-server localhost:9092 --delete --group console-consumerconsole-consumer-961' could not be deleted due to: java
浏览 876提问于2020-05-16得票数 4
回答已采纳
我使用的是Confluent5.2的社区版本。我创建了一个名为employee-info的新主题。
我使用flink作为上述主题的消费者。在flink中，为了添加kafka源，我们需要传入group.id (消费者组)作为参数。如何为我的主题创建一个新的消费组？我很少有参考资料说在--consumer-property group.id=group_name中使用kafka
浏览 45提问于2019-08-02得票数 1
我知道Kafka Queue Partition中的所有消息(或偏移量)都有它的偏移量，它负责偏移量的顺序。但是，如果我有一个Kafka Consumer Group (或单个Kafka Consumer)，它正在读取特别是Kafka主题分区，那么它如何维护读取的偏移量消息，以及谁维护这个偏移量计数器？如果消费者宕机，那么新的消费者将如何开始读取下一个未读(或未确认)偏移量。
浏览 18提问于2020-07-04得票数 1
回答已采纳
我想构建一个程序，在Kafka中根据数据的时间戳重新处理数据，而不影响工作消费者的偏移量。 所以我做了一些研究，有机会看到了一个与我的情况相似的StackOverFlow答案。https://stackoverflow.com/a/50405704/7034612 然而，我仍然不确定上面答案中写的代码是否会影响当前工作的消费者的偏移量。
浏览 16提问于2021-07-04得票数 0
回答已采纳
1回答
我正在使用kafka 0.10 kafkaConsumer接口来获取消费者和消费者订阅下的主题集。我的问题是如何获得组和主题之间的关系。我知道一个群
浏览 0提问于2016-12-06得票数 2
当我在命令行中运行快速入门示例时，我发现我不能在命令行中创建多个使用者。我用3个分区构建了一个名为test的主题，我还在这个主题上构建了一个生产者。然后我想创建两个不同的消费者，在这个主题上共享一个名为test1的相同的消费者组。我像下面这样运行了两次命令：
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --grou
浏览 0提问于2014-10-10得票数 15
1回答
我有4个主题：topicBtopicDgroupAgroupA目前用于topicA和topicB
groupB目前用于topicC和topicD可以创建一个新的消费者组来复制topicA和topicB的groupA以及topicC和topicD的groupB的主题分区偏移量提交吗？我可以一次为两个以上的组执行此操作吗？
浏览 4提问于2020-05-27得票数 0
我有python脚本，并且需要使用kafka1 broker集群检索一组从kafka主题读取的消费者的当前消费者组偏移量。这些是原生kafka消费者，将偏移量存储在kafka集群中，而不是zookeeper中。
脚本本身不需要使用任何消息，只需读取其他使用者的当前偏移量。我意识到使用kafka-consumer-groups.sh可以做到这一点，
浏览 1提问于2018-03-12得票数 3
2回答
我想使用Pyhon和Kafka客户端获取Kafka主题的承诺偏移量和结束偏移量(位置)，而位置是由消费者+主题的分区(KafkaConsumer.end_offsets(partitions))接收的。
浏览 3提问于2020-06-07得票数 0
我正在创建两个apache camel (blueprint XML) kafka项目，一个是kafka-producer，它接受请求并将其存储在kafka服务器中，另一个是kafka-consumer，它从kafka服务器获取消息并处理它们。这种设置对于单一主题和单一使用者来说工作得很好。但是，如何在同一个kafka topic中创建独立的消费群？如何在不同消费
浏览 28提问于2020-05-03得票数 1
1回答
我们有一个WebSocket服务器，它为每个WebSocket客户端创建一个单独的消费者组，这样每个WebSocket用户就可以相互独立地接收来自Kafka主题的更新。我们使用camel API来创建Kafka消费者(组)，它使用了Kafka原生Java API，所以这与Camel没有任何关系，但提到camel只是一个FYI。通过使用JMX和JMC监控，我们发现Kafka<
浏览 1提问于2018-11-06得票数 1
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
