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...
AWS MSK -创建开启ACL的Kafka主题时超时
我正在使用AWS MSK，并且想要启用ACL，但是当ACL被打开时无法创建主题。我使用命令行工具进行所有操作。以下是我所做的操作摘要： 创建一个全新集群 创建一个主题 - 这个操作正常运行 在资源=CLUSTER和操作=ALL上为client1打开ACL 使用AdminClient创建主题...
如何在Apache Kafka中删除多个主题
假设我有许多以相同前缀开头的主题，例如：giorgos-topic1 giorgos-topic2 giorgos-topic3 ... 用于删除单个主题（例如giorgos-topic1）的命令如下：./bin/kafka-topics.sh --zookeeper localhost:21...
Java，如何在Apache Kafka中获取主题中的消息数量
我正在使用Apache Kafka进行消息传递。我已经在Java中实现了生产者和消费者。我们如何获取特定主题中的消息数量？
单个消费者能够读取 Kafka 主题的多个分区吗？
有一个包含16个分区的Kafka主题。 使用给定的消费者组名称，我们当前正在启动单个消费者从主题中读取。 单个消费者会从该主题的分区0（仅）中读取吗？ 如果分区0中的消息已耗尽，那么消费者会开始从下一个分区（partiton 1……等等）读取吗？ 我们有选项可以启动多个具有相同消费...
Kafka log.segment.bytes vs log.retention.hours
我正在跟随第一版《Kafka权威指南》来了解经纪人何时删除日志段。根据文本，只有当日志段关闭后才能成为可删除的日志段。只有在达到log.segment.bytes大小（考虑未设置log.segment.ms）时，日志段才能关闭。一旦日志段成为可删除的，log.retention.ms策略将最终...
Kafka主题有分区，其领导者为-1（Kafka领导者选举），而节点正在运行。
我有一个由3个成员组成的kafka集群，其中__consumer_offsets主题有50个分区。 以下是对命令的描述结果： root@kafka-cluster-0:~# kafka-topics.sh --zookeeper localhost:2181 --describe Topi...
从Kafka主题中删除一条消息
我是新手在使用Kafka，我有一个问题。如果我知道主题、偏移量和分区，我能否仅删除主题中的一个消息？如果不能，是否有任何替代方案？
为什么Kafka无法创建主题？bootstrap-server不是一个可识别的选项。
我对Kafka很新，正在尝试在我的本地机器上创建一个新的主题。 我正在遵循这个链接。 以下是我遵循的步骤： 启动Zookeeperbin/zookeeper-server-start.sh config/zookeeper.properties 启动 kafka-serverbin/...