-
如何传递队列名称以发送消息中间件
是否可以为SendMessageMiddleware设置主题? 当使用者无法处理消息时,将消息发送到重试,SendMessageMiddleware -
有关分配偏移量时的错误的问题
我编写了一个Kafka使用者函数,该函数首先从读取的最后一个偏移量中检索消息,然后开始使用下一个偏 -
librdkafka使用者未收到来自代理的消息
我使用librdkafka库用C语言编写了kafka的消费者和生产者。 Kafka经纪人版本为kafka_2.12-2.3.0。生产者正在成功 -
如何在confluent-kafka-go中创建具有多个消费者的消费者群体?
由于我是Go和kafka的新手,因此我需要使用confluent-kafka-go模块实现消费者群体。谁能帮我吗? 预先感谢 -
librdkafka批处理使生产者暂停产生消息
我们有一个工具,每秒可产生数千个事件。但是,它实际上并不会每毫秒创建一批消息以达到目标TPS。 -
librdkafka生产者的内部队列-它们如何工作?
我对使用librdkafka的GoLang Kafka生产者有一些疑问- 这些基于我在设置debug:all时在生产者日志中看到的日志 -
LibrdKafka Producer无法在TLS通信中与KafkaBroker(Java)通信
<ul> <li>我已经为Java KafkaBroker创建了KeyStore,并为librdKafka创建了必需的证书,当这些组件尝试与SSL / TLS通信 -
Amazon Linux:节点rdkafka安装程序不起作用
请在下面找到操作系统详细信息 <pre><code>VERSION="2017.03" ID="amzn" ID_LIKE="rhel fedora" VERS -
错误:配置属性“ security.protocol”的值“ sasl_ssl”无效)
当尝试使用golang连接到kafka使用者(在Centos中为kafka_2.11-2.0.0)时,出现以下错误: <pre><code>[ 2019_12_12 -
有没有一种方法可以在使用node-rdkafka库生成消息时传递带有标头的tenantId?
我正在为我的一个应用程序使用<strong> node-rdkafka </strong>库。 因此,我有一个要求在生成消息时将<strong> -
如何传递多个groupid和主题对以与node-rdkafka一起使用?
我正在为其中一个应用程序使用<strong> node-rdkafka </strong>。 我想使用groupid使用来自多个主题的消息。(gr -
如何在单个应用程序中对具有多个分区的一个主题实现并发? (库节点-rdkafka)
场景: 我正在使用<strong> node-rdkafka </strong>库来创建一个应用程序,该应用程序将处理来自消费者 -
有时,node-rdkafka使用者未从主题中读取任何消息
以下代码段工作正常。 <strong> <em>但有时它不是从Kafka主题中读取消息</em> </strong>。我没有任何错误。在K -
如何使用librdkafka为纯文本协议(无SASL)设置用户名和密码?
我正在尝试将具有<code>security.protocol</code> conf属性的生产者连接到纯文本。 如何在调用<code>username</code> -
Avro C和librdkafka-消费者实施;获取NULL以解析字段的值-始终
代码示例 <pre><code>KEY = (char *)malloc(sizeof(argRkMessage->key)+1); if( KEY != NULL ) { //Logger } -
librdkafka partition.assignment.strategy添加新策略
今天使用librdkafka的<strong> <em> partition.assignment.strategy </em> </strong> <a href="https://github.com/edenhill/librdkafka/blob -
卡夫卡avro消息使用者问题avro字符串值即将为空
我使用librdkafka得到了kafka消息。 kafka消息采用已编码的avro格式。我正在使用libavro消费avro消息。从librdkaf -
与群组协调器断开连接后,Kafka Consumer无法重新连接
这是每1秒进行一次高级消费者轮询。会话超时10秒。心跳间隔3秒。 我期望使用者在会话超时后自动重新 -
如何在librdkafka中正确重新发送失败的消息?
<pre><code>static void DeliverCallback(rd_kafka_t *rk, void *payload, size_t len, rd_kafka_resp_err_t error_code, void *opaque, void *msg_ -
如何将librdkafka有效负载转换为json以获取参数值?
我正在为librdkafka使用<a href="https://github.com/edenhill/librdkafka/blob/master/examples/consumer.c" rel="nofollow noreferrer">co -
librdkafka:rd_kafka_assignment返回分配的分区的偏移量-1001
当我向消费者查询分配的主题分区列表时,结果中的所有分区的偏移量都为-1001。 如果我打印出接收到 -
如何在node-rdkafka中一一阅读消息
我正在使用node-rdkafka(<a href="https://github.com/Blizzard/node-rdkafka" rel="nofollow noreferrer">https://github.com/Blizzard/no -
集群关闭并重新启动后,Kafka Consumer是否重新连接并重新订阅主题
使用librdkafka(高级消费者)的<ka> kafka消费者连接到kafka集群并订阅了10个主题和消费数据。有分配分区事 -
用于Kerberos身份验证的librd Kafka配置设置
我的目标集群启用了kerberos。通过控制台,生产者连接正在工作。 <pre><code>./kafka-console-producer.sh --brok -
如何使用librdkafka设置Kafka消息的最大大小
我正在尝试使用Kafka发送〜10Mb的消息。我知道它的默认大小是1Mb,但这是一个硬限制吗? librdkafka可以支 -
无法通过管道从源代码(pypi)安装confluent-kafka 1.4.0-似乎没有解决方法
在pypi上似乎有<a href="https://github.com/confluentinc/confluent-kafka-python/issues/830" rel="nofollow noreferrer">issue</a>与<a h -
Confluent.Kafka用于UWP应用。 (HoloLens)
我正在为Hololens创建UWP应用程序,我需要Kafka-Client。我使用来自confluent-kafka-dotnet(<em> <a href="https://github. -
瞬态“本地:经纪人运输失败”
我在librd Kafka Consumer上有一个薄包装,它有一个单独的轮询线程,该线程将调用consume方法。 应用 -
具有自动提交功能的KafkaConsumer CPP API Assign()
我有一个CPP Kafka使用者,它使用assign指定分区。由于我使用assign()分配分区,而不使用我擅长的subscrib -
无法在docker上运行librdkafka = 1.3.0
我试图使用以下方法通过我的docker容器从阿尔卑斯发行版运行librdkafka版本1.3.0: <pre><code>FROM golang:1.1