apache-kafka-streams - 代码之家

Kafka流处理期间处理数据时出现异常

Stella · 技术社区 · apache-kafka-streams apache-kafka · 6 年前

kafka流中的处理器节点

Stella · 技术社区 · apache-kafka-streams apache-kafka · 6 年前

卡夫卡流:Lib Rocks数据库上的UnsatifiedLinkError

mukesh210 · 技术社区 · rocksdb apache-kafka-streams apache-kafka scala · 6 年前

Kafka流:通过Json日志中的键进行分组

el323 · 技术社区 · apache-kafka-streams apache-kafka java · 6 年前

如何使用Avro反序列化器和Avro序列化器为KafkaStreams编写Junit测试用例

Suchita · 技术社区 · apache-kafka-streams avro testng junit java · 6 年前

如何获得有关GlobalKTable状态存储更新的通知?

Cemo · 技术社区 · apache-kafka-streams · 6 年前

Kafka将GlobalKTable同步流传输到应用程序

px5x2 · 技术社区 · apache-kafka-streams apache-kafka java · 7 年前

加工机为Kafka流中的单个任务多次调用init()

Dth · 技术社区 · apache-kafka-streams apache-kafka java · 7 年前

Kafka Streams多实例设计含义

nattyddubbs · 技术社区 · confluent-platform apache-kafka-streams apache-kafka · 7 年前

如何使用卡夫卡流窗口为烛台图生成创建一条记录

dvlcis · 技术社区 · apache-kafka-streams apache-kafka · 7 年前

从scala启动KsqlRestApplication表单并获取NoSuchMethodError org。阿帕奇。卡夫卡。流。StreamsConfig。getConsumerConfigs

Christopher Beck · 技术社区 · ksqldb apache-kafka-streams apache-kafka scala · 7 年前

在主题之间筛选

Outlander · 技术社区 · apache-kafka-streams apache-kafka java · 7 年前

如何在内存Kafka Streams状态存储上启用缓存

Dth · 技术社区 · apache-kafka-streams apache-kafka java · 7 年前

kafka流:获取CorruptRecordException

Eric · 技术社区 · apache-kafka-streams apache-kafka java · 7 年前

反序列化Avro序列化Kafka流时出现问题

cscan ssice · 技术社区 · confluent-platform apache-kafka-streams avro apache-kafka java · 7 年前

KTable Reduce函数不支持窗口化

Nagabhushan Sheshagiri Rao · 技术社区 · apache-kafka-streams apache-kafka · 7 年前

停靠Java Springboot应用程序的优势?

achilles · 技术社区 · apache-kafka-connect apache-kafka-streams apache-kafka docker · 7 年前

我们可以从历史数据创建卡夫卡时间窗口流吗?

Xiang Zhang · 技术社区 · apache-kafka-streams apache-kafka · 7 年前

使用Spring Boot 1.5避免Kafka流在测试中启动

riccardo.cardin · 技术社区 · spring-boot-test spring-kafka apache-kafka-streams spring-boot java · 7 年前

如何为定制处理器定义新的度量标准(并使其在jconsole中可用)?

timmy_stapler · 技术社区 · jconsole apache-kafka-streams jmx · 7 年前

具有依赖对象的Kafka流等待函数

Lothium · 技术社区 · apache-kafka-streams apache-kafka stream · 7 年前

如何始终使用卡夫卡流中的最新偏移量

Saloni Vithalani · 技术社区 · apache-kafka-streams apache-kafka · 7 年前

如何从KafkaStreams PersistentKeyValueStore中删除记录?

littzh · 技术社区 · apache-kafka-streams apache-kafka · 7 年前

为什么我的Kafka Streams拓扑不能正确重播/重新处理?

Dmitry Minkovsky · 技术社区 · apache-kafka-streams apache-kafka · 7 年前

docker compose中的Kafka流需要很长时间才能分配分区

shaftoes · 技术社区 · apache-kafka-streams docker-compose apache-kafka docker · 7 年前

从Kotlin调用通用Java varargs方法

gavrie · 技术社区 · apache-kafka-streams kotlin · 7 年前

在给定窗口的流上计算统计信息

jaker · 技术社区 · apache-kafka-streams apache-kafka java · 7 年前

自动部署Kafka流应用程序

David Corral · 技术社区 · apache-kafka-streams apache-kafka · 7 年前

在Kafka流中为不同的操作设置不同的线程

rishi007bansod · 技术社区 · apache-kafka-streams apache-kafka · 7 年前

使用Kafka流进行自定义转换

sujin · 技术社区 · stream-processing apache-kafka-streams etl apache-kafka java · 7 年前