2回答
我正在编写一段代码，每隔几毫秒就需要读取卡夫卡的数百条信息。我用的是C++和图书馆员。当我的程序停止，然后重新启动时，它不需要恢复所有丢失的消息，因为它已经停止了，而是需要始终从最新发送的消息中读取。使用这两个值时，我发现如果我将enable.auto.commit设置为false而不提交任何偏移量，而将auto.offset.reset设置为latest，则似乎总是检索最新的消息；但是这个解决
浏览 9提问于2022-01-13得票数 1
回答已采纳
-1| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1%7|1564230563.245|INIT|rdkafka#producer-1| [thrd:app]: librdkafka v1.1.0 (0x10100ff)
浏览 0提问于2019-07-27得票数 5
回答已采纳
1回答
std::this_thread::sleep_for(std::chrono::seconds(1));应用程序日志%7|1582884541.326|BROKER|rdkafka-2| [thrd:app]: 127.0.0.1:9092/bootstrap: Added new broker with
浏览 2提问于2020-03-06得票数 1
回答已采纳
std::string topic_str = "sample";int32_t partition = 0;RdKafka::Conf *tconf = RdKafka::Co
浏览 1提问于2016-10-05得票数 1
回答已采纳
1回答
#producer-1| [thrd::0/internal]: :0/internal: Enter main broker thread%7|1562193919.21
浏览 0提问于2019-07-03得票数 1
回答已采纳
1回答
我遵循了中的文档，最后显示了
PHP警告:无法加载动态库“rdkafka.so”(尝试: /usr/lib/ PHP /20170718/rdkafka.so (/usr/lib/php/20170718/rdkafka.so:无法打开共享对象文件:没有此类文件或目
浏览 4提问于2021-10-02得票数 0
Source=RdKafka StackTrace: bei RdKafka.Internal.SafeConfigHandle.Create() beiSource=RdKafka
TypeName
浏览 0提问于2016-05-27得票数 0
当我运行我的消费者组时，我总是有这样的统计数据：
2016-10-15 13:56:17.925: "STATS": { "name": "debian-meox#producer-2", "type": "producer", "ts":16768436761, "time":1476532577, "replyq":0, "msg_cnt":75428, "msg_size":29314007, "msg_max":
浏览 2提问于2016-10-15得票数 1
1回答
生成时对sasl_x的未定义引用
、、、、
我试着用图书馆库和gcc一起编写我的程序，
函数//usr/local/lib/librdkafka.a(rdkafka_sasl_cyrus.o)：In rd_kafka_sasl_cyrus_close': /home/ilan/librdkafka-master/src/rdkafka_sasl_cyrus.c:409: undefined:74: undefined refer
浏览 0提问于2018-03-23得票数 1
回答已采纳
1回答
我在structs中定义了一组Thrift，如下所示： 1: i32 a,}(a)将Foo实例序列化为与Binary兼容的字节(使用Binary协议或Compact协议)问题提前感谢
浏览 3提问于2017-03-18得票数 3
回答已采纳
1回答
我正在尝试在linux服务器上的Drupal9站点上安装rdkafka，我尝试了以下命令 sudo apt install php-pear
sudo apt-get install -y librdkafka-devsudo pecl install rdkafka 然后我将这个添加到php.ini extension=rdkafka.so 但当print phpinfo()；rdkafka库尚未安装时
浏览 54提问于2021-06-25得票数 1
1回答
rdkafka_timer.o rdkafka_offset.o rdkafka_transport.o rdkafka_buf.o rdkafka_queue.o rdkafka_op.o rdkafka_request.ordkafka_msgset_writer.o rdkafka_msgset_reader.o rdkafka_header.o rdkafka_admin.o rdk
浏览 1提问于2021-07-24得票数 1
回答已采纳
::Conf *conf = RdKafka::Conf::create(RdKafka::Conf::CONF_GLOBAL); if (!::ErrorCode resp = producer->produce(topic, partition,
浏览 5提问于2017-06-11得票数 3
回答已采纳
1回答
日志突出显示rdkafka库检测到并抑制了相同的错误。调试日志是否可以配置rdkafka，以便在尝试将AdminClient连接到代理时不阻止相同的错误？在上面的示例中，一旦rdkafka轮询线程最终检测到代理已经启动并运行，为什么Admin
浏览 7提问于2020-12-30得票数 2
回答已采纳
我不知道如何为Kafka配置Symfony messenger。一切都适用于rabbitmq (我创建了信使和信使处理程序)：MESSENGER_TRANSPORT_DSN=amqp://user:password@myhost:5672/%2f/messagesframework: transports:.env
MESSENGER_TRANSPORT_DSN=enqueu
浏览 2提问于2019-10-10得票数 6
我正在使用 PHP客户端库。我们的Kafka安装在服务器A上，来自不同服务器的生产者使用Java代码添加数据，现在我试图通过服务器B通过PHP来使用数据。我需要传递用户名和密码来访问数据，但是在中，我没有任何方法传递用户名、密码和引导服务器。spring.kafka.bootstrap-servers=<value-here>
spring.kafka.properties.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule requi
浏览 13提问于2022-04-26得票数 0
我使用PECL安装了PHP7.4和RdKafka，但是模块没有启动，下面是PHP -v的输出用模块API=20210902编译的模块这些选项需要匹配
根据pecl
浏览 38提问于2022-05-31得票数 0
php $conf->set('group.id', 'elk_consumedeijhelloworld');$rk = new \RdKafka\Consumer($conf);echo 222;
终端输出只有111并且挂起(没有响应，没有退出)，进度为什么还在那里？
浏览 2提问于2017-10-01得票数 1
1回答
RUN apt-get install librdkafka-dev -y && docker-php-ext-enable rdkafka在停靠-构建和上-d之后，exec容器php、make php -m和我在模块列表中看到了rdkafka。在添加和安装的composer.json中类似： "php": "^7.2.5",
"ext-
浏览 5提问于2020-09-29得票数 1
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
