-
S3中PARQUET格式的Kafka S3源连接器
我有使用 Protobuf 生成的主题事件。我可以使用 Parquet 格式的 S3 Sink 连接器成功地将我的主题事件沉入 S3 -
设置的属性在 Kafka Streams 中不起作用
我对 Kafka Streams 中的属性有疑问。例如,如果我在拓扑节点中设置此属性: <pre><code> Properties con -
kafka连接hdfs sink连接器如何保证exactly-once交付?
<a href="https://docs.confluent.io/kafka-connect-hdfs3-sink/current/overview.html#exactly-once-delivery" rel="nofollow noreferrer">https: -
将 Zio-Kafka 消费者与 Zio-Json 反序列化器集成
我正在研究库 <code>zio-kafka</code>,我想使用 <code>zio-json</code> 以 JSON 格式反序列化消息的值。 我有 -
无法在键盘中断后正常关闭 Asyncio 应用程序
当用户通过按 <kbd>Ctrl</kbd>+<kbd>C</kbd> 创建 <code>asyncio</code> 时,我无法让我的 <code>KeyboardInterrupt</code> 应 -
在 Reactor Kafka 中使用基于分区的排序进行并发处理
我正在开发一个示例应用程序,该应用程序将从 Kafka 主题的不同分区读取,并发处理基于分区排序的记 -
Kafka、Docker-Compose、Bootstrap 代理断开连接
我正在尝试使用 docker-compose 启动 kafka 服务。我使用卡夫来摆脱动物园管理员。我正在做的只是为了发展 -
KStream copartition 加入具有不同模式名称的 avro 键
我正在对两个 kafka 主题 A 和 B 进行联合分区。 A 的 Avro(AVDL) 密钥架构: <pre><code>record AKey { lo -
在 Apache Flink 中流式处理商店订单?
我学习流处理数据,想知道在用户下订单时如何连接数据。 订单数据发送到Apache Flink。如果客户在 -
Spring Cloud 数据流 Kafka 源
我是 Spring Cloud Data Flow 的新手,需要监听来自外部 kafka 集群的主题消息。融合云中的这个外部 kafka 主题 -
如何在 Apache Flink 的连续流作业中抑制我不关心的字段更改的记录?
我试图理解为什么在我的工作中使用 <code>upsert-kafka</code> 源时,我看到的记录基本上是重复的。 假 -
如何在Kafka中查询GlobalState Store
我需要从多个应用程序实例查询全局存储。我希望所有存储数据可供所有实例查询。 LocalStore 似乎 -
获取每个组的Kafka消费时间
我想获取Kafka中每个组的每条消息的消耗时间,但我不想要consumer_offsets主题中持久化的提交时间,因为 -
Kafka 消费者如何处理部分提交的事务?
我正在尝试准确理解 Kafka 事务保证。据我从 <a href="https://docs.google.com/document/d/11Jqy_GjUGtdXJK94XGsEIK7CP1SnQGdp2 -
优化从 Filebeat 到 Kafka 的事件分发
我正在使用 Filebeat 从日志文件中获取事件,然后将它们发布到 Kafka 主题。这是一个多集群 Kafka 设置, -
带有pyspark的kafka readStream无法连接
我正在处理 kafka 主题并尝试使用 pyspark 在我的本地机器上创建一个 readStream。 我已经通过 home-brew -
为什么 kafka-0.9 同一组中的多个消费者消费相同的消息
个人资料: <pre><code>spring.kafka.consumer.bootstrap-servers=127.0.0.1:9092 spring.kafka.consumer.group-id=home spring.kafk -
Mongo 变更流 + Kafka vs Monga kafka 连接器
在使用 Mongo Kafka 连接器 vs Mongo 更改流 + 单独的 Kafka 发布者方面是否有任何偏好? Mongo Kafka 连接器中是 -
如何让AIOKafkaConsumer从具有一定值的最新消息开始消费Kafka Topic
如果应用将 JSON 对象/字典 <code>payload</code> 发布到 Kafka 主题 <code>test</code>,其数据包含 <code>"type": -
在融合模式注册表中,哪个更好的自动注册模式或手动注册?
我试图了解融合的模式注册表和其中的模式演变。我找不到以下哪个更好。首选使用什么以及何时使用 -
是否可以仅使用 kafka-client 在 spring boot 中运行 kafka,例如没有 spring-kafka?
我正在 spring boot 中创建一个 kafka 流 api 应用程序,我不想使用 spring-kafka 依赖项。是否可以仅使用具有 -
我可以使用 ZSink 在 Zio-Kafka 中提交偏移量吗?
我正在使用库 <code>zio-kafka</code> 学习 ZIO 与 Apache Kafka 的集成。在 <a href="https://github.com/zio/zio-kafka" rel="nof -
配置使 Kafka client.id 成为必需
Kafka消费者中的client.id是可选的,那么有什么办法可以强制消费者在连接和消费消息之前设置它? -
创建死信队列
如何创建死信队列并对其进行测试?我有一个生产者和消费者。我还有生产者配置,如确认、重试。