英文: Kafka Consumer not receiving any message from Topic even though group id and client id is set co...
触发Kafka主题中的压缩应如何操作?
英文: How to trigger compaction in Kafka topic? 问题 我使用以下设置创建主题: final AdminClient localKafkaAdmin = Ad...
Kafka消费者在多个主题下的行为表现
英文: Kafka consumer behaviour with multiple topics 问题 为什么我们没有一种指定要轮询的主题的方法的理由是什么? 单次拉取/消费是否会返回来自不同主题的...
Spring Boot Kafka如何动态增加/减少消费者线程数
英文: Spring boot kafka how to dynamically increase/decrease consumer thread count 问题 我有一个Kafka主题,有一些高...
Spring Kafka手动确认使用AckMode.RECORD。
英文: Spring Kafka manual acknowledge using AckMode.RECORD 问题 I am trying to use Kafka for the below u...
Karafka 服务器为什么会抛出错误的查询水印偏移量?
英文: Why Karafka Server Throw error query watermark offset? 问题 我正在为我的Ruby on Rails应用程序使用这个宝石来生成和消费来自K...
为什么我的Kafka消费者在我寻求到另一个位置时会得到一个ValueError?
英文: Why do I get a ValueError in my Kafka Consumer if I seek to another position? 问题 I'll provide a ...
如何检查Kafka中是否分配了一个分区
英文: How to check a partition is assigned in Kafka 问题 我正在尝试找到一种在执行某项操作之前检查是否已分配分区的方法。我们知道通过检查 consume...
How can I consume data from specific partitions in Kafka using Confluent Python?
英文: How can I consume data from specific partitions in Kafka using Confluent Python? 问题 我尝试了这段代码,但它也...
Kafka Consumer – How can I do Replay/Get the same message from kafka broker in case my service is down/some exception occurred
英文: Kafka Consumer - How can I do Replay/Get the same message from kafka broker in case my service i...