英文: KStream-KStream Join not trigger left-join 问题 我使用kafka streams和spring-cloud-stream-binder-kafka-...
RocksDB 似乎将完整的 KTable 状态存储加载到内存中。
英文: Rocksdb seems to load full Ktable statestore in memory 问题 在我的Kafka流拓扑中,我将一个KTable与一个KStream进行了连接...
Kafka Streams:在单独的线程中写入持久状态存储是否被允许?
英文: Kafka Streams: is writing to a persistent state store in a separate thread permitted? 问题 我需要遍历整个...
如何在Scala单元/功能测试中禁止日志记录?
英文: How do I suppress logging for Scala unit / functional tests? 问题 以下是翻译好的部分: "I'm testing cod...
如何演进本地键值存储模式
英文: How to evolve local keyvaluestore schema 问题 我们有一个使用Kafka Streams处理数据的应用程序,我们使用Confluent Registry...
Kafka Streams状态存储 – 在Kubernetes中运行时要使用哪种存储。
英文: Kafka Streams state store - what kind of store to use when running in Kubernetes 问题 Kafka Stream...
Kafka Streams通过Punctuator批量更新/删除条目。
英文: Kafka Streams bulk entry update/delete by Punctuator 问题 这在你的情况下是否是合法的ProcessorAPI用法?还是需要使用 Topol...
全局窗口存储无法恢复。
英文: Global window store cannot be restored 问题 通过StreamsBuilder,Kafka Streams提供了定义全局窗口存储的方式。一旦定义好,就可以...
切换到不同的集群
英文: kafka streams | switch to different cluster 问题 我有一个需求,我必须根据某个条件将连接到kafka-cluster-1的kafka流切换到kafk...
Kafka Streams在auto.register.schemas=false情况下无法将消息发送到动态创建的主题。
英文: Kafka streams fails to send messages to dynamically created topics when auto.register.schemas=fa...