英文: Kafka offset increments even without reaching Ack 问题 我有一个消费者,它消费一条消息,执行一些繁重的任务,然后进行确认操作。 @KafkaL...
春季Kafka集成属性,用于使用application.yml/properties的批处理监听器:
英文: Spring kafka integration properties for batch listener using application.yml/properties 问题 我正在尝试...
Cannot resolve method ‘parse’ in ‘DockerImageName’ when using Testcontainers and gradle in JUnit5
英文: Cannot resolve method 'parse' in 'DockerImageName' when using Testcontainers and...
将”Acks”设置为”all”时,我在我的Kafka生产者中得到了”acks = -1″。
英文: Getting acks = -1 when I set acks to all in my Kafka producer 问题 我在我的Kafka生产者上设置了以下属性: propertie...
java.lang.ClassNotFoundException: org.apache.kafka.clients.consumer.ConsumerGroupMetadata
英文: java.lang.ClassNotFoundException: org.apache.kafka.clients.consumer.ConsumerGroupMetadata 问题 以下是...
NoClassDefFoundError 在尝试在 Kafka 中创建分区时发生错误。
英文: NoClassDefFoundError when trying to create partitions in Kafka 问题 以下是要翻译的内容: 我有以下代码: public Kafk...
如何在Spark Kafka流中创建消费者组并将消费者分配给消费者组。
英文: How can make consumer group in spark kafka stream and assign comsumers to consumer group 问题 我有一个...
在Java中检查Kafka消费者是否没有任何记录要返回并且为空的好方法是什么?
英文: Good way to check if Kafka Consumer doesn't have any records to return and is empty in java?...
无法使用Spring Boot构建Kafka消费者。
英文: Failed to construct kafka consumer with Spring Boot 问题 我已经实现了一个简单的消费者应用程序来消费主题中的消息。当我运行kafka-con...
如何在Java中逐条从Kafka消费者获取消息?
英文: How to get messages from Kafka Consumer one by one in java? 问题 我正在使用Apache Kafka API,尝试一次只获取一条消息...
41