apache-kafka-streams

英文: Can I send output of a Kafka Stream to a REST API endpoint 问题 我目前有一个应用程序，它使用Consumer API从Kafka主题...

英文: Kafka- Joining a Kafka Stream with a Global K Table using non key value 问题 I've seen multiple po...

英文: Not possible to configure changelog topics 问题 我有一个由更改日志主题支持的状态存储。为了限制更改日志主题的大小，我希望为该主题设置cleanup....

英文: Kafka streams internal repartition topics not being created 问题 我正在运行一个Kafka Streams应用程序，该应用程序为拓扑...

英文: NullPointerException + org.apache.kafka.common.header.internals.RecordHeader.key 问题 我在我的微服务上自上次发...

英文: Will Kafka Streams guarentee at-least once processing in stateful processors even when Eaxctly-o...

英文: Kafka Streams - Unit test for ProductionExceptionHandler implementation 问题 I am developing a Kaf...

英文: Is Kafka Streams library v1.1.0 forward compatible with Kafka cluster v2.8.1? 问题 I'm running a K...

英文: what is the maximum tasks for kafka streams on multiple topcis with different partition 问题 假设我们有...

英文: KafkaStream Vs Flink 问题 我已经使用Flink将数据从源发送到目标。 我的Flink应用程序从Kafka消费数据并发送到目标。 目标也是Kafka主题，具有不同的主题名称...