很少有kafka分区未分配给任何flink使用者
我有一个包含15个分区[0-14]的kafka主题，并且正在以...
即使未调用生产者提交，Kafka事务性生产者也会写消息
对我来说，kafka事务性生产者的行为似乎像常规生产者...
是否有任何方法可以获取kafka主题的最旧的可用偏移量
我要在哪里存储偏移量信息，直到系统读取数据为止。...
@KafkaListener：事件的行为和跟踪处理
我们在应用程序中使用spring-kafka 2.3.0。在以下场...
卡夫卡停止后如何处理发送给它的消息？ 编辑评论中的新问题
我是Kafka的新手，我一直在研究Kafka停止发送消息时...
如何将卡夫卡消费群中的消费抵销额提高到最后？ 选项1 选项2 选项3
是否存在使用Kafka REST API的<strong>简便&l...
严重：无法销毁类型为[org.apache.tomcat.websocket.server.WsFilter]的名为[Tomcat WebSocketJSR356过滤器]的过滤器
我正在尝试运行Spring Boot项目，但出现以下错误。 ...
轮询前使用本地Apache Kafka消费者api过滤消息
是否可以选择在轮询前使用本地Apache Kafka使用者过...
KafkaConsumer.commitSync / commitAsync是否可以提交未分配分区的偏移量
<pre><code>KafkaConsumer.commitSync(...
Springboot KafkaListener侦听多个主题
我正在尝试构建一个涉及两个主题和一个消费者的kafk...
Kafka通过Kafka Consumer API流DSL
最近，在一次采访中，有人问我有关Kafka Streams的问...
Kafka重新平衡算法在各个主题之间保持平衡吗？
Kafka重新平衡算法可以跨主题使用吗？ 假设我有5个...
Kafka Mqtt源连接器无法接收从MQTT发布的数据，并失败，并显示“ java.lang.NullPointerException”
我是Kafka的新手，正在研究Kafka Mqtt源连接器。我正...
出现Kafka错误-java.util.concurrent.ExecutionException：org.springframework.kafka.core.KafkaProducerException：无法发送
我在Kafka中遇到错误。在发送有关主题的消息时 这是...