与Apache Kafka的内置流处理引擎相关，称为Kafka Streams，它是一个用于使用Apache Kafka构建分布式流处理应用程序的Java库。
我正在使用spark从主题kafka获取数据。我必须使用KafkaAvroDeserialaizer对avro数据进行deserialaizer。我配置kafka使用者：kafkaParams.put（“bootstrap.servers”，“10.0.4.215：9092”）; ...
Kafka Streams：topic.compression.type不是已知的配置
在Kafka Streams中添加压缩配置，与此链接类似：properties.put（StreamsConfig.topicPrefix（TopicConfig.COMPRESSION_TYPE_CONFIG），“snappy”）;但我看到以下......
事件采购 - Apache Kafka + Kafka Streams - 如何确保原子性/交易性
我正在使用Apache Kafka Streams评估事件采购，以了解复杂场景的可行性。与关系数据库一样，我遇到过一些案例，原子性/事务性是......
使用STATE_CLEANUP_DELAY_MS_CONFIG
在StreamsConfig中有一个参数STATE_CLEANUP_DELAY_MS_CONFIG，它表示“在迁移分区时删除状态之前等待的时间量（以毫秒为单位）。只有状态目录......