Kafka使用者即使订阅了该主题也无法收到消息
我正在订阅一个主题并尝试使用消息，但是，尽管我看...
如何在Spring Boot中延迟加载Kafka Consumer？
我想通过命令行参数提供组ID，但尝试此操作时出现以...
Java客户端配置了单个Kafka代理IP和要连接的端口，如果该代理在集群中关闭了怎么办
我有一个Java使用方使用broker1：9092连接到kafka集...
我如何让Kafka根据提供的保留期限删除日志
我有一个kafka集群或3个在AWS EC2实例上运行的代理。...
如何在Kafka中删除消费者组成员
是否可以从Kafka的消费者组中删除组成员，而不必删除...
考虑到在为长时间运行的处理添加新使用者时发生的重新平衡，我如何正确地暂停/恢复操作？
我正在将kafka 2.3.1（server）与spring-kafka 2.2....
为大量的卡夫卡消费者提供持续的重新平衡
Confluent Platform版本5.4.2 在Kubernetes中部署...
Confluent.net中的模式匹配
因此，我有一种情况想与我所订阅主题的模式相匹配。...
System.ObjectDisposedException：句柄被破坏
Kafka使用者应用程序在启动停止使用者服务的过程时...
如果超过特定的字节数，是否可以丢弃聚合Kafka流？
我的目标是在超过一定数量的字节（序列化json）时将...
Kafka Stream-自动提交关闭时如何处理错误
对于Kafka Streams，如果将commit.internal.ms配置设...
卡夫卡消费者fetch-min-sizefetch.min.bytes是否在等待上述大小被填满？ fetch.min.bytes fetch.max.wait.ms
假设有107条记录，每条记录为1kb。如果提取大小为15...
错误运行使用者时发生未知错误：org.apache.kafka.common.errors.SerializationException：未知魔术字节
正在尝试从python向kafka消费者发送消息。但是由于&...
如何在Kafka侦听器方法中寻找特定的偏移量？
我正在尝试使用我的kafka侦听器方法从SQL数据库中寻...