与Apache Kafka的内置流处理引擎相关,称为Kafka Streams,它是一个用于使用Apache Kafka构建分布式流处理应用程序的Java库。
我知道 Kafka Streams 使用 Murmur3 来散列消息的值以解决竞争条件。但这也意味着如果我们改变消息的结构,连接就会失败,因为......
要求确认我的推理是否正确。 我的应用程序有 12 个输入分区,分布在 3 个应用程序实例中。 通常情况下,我希望线程数设置为 4,因为 4
我对 kafka 流完全陌生,我正在尝试在 quarkus 应用程序中使用它。 我尝试像数据库表一样使用它。 我想知道这是否是正确的方法以及是否有......
org.apache.kafka.streams.KafkaStreams#store 方法线程安全吗?
在我的 Kafka Streams 应用程序中,我有以下 2 个线程: 线程 A:这会创建一个 Topology 对象,包括状态存储和所有内容,然后最终调用 KafkaStreams 的构造函数
KStreams 在 Spring Cloud Stream 中运行速度非常慢
我已经在Spring boot中使用SpringCloudStreams实现了KStreams。 我已准备好从具有 20 个分区的主题写入具有相同分区数的主题。我有 2 个 Pod 正在运行。 平均...
我有使用 spring-kafka 和 kafka-streams 的 Java Spring-boot 应用程序。 我正在尝试使用以下命令构建 GraalVM 本机映像 mvn -Pnative spring-boot:build-image 构建成功,但是当我尝试时...
StreamsBuilderFactoryBeanCustomizer 未自定义 StreamsBuilderFactoryBean
我有带有 Kafka 流的 springboot 应用程序,其中我肯定主要的 bean 如下。 @豆 公共 StreamsBuilderFactoryBeanCustomizer StreamsBuilderFactoryBeanCustomizer(CustomStateListener
我正在使用kafka处理器api,我从3个分区的主题创建一个状态存储(我有3个经纪人),我有1个流实例。我想知道当我到达当地的国营商店时,我可以买到所有的东西吗...
我有一个名为 A 的 Kafka 主题。 主题A中的数据格式为: { id :1,名称:stackoverflow,created_at:2017-09-28 22:30:00.000} { id : 2, name:confluence, 创建时间:2017-09-28 22:00:00.000} { ID ...
如何获取Kafka Streams InMemoryWindowStore中键值对的数量
获取 InMemoryWindowStore 中键值对的数量(如果可能的话,还可以获取窗口的数量)的最有效方法是什么?我想定期捕获该号码
如何动态生成 Kafka 流中多个主题的单个事件? 我遇到了 TopicNameExtractor,但它一次只返回 1 个主题。 有没有其他方法可以生产...
如果没有状态存储并且仅使用无状态操作,命名 Kafka 流处理器有什么好处吗?看起来唯一的好处是漂亮的“Topology#desribe()”输出? 如果我...
我是 KSQL 和 Apache Kafka 的新手。 我正在尝试解决我的表如何不断返回 null 的问题,因为表和流的数据类型相同。 链接到 avro: https://github.com/confluenceinc/
我创建了一个 3 VM Kafka 集群,并在每个 VM 上安装了 mongoDB。另外,运行 kafka-mongoDB 连接器。 我在第一个虚拟机上的源连接器配置是: { “名称”:“来源1”, ...
google.protobuf.struct.proto 上的 Kafka 架构注册表 409s
我正在使用 Protobuf 作为消息模式构建 Kafka Streams 应用程序。目前,应用程序本身只是从一个主题传递到另一个主题。 我使用 Confluence 在本地运行 Kafka
我需要在 Python 中使用 Kafka 流,并且我正在分析可用的不同库。这个问题提供了一些很好的答案,看起来 Faust 分支是最完整的 Kafka
我有一个要求,我必须根据某些条件评估将kafka流路由到多个主题。我遇到了TopicNameExtractor接口,但它只支持单个主题。是吗...
我在Java中使用过Kafka Streams。我在 python 中找不到类似的 API。 Apache Kafka 支持 python 中的流处理吗?
无法使用 GPKAFKA 在 GreenPlum 中插入数据
我在使用 GPKAFKA 从 KAFKA 读取数据并将数据插入 GreenPlum 数据库时遇到问题。我的目标表有多个不同数据类型的列和外部表...
过去,我使用 Spring Kafka Streams 进行分组和聚合,并且工作非常顺利,但现在有一个可能的用例,我不确定如何根据需要进行工作。 使用c...