-
如何在同一主题上使用globalKtable和StateStore?
请澄清一下,我是Kafka的新手,很抱歉,如果我的问题似乎没有记载,我正在阅读教程,文档以及我能理 -
当我使用Kafka Streams时,我很困惑,如何指定要消费的topic-partition的偏移量?
例如。我有一个主题“ test”,带有4个分区。当我启动流应用程序时,过了一段时间,应用程序崩溃了 -
使用RocksDB-Cloud的Kafka流状态存储
是否可以将Kafka Streams配置为使用<a href="https://github.com/rockset/rocksdb-cloud" rel="nofollow noreferrer">RockesDB-Cloud</a -
Kafka流:左连接期间类强制转换异常
我是kafka的新手。我试图将kafka流(命名为<strong> inputStream </strong>)加入到kafka-table(命名为<strong> detailTa -
开窗后,Kafka Stream Suppress不产生输出
我正在窗口中查看流环境中的传入对象,并进行收集和打印。 使用kafka抑制可避免出现中间结果。 <p -
Kafka-stream:如何通过从值列表中选择密钥来重新密钥流
我有一个对象A: <pre><code>public class A { String id; List<String> otherIds; SomeOtherObject object; } </code></ -
Kafka DSL KStream变压器之间的Kafka共享状态存储
我有一个拓扑,其中我使用Transformer聚合对象,后来在我的拓扑中,我尝试从第一个Transformer中使用的状 -
可从Kafka Streams应用程序查询KSQL状态吗?
是否可以从单独的KStreams应用程序中通过键查询KSQL KTable?或者换句话说,可以通过编写另一个应用程序 -
Kafka Streams-杰森
我正在考虑执行以下操作。 <ol> <li> Topic1具有JSON数据 例如:<strong> <code>{"name":"alice -
Spring Cloud Streams-Apache Kafka活页夹-Avro反序列化异常-使用者
将<code>@StreamListener</code>注释与Apache Kafka Binder + Spring Cloud Streams一起使用时,推荐的处理反序列化异常的 -
无法实例化[org.springframework.cloud.stream.binding.BindingService]:工厂方法“ bindingService”抛出异常
我正在尝试使用Spring Cloud Stream和Apache Kafka作为流绑定器的事件驱动架构。 Spring Boot版本:2.1.9发 -
Kafka比较键的连续值
我们正在构建一个应用程序以从传感器获取数据。数据将流式传输到Kafka,消费者将从那里将数据发布到 -
KTable中的数据存储多长时间?
<a href="https://github.com/gwenshap/kafka-clickstream-enrich" rel="nofollow noreferrer">This</a>作为参考,存储在KTable对象中 -
可以将Apache Kafka“无限保留策略”用作具有CQRS的事件源系统的基础吗?
我目前正在评估用于设计/实现事件源+ CQRS体系结构系统设计方法的选项。由于我们要在其他方面使用Apac -
Spring Cloud Stream Kafka聚合使用自动装配bean的新实例
有没有办法在Kafka Streams聚合中使用Autowired bean的新实例? <pre><code>@EnableBinding(Processor.class) public class -
如何增加拓扑中处理记录的线程数?
我有一个拓扑: <pre><code>Topology builder = new Topology(); builder.addSource("source",stringDeserializer,st -
问题是如何在不使用交互式查询的情况下访问Window的先前状态
创建一个包含列表的SessionWindow集合输入数据groupBy键,将集合值存储在KTable中。 对于每个关键数据 -
如何将kafka流从一种类型转换为另一种类型
如何将KStream转换为另一个KStream?由于我的流中有多个转换,因此无法在配置中为DEFAULT_VALUE_SERDE_CLASS_CONF -
如何在kafka流应用程序/中进行REST API调用
时间序列数据是在kafka主题中生成的。我需要读取每条记录并用数据库中的一些数据进行修饰,并最终调 -
终止使用Kafka-Streams和MongoDB的Spring Boot应用程序
我有一个使用Kafka-Streams的Spring Boot应用程序。详细地说,有一个流使用MongoDB中执行的查询结果过滤接收 -
错误:无法更改Changelog Kafka主题的segment.bytes
您好,我们使用静态微服务kafka流,恢复这些微服务需要很多时间,有时,部署在pods中的所有微服务都 -
Kafka Streams:如何确保在处理完成后提交偏移量
我想使用Kafka流处理存在于Kafka主题中的消息。 处理的最后一步是将结果放入数据库表中。为了避 -
Spring Cloud Stream Kafka KTable作为输入不起作用
Spring Cloud Stream Kafka,KTable作为输入不起作用 <strong> Sink.java </strong> <pre><code>public interface Event -
有关prevent()方法的卡夫卡流问题
我想使用<code>windowby()</code>和<code>count()</code>方法来获取请求计数,然后在<code>toStream()</code>方法之后显 -
Kafka Streams-最近X分钟的汇总
我有一系列点击事件。每个事件代表一个点击广告的用户。 对于每个事件,我想知道用户在过去2 -
如何确保Kafka流正在汇总当天的数据
我有一个streams应用程序,用于计算传入交易的高/低/交易量。 我有一个包含交易信息的输入主题。没有 -
卡夫卡一键式或多键流式播放
我正在使用1.5.4弹簧启动,Java 8和kafka 2.2.0版本。我有5个经纪人和每个50个分区的4个不同主题。 我 -
备用任务保留在AssignedTasks中的“创建的”哈希图中
我们正在使用kakfa stream 1.1.0版本 我们对kafka流代码进行了一些更改。我们正在生产环境中观察以下 -
Kafka Stream-弹性扩展的工作方式
我正在阅读有关Kafka Stream-弹性缩放功能。 意味着Kafka Stream可以将任务切换到其他实例,并且将使 -
Kafka将应用程序流式传输到内存
我们构建了具有相当复杂拓扑的Kafka-Streams应用程序: <pre><code>Sub-topology: 0 Source: KSTREAM-SOURCE-000