apache-kafka-streams 相关问题

带有Spring云流Binder和Json反序列化器的模式注册表

我是 Kafka 的新手，我正在尝试使用模式注册表并与 spring 云流绑定消费者集成，我已经研究了很多并获得了很多参考资料，但没有真正解决问题。所以可以...

基于 Quarkus 的 Kafka Streams 应用程序中的多个拓扑

我正在尝试使用 Quarkus 构建 Kafka Streams 应用程序。我想知道如何在同一个 Quarkus 应用程序中拥有多个拓扑？ 我试图像这样实现它： @ApplicationScoped 公开课

Kafka Streams：如何确保处理完成后提交偏移量

我想使用 Kafka 流处理 Kafka 主题中存在的消息。 处理的最后一步是将结果放入数据库表中。避免数据库争用相关问题（

如何使用Kafka Stream手动提交？

有没有办法使用 Kafka Stream 手动提交？ 通常使用 KafkaConsumer 时，我会执行如下操作： 而（真）{ ConsumerRecords 记录 = Consumer.pol...

'store(org.apache.kafka.streams.StoreQueryParameters<T>)'不能应用于'(java.lang.String, org.apac

我正在使用流表示例，如下所示：https://udemy.com/course/kafka-streams-real-time-stream-processing-master-class/learn/lecture/14244016#questions，当我升级kafka依赖...

如何处理内部 kafka-streams 主题的 avro 架构？

我们正在为代表“公共”接口的 kafka 主题使用 Avro 方案。当这样的主题现在在 Kafka-Streams 应用程序中使用并且调用有状态操作时，

Kafka Streams可以从s3读取数据并将其发送到其他目的地，例如mysql或olap吗？

有一些关于 kafka 流的文章，它从 s3 读取数据并将其发送到其他目的地，例如 olap 或 oltp。 我看不到它们的示例代码，所以我是否更正 kafka

向 Spring Kafka 消费者指标添加自定义静态标签

我的应用程序使用来自 2 个不同集群的相同主题名称 唯一出现的指标标签是“spring.id”， 需要添加更多标签 - 例如集群名称 试图实现这个 哈...

将自定义类存储到 TimestampedKeyValueStore

我有点挣扎。我将来自 Kafka 的消息存储到 TimestampedKeyValueStore 中，但我的消息有一个标头（不仅是类型 id），在它们被存储并沿线发送之后，

Kafka Streams API 中的节点断开连接错误

我已经使用 Kafka Streams API 创建了 Kafka Consumer 代码，并且我能够成功从 Kafka Topic 获取记录并能够处理这些记录。 我在应用程序日志中看到以下错误...

我怎样才能获得具有exactly_once_v2保证的Kafka Streams应用程序以与AWS MSK一起使用

当我配置了启用processing.guarantee=exactly_once_v2 的Spring Boot Kafka Streams 应用程序时，我在运行它时遇到问题。当我启动我的应用程序时，它最终崩溃了（我所有的...

Kafka 流重新分区将数据倾斜到单个分区 - 导致性能问题

我有一个用例，其中我必须根据有效负载值中的参数来计算事件数 流中的数据类似于 键 -> 字符串（不同且可以很好地扩展且唯一） 值 ->

Kafka流处理器什么时候提交？不记录日志我们能做到容错吗？

假设我有一个简单的处理器，可以输出每个键的最新记录，使用不一定与 Kafka 时间戳相同的内部版本（因此不可能压缩日志）。

KafkaStreams 指标，每个流处理的记录/提取拓扑中每个流的偏移量

我正在使用 org.apache.kafka.streams.KafkaStreams，例如我的拓扑如下所示： StreamsBuilder 构建器 = new StreamsBuilder(); builder.stream("输入主题1") .

kafka 流是从主题分组消息并进一步发送的良好解决方案吗

我正在开发 Kafka Streams 应用程序，我想对按键分组的主题中的数据进行批处理，并进一步发送分组的数据。我不完全确定 Kafka Streams 是否是一个很好的解决方案

Kafka 流如何在任务内执行并行操作？

假设我们有一个 kafka-streams 拓扑，例如： 输入主题 | | \ / Kstream-源 ...

如何调试kafkastreams代码？

有人设法使用 IntelliJ IDEA 调试用 Java 8 编写的 kafkastreams 代码吗？我正在运行一个简单的linesplit.java代码，它从一个主题获取流并将其分割并将其发送到...

Kafka Streams：获取时间窗口中的事件计数

我有数据流作为事件。我想获取 10 分钟时间窗口内的事件计数并输出到另一个主题。以下是我的代码 StreamsBuilder StreamsBuilder = 新

创建 Kafka Stream 以根据值计算金额

我正在生成如下数据： 键：“迈克”，值：{“金额”：46，“时间”：“2021-11-05T07：53：32.005751Z”} 键：“约翰”，值：{“金额”：46，“时间&

使用 Kafka Connect 生成整数 (INT32) 键

我不知道我是否在这里白费力气，并试图做一些完全毫无意义的事情，但我想我还是会问，因为我已经花了足够长的时间把头撞到一个砖瓦...