英文: Kafka Consumer not receiving any message from Topic even though group id and client id is set co...
How to enable database + kafka transaction in Spring Cloud Stream for producer-only transactions (db + kafka)?
英文: How to enable database + kafka transaction in Spring Cloud Stream for producer-only transactions...
如何使用`consumerseekaware`接口以从特定的Kafka偏移位置获取Kafka消息。
英文: how to use consumerseekaware interface in order to fetch kafka message from a paticluar kafka of...
在错误情况下的提交行为失序
英文: Out of order commit behaviour in case of errors 问题 我喜欢使用Spring Kafka记录消息监听器以及无序提交功能。由于处理记录可能会因相关...
KStream-KStream Join不触发左连接。
英文: KStream-KStream Join not trigger left-join 问题 我使用kafka streams和spring-cloud-stream-binder-kafka-...
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...
在Spring Batch中限制从Kafka获取的消息数量。
英文: Limit number of messages from Kafka in Spring Batch 问题 我如何限制队列大小为100万条?每当队列被轮询并且有空闲空间时,它应该重新开始监听...
Kafka Springboot – 在运行时向生产者发送 topicName
英文: Kafka Springboot - send topicName to producer on the fly 问题 我正在编写一个应用程序,我想要在给定的主题中发送消息(如果主题存在),如...
Kafka消息压缩未按预期工作。
英文: Kafka message compression not working as expected 问题 我的项目使用Apache Kafka来发送消息。随着时间的推移,负载变得很大,已经超过...