-
KTable 数据 - 字节打印
我在 Kafka 中有一个 KTable,当我调试时,我以字节为单位获取数据。 如果我想要它在字符串中,我 -
使用 SpecificAvroSerde 从 kafka 读取事件时出错
从 kafka 主题读取事件时出错 <块引用> 'org.apache.kafka.common.errors.SerializationException:错误 为 id 4494 反 -
如何使用 PartitionAssignmentHandler 刷新 Kafka 偏移量
我们正在使用类似于以下示例的内容来处理我们的 Kafka 事件: <pre><code>Consumer .sourceWithOffsetContext(c -
Kafka Streams 将事件写回输入主题
在我的 kafka 流应用程序中,每当处理逻辑中抛出特定类型的异常时,我都需要重新尝试处理消息。 <p -
使用 Kafka Binder 在 Spring 云中打印 JsonObject
我是 Spring Cloud 和 kafka 流的新手。我正在尝试使用 kafka 活页夹设置 spring 云应用程序。我尝试在本地测 -
KTable 表 - 了解连接
我是卡夫卡的新手。我正在学习联接。 我有一个消费者,它使用一个主题,以 JSON 格式提取有效负 -
如何进行 Kafka Streams Left Join,在固定时间段后返回没有相应 RHS 的 LHS 消息?
我是 Kafka Streams 的新手。我刚刚在流 A 和流 B 之间建立了一个左连接。在我的设置中,每个 A 都有一个 B -
kafka 流 taskId 含义
有人可以解释如何读取 kafka 流 taskId,即 2_0 或 0_0。我知道第二个数字是一个分区,但第一个数字是什么 -
NoSuchMethodError: void org.apache.kafka.common.metrics.Sensor.add
我正在尝试通过使用主题来创建 <code>KTable</code>。之后我想使用 <code>KafkaStreams</code> 来构建我的拓扑(代 -
Kafka 自定义解串器
到目前为止,我已经能够在一个主题的帮助下创建一个 KStream。 <pre><code>KStream<String, Object> testqa2 -
阻塞停止世界之巅 vs 持续流增量粘性再平衡,用于消费者组自动缩放
我正在 kubernetes 上运行一个简单的 kafka 消费者组反应式自动缩放实验,同时在第一次运行时利用世界分 -
Confluent平台中Kafka心跳相关的日志在哪里?
我可以在位置 <code>/var/log/kafka.log</code> 中找到以下错误 <块引用> [2021-07-28 05:15:16,801] INFO [GroupCoordina -
如何确定 Kafka Streams 的正确参数
核心应用程序处理一条记录平均需要 500 毫秒。 我尝试了以下模式。不幸的是,我无法摆脱重新平 -
使用 @KafkaListner 而不是 @StreamListener
我想使用@KafkaListener 进行流式处理 如何使用 @KafkaListner 而不是 @StreamListener ? <pre><code>@StreamListe -
如何确保多个 Kafka 拓扑对所有主题具有相同的分区分配?
我有一个用例,我们在同一个应用程序中定义了多个 Kafka 拓扑。我正在运行我的应用程序的多个实例( -
如何在kafka流的键中使用几个字段,加入流和表?
我有来自主题的优惠券信息流: <pre><code>CREATE STREAM personal_coupons (Coupon VARCHAR KEY, CouponType VARCHAR, Marketi -
Kafka Confluent InvalidConfigurationException:未经授权;错误代码:401
我正在使用来自 kafka Confluent 架构注册表的 SpecificAvroSerde 读取架构。但我在下面收到此错误: <pre><cod -
设置的属性在 Kafka Streams 中不起作用
我对 Kafka Streams 中的属性有疑问。例如,如果我在拓扑节点中设置此属性: <pre><code> Properties con -
KStream copartition 加入具有不同模式名称的 avro 键
我正在对两个 kafka 主题 A 和 B 进行联合分区。 A 的 Avro(AVDL) 密钥架构: <pre><code>record AKey { lo -
如何在日志中找出Kafka流应用程序重新平衡的原因
我的 Kafka 流应用程序经常不断地重新平衡。我在这里有几张红色的票,以及关于不同解决方案的博客文 -
如何在Kafka中查询GlobalState Store
我需要从多个应用程序实例查询全局存储。我希望所有存储数据可供所有实例查询。 LocalStore 似乎 -
卡夫卡流间歇性 isDisconnected
我的日志中有一个间歇性问题。 似乎心线一直在挣扎和获取 <pre><code>Error sending fetch request org.apa -
是否可以仅使用 kafka-client 在 spring boot 中运行 kafka,例如没有 spring-kafka?
我正在 spring boot 中创建一个 kafka 流 api 应用程序,我不想使用 spring-kafka 依赖项。是否可以仅使用具有