apache-kafka-streams

英文: Kafka streams handle batch data to reset aggregation 问题 以下是翻译好的内容： 我有一些数据到达我的Kafka主题“datasource”...

英文: How to log offset in KStreams Bean using spring-kafka and kafka-streams 问题 我已经几乎参考了关于如何通过Process...

英文: Kafka Stream is not populated 问题 我有一个非常简单的Java/Spring应用程序来演示KStream功能，但不幸的是，我无法使KStream加载数据。想法是创...

英文: Kafka streams GlobalKTable throws Deserialization exception on Tombstone - null value- records 问...

英文: How I receive the last windowed Kafka message in a windowedBy+aggregate when producer stops to s...

英文: How to use multiple transformers using the same topic for kafka streams? 问题 我需要使用多个转换器解析 Kafka 上...

英文: Need suggestion regarding Spring Boot Kafka Stream Binder Application error 问题 我试图从 https://clou...

英文: Kafka streams aggregation RecordTooLargeException 问题 尝试使用5分钟的滚动窗口从单个流中聚合数据。最初运行正常，能够打印出聚合的记录。使用J...

英文: Using Custom Kafka State Stores in kstreams application 问题 我们正在使用包含在Spring Cloud Stream Hoxton R...

英文: Do i need to register schema for kafka stream changelog topic under schema registry? 问题 我正在使用Pro...