-
如何构建融合的卡夫卡消费者?
我正在使用<a href="https://github.com/confluentinc/confluent-kafka-go" rel="nofollow noreferrer">confluent-kafka-go</a>来写kafka -
为什么我的产品无法完成冲洗方法?
我的程序卡在了generate.flush中,并且合流控制中心中没有相应的消息。 <pre><code>from confluent_kafka import -
如何在confluent-kafka-go中创建具有多个消费者的消费者群体?
由于我是Go和kafka的新手,因此我需要使用confluent-kafka-go模块实现消费者群体。谁能帮我吗? 预先感谢 -
当Broker关闭,然后稍后恢复活动时,Kafka Consumer不会收到“旧-未成功提交”消息
我正在使用confluent.kafka dotnet Nuget软件包 Nuget版本1.2.1 操作系统:Windows 10 消费者配 -
librdkafka批处理使生产者暂停产生消息
我们有一个工具,每秒可产生数千个事件。但是,它实际上并不会每毫秒创建一批消息以达到目标TPS。 -
C#.net核心Confluent.Kafka Avro反序列化
我有一个使用avro生成的类。 avrogen -s customer-v1.avsc。 使用Confluent.Kafka nuget软件包。 我可以序列化Cu -
升级至python 3.7后无法建立与Kafka的SSL连接
使用Python 3.7.3时,我使用Python 3.6.7中的SSL连接成功连接到Kafka的代码失败,错误消息为<code>SSL: WRONG_VERSION -
Confluent 11.5 C#.net Kafka订阅请求挂起
位于的代码 <code>var result = deliveryReport.Result;</code> 无限期地挂起。该代码一直工作到本周末为止,然后突 -
在架构中包含数组时,将Avro GenericRecord与Confluent.Apache.Avro C#结合使用
我具有以下包含avro数组类型的架构。 <pre><code>{ "type" : "record", "name" : "Personal -
如何为卡夫卡消费群生成唯一的ID?
我有一个<code>.NET Core Api</code>,我希望能够接受HTTP请求并将请求者订阅多个Kafka主题。 阅读Kafka文 -
如何使用Python confluent_kafka管理员NewTopic * args或** kwargs来微调主题配置
如何使用Python confluent_kafka管理员NewTopic * args或** kwargs来微调主题配置? 这是我发现的基座字符串 -
producer.poll(0)不会产生任何消息,但是producer.flush()可以工作
当我使用<code>producer.flush()</code>时有效,但根据<a href="https://github.com/confluentinc/confluent-kafka-python/issues/137" -
Python Confluent-Kafka SSL配置
已经创建了一个基本的Confluent-Kafka生产者和消费者来发送纯文本消息。 从生产者向消费者成功发 -
模拟Kafka API进行单元测试
我想在GO中为消费者和生产者使用Confluent Kafka API进行单元测试,是否有任何方法(过程/步骤/库)成功模 -
JSON列作为kafka生产者中的键
我们知道,我们可以发送带有kafka生产者的密钥,该密钥在内部进行散列,以查找主题数据中的哪个分区 -
如何使消耗方法成为汇合点数卡夫中的非阻塞
我使用Confluent Kafka .Net库1.2.1版,我已经实现了使用者来消费主题中的消息,问题是Consume方法阻塞了主线 -
无法加载类型Confluent.Kafka.Serialization.StringDeserializer
<a href="https://i.stack.imgur.com/0pr13.png" rel="nofollow noreferrer"><img src="https://i.stack.imgur.com/0pr13.png" alt="enter image -
烧瓶gevent线程卡在kafka使用者上
我们有一个flask应用程序,在gevent worker模式下使用gunicorn进行部署。 该应用程序本身只收听很少的REST API