apache-kafka

英文: Is there a way to read messages using Kafka stream(not via KafkaConsumer) from beginning everyti...

英文: Kafka Stream-GlobalKTable join on a specific field 问题 以下是您要翻译的部分： 我有一个KStream，它被反序列化为一个POJO，如下所示...

英文: How to resolve current committed offsets differing from current available offsets? 问题 我正尝试使用Spar...

英文: How to sum the values in a KTable (Kafka) 问题 我有两个KTables。一个保存我拥有的股票数量，另一个保存这些股票的最新价格。 例如， 数量 键 值...

英文: How to add config clean up policy as "compact" to input topic in below Java code? 问题 我...

英文: Usage of Java Kafka Consumer in multiple threads 问题 我正在考虑在线程池中使用Kafka消费者。我提出了这个方法。现在看起来运行正常，但我在考...

英文: Spring Kafka Consumer printing incorrect headers 问题 以下是您要的翻译： public final class KafkaConsumer {...

英文: Spring Kafka Configuration for 2 different kafka cluster setups 问题 在我们基于Spring Boot的服务中，我们打算同时连接...

英文: How to loop and limit the number of items fetched each time in an Observable 问题 以下是您要翻译的内容： 我有以下...

英文: Can we do parallel Kafka Streams processing with CompletableFutures 问题 可以使用Java的CompletableFutur...