我按照示例创建了一个新的win32控制台项目。我发现，除非我在程序的末尾添加getline()函数，否则API对我不起作用。如果我删除getline()，则produce(..)方法仍然返回成功的结果。但是，我在kafka-console-consumer的命令窗口中看不到任何响应我找到了为什么它不能工作。删除生产者对象似乎太快，导致生产者无法向代理发送消
浏览 5提问于2017-06-11得票数 3
回答已采纳
似乎大多数流行的.net客户端()缺少设置和创建主题的方法。当调用Producer.ProduceAsync()时，主题是自动创建的，但我找不到一种方法来设置分区、保留策略和其他设置。我试图在网上找到任何示例，但我找到的都是默认值。
也许有另一个.net客户端可以代替我使用？
浏览 4提问于2018-04-27得票数 6
回答已采纳
我正在使用librdkafka stderr API，并且我想要更改c++的默认行为(默认为stderr)。配置文档中列出了我可以更改log_cb函数，但我找不到如何在c++应用程序接口中执行此操作。
在c中，有一个函数rd_kafka_conf_set_log_cb()来设置日志回调。
浏览 8提问于2017-01-22得票数 0
回答已采纳
2回答
在我的应用程序中，我们使用Kafka高级用户，如果生产者和使用者使用java对数据进行压缩和解压缩，它将使用解压缩数据，而不会出现任何问题。如果生产者使用librdkafka C++ API进行压缩(无论是snappy还是GZIP)，会发生什么？java使用者是否像上面提到的那样透明地解压缩。消费者端的获取大小会发生什么？这也是
浏览 0提问于2015-01-22得票数 1
回答已采纳
1回答
自定义记录器，函数签名
、、、
我正在使用librdkafka c++ API，我希望更改记录器的默认行为。void(*)(const rd_kafka_t *rk, int level, const char *fac, const char *buf)
但是，我不知道const*fac在函数签名中</em
浏览 5提问于2021-11-26得票数 0
回答已采纳
2回答
我使用C++卡夫卡库来生成/使用卡夫卡消息--一切都很好。除了由一个组中的所有消费者共享的group_id之外，每个使用者还会得到一个临时的、唯一的consumer_id (表单主机名:uuid)，用于标识目的。，“topicN”：#stre
浏览 3提问于2016-04-27得票数 3
2回答
我们对Kafka (Apache)队列的持续集成测试在本地机器上运行得很好，但是在Jenkins CI服务器上，偶尔会出现这样的错误：%3|1508247800.270|ERROR|art#producer违规代码是
浏览 3提问于2017-10-17得票数 1
我使用kafka-node 接口来创建kafka主题。我不知道如何创建一个带有分区的kafka主题。var kafka = require('kafka-node'), client = new kafka.Client(),producer = new Producer(c
浏览 2提问于2017-11-06得票数 5
一些背景:我正在研究我们团队中的其他开发人员将使用的一些python模块。每个模块的一个共同主题是将一条或多条信息发布给卡夫卡。我们打算在这个时候使用融合卡夫卡客户。在我们的组织中，我们对python开发非常陌生--我们传统上一直是一个.NET商店。复杂之处在于:虽然我们创建的代码将运行在Linux ( their 7)上，但大多数开发人员将在Windows上完成他们的</
浏览 14提问于2016-10-06得票数 7
我一直试图在C++中使用VsCode in MacOS (Catalina version 10.15.7)为Kafka构建一个简单的消费者，但我遇到了同样的链接错误。我试图在这里找到一些答案，但我找到的答案对我没有用(例如，)，因为我可以正确地构建卡夫卡。首先，我使用brew使用
浏览 0提问于2021-07-29得票数 1
回答已采纳
1回答
我一直试图通过C# Apache汇合API找到连接IBM的文档，但没有成功。github上的官方回购没有C#的样本。是否有人能够使用C#与ibm通信，如果是的话，您可以共享这个过程。
private static Dictionary},
{"ssl.ca
浏览 2提问于2017-06-29得票数 0
回答已采纳
我创建了一个生产者和一个消费者，使用“Kafka节点”包发送和消费来自kafka主题的信息。生产者和消费者通过API调用。POST方法用于向主题发送消息，而GET方法用于在使用者处从主题获取消息。当我在向KAFKA发送消息之后调用消费API时，所有以前的消息都在consumer.on('message', function(message){})中</e
浏览 6提问于2021-12-15得票数 0
1回答
我想知道这里的研发人员是否有使用.NET的卡夫卡经验，下面的代码片段来自一个客户端，它是用Java编写的。似乎卡夫卡的Java库比.NET的要丰富得多，我想要做的是在客户端的远程服务器上启动一个卡夫卡生产者，这样就可以通过卡夫卡生产者传递RTA状态。我需要做的是在.NET中重新创建下面的代码，特别是最后一行'openInterfaces
浏览 1提问于2018-04-11得票数 2
kafka-python (1.0.0)在连接到代理时抛出错误。我使用的是文档中的基本示例：from kafka.common import KafkaError
self.
浏览 21提问于2016-02-29得票数 14
基于的内容(回调类型)，我必须将其放入相应的传出主题(例如账单-n-cdr，dr-cdr，.)。我在互联网博客上看到的所有例子，用阅读源主题和其他目的地主题的上下文来解释热气腾腾的应用程序。那么，这是否可以从非主题源(例如redis存储)或消息队列(<em
浏览 4提问于2022-06-10得票数 0
我有一个本地设置卡夫卡在我的windows 10机器。目前，我仍然在学习卡夫卡，并在我的本地机器上测试它的能力。.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
.我读过关于的文章，但不知道如何在</
浏览 5提问于2021-05-05得票数 0
回答已采纳
我想将输入从Django传递给Kafka。我有字段a，b，c，d和h1，h2和h3。所有字段都是来自用户的输入。我想启动我的卡夫卡进程，一旦用户进入提交按钮在我的Django前端界面。所有字段都保存在Mysql中。是否有任何方法或连接器可以使用python将用户在Django界面上的输入传递给kafka？
浏览 2提问于2018-04-02得票数 13
我正试着用AWS做我的第一次尝试package main
"bufio" "fmt" } lambda.Start(HandleRequest)注1:我有一些函数使用ka
浏览 0提问于2018-08-24得票数 1
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号