Java，如何在Apache Kafka中获取主题中的消息数量
我正在使用Apache Kafka进行消息传递。我已经在Java中实现了生产者和消费者。我们如何获取特定主题中的消息数量？
如何使用Python编写程序来在Apache Kafka中创建主题
到目前为止，我还没有看到一个Python客户端明确实现创建主题（topic）的，而不使用配置选项自动创建主题。
如何在Apache Kafka中删除多个主题
假设我有许多以相同前缀开头的主题，例如：giorgos-topic1 giorgos-topic2 giorgos-topic3 ... 用于删除单个主题（例如giorgos-topic1）的命令如下：./bin/kafka-topics.sh --zookeeper localhost:21...
为什么Kafka无法创建主题？bootstrap-server不是一个可识别的选项。
我对Kafka很新，正在尝试在我的本地机器上创建一个新的主题。 我正在遵循这个链接。 以下是我遵循的步骤： 启动Zookeeperbin/zookeeper-server-start.sh config/zookeeper.properties 启动 kafka-serverbin/...
从Kafka主题中删除一条消息
我是新手在使用Kafka，我有一个问题。如果我知道主题、偏移量和分区，我能否仅删除主题中的一个消息？如果不能，是否有任何替代方案？
一个 Kafka 主题可以处理多少个消费者组？
假设我有一个Kafka主题，大约有10个分区。我了解到每个消费者组在任何时候都应该有10个消费者从主题中读取以实现最大并行性。 但是，我想知道是否有任何直接规则来确定主题在任何给定时间点可以处理的消费者组数量（我最近在面试中被问到）。据我所知，这取决于经纪人的配置，以便它可以处理多少连接在任...
单个消费者能够读取 Kafka 主题的多个分区吗？
有一个包含16个分区的Kafka主题。 使用给定的消费者组名称，我们当前正在启动单个消费者从主题中读取。 单个消费者会从该主题的分区0（仅）中读取吗？ 如果分区0中的消息已耗尽，那么消费者会开始从下一个分区（partiton 1……等等）读取吗？ 我们有选项可以启动多个具有相同消费...
Kafka主题有分区，其领导者为-1（Kafka领导者选举），而节点正在运行。
我有一个由3个成员组成的kafka集群，其中__consumer_offsets主题有50个分区。 以下是对命令的描述结果： root@kafka-cluster-0:~# kafka-topics.sh --zookeeper localhost:2181 --describe Topi...
Kafka 流测试：java.util.NoSuchElementException: 未初始化的主题："output_topic_name"
我已根据https://kafka.apache.org/24/documentation/streams/developer-guide/testing.html编写了一个kafka流应用程序的测试类，代码如下： import com.EventSerde; import org.apac...