apache-kafka-streams - 编程之家

我正在寻找有关属性的说明，我们可以使用这些属性来避免生产者超时，因为自从创建具有阻塞批次的

我正在加入KStreams，因此需要设置 JoinWindows 。联接的数据已根据 CustomTimestampExtractors 计算

因为我不知道我的<a href="https://stackoverflow.com/questions/64318358/kstream-kstream-join-less-resulting-records-than-expected">

我们正在通过Spring Cloud Stream集成使用Kafka Streams。通过设置，我将复制因子配置为在所有内部Kafka Strea

当我正在运行的节点<code>io.projectreactor.kafka:reactor-kafka:1.1.0.RELEASE</code>过载时，有时会发生使用者丢失分

我想知道是否有人知道一个好的解决方案，用于指定应在Kafka Streams应用程序的一个实例上管理的最大聚

我们正在使用JDBC源连接器将数据从表同步到Kafka中的主题（称为主题1）。我们知道这仅捕获插入和更新

在Kafka Streams + Spring Boot应用程序中配置（提供主机和端口信息）并访问交互式查询的“惯用”方式是什

我有一个用例，我收到点击流，我需要使用来自Cassandra的数据进行某些计算，最后将计算出的值推送到Re

我构建了一个Spring Boot应用程序，用于使用Spring Cloud Stream，Spring Kafka之类的依赖项来访问Kafka。当前，我

我是kafka stream的新手，最近在我的项目中使用streamDsl。让我们举一个我想实现的例子。 <pre><code>before

我正在使用Protobuf构建用于消息模式的Kafka Streams应用程序。目前，应用程序本身只是从一个主题到另一

我在用户输入中应用了一些过滤器，并且一旦我可以确定我知道编码时的过滤器数量（以下代码中为2）

我正在使用<code>python 3.6.8</code>和<code>kafka-python=2.0.2</code> 是否可以通过python代码设置主题的分区数

嗨，我在下面有一个json。 <pre><code>{ "Obj1": { "a": "abc", "b": "def",

我正在实现Spring Java应用程序，该应用程序需要使用事件（表示事务），按userId（这是键）对它们进行分

我正在尝试通过发出（“键”，空）键-值对来删除（压缩）压缩主题中的某些记录，通过压缩将在一段

我是<a href="https://en.wikipedia.org/wiki/Apache_Kafka" rel="nofollow noreferrer">Kafka</a>的初学者。因此，在学习它的过

我正在尝试在KafkaStreams顶部构建重试机制： <a href="https://i.stack.imgur.com/mP4rG.png" rel="nofollow noreferrer"

有了弹簧云，我看到我们可以定义用管道分开的组合函数。我想知道Spring Cloud kafka stream 活