这是我正在运行的代码片段:err:=godotenv.Load()iferr!=nil{log.Fatal("Errorloading.envfile")}broker:=os.Getenv("BROKER")topic:=os.Getenv("TOPIC")username:=os.Getenv("USERNAME")password:=os.Getenv("PASSWORD")calocation:=os.Getenv("CALOCATION")p,err:=kafka.NewProducer(&kafka.ConfigMap{"metadata.broker.list":brok

我一直在寻找C++kafka消费者。我遇到了以下用于C++kafka的，但没有消费者。https://github.com/adobe-research/libkafka(仅sample制作者)https://github.com/edenhill/librdkafka/tree/master/src-cpp有没有人有基于上述工作的C++kafka消费者或C++kafka消费者的任何新方法 最佳答案 librdkafka的examples/目录包含一个C++消费者(和生产者):高级平衡的KafkaConsumer:https://g

使用C/C++语言操作Kafka时，librdkafka是首选的开源库使用librdkafka创建消费者客户端时，应配置如下属性消费者会话组保持活动心跳间隔自动提交偏移自动重置偏移自动重置偏移有五种属性设置：a.earliest（最早的）b.latest（最近的）c.largest（最大的）d.smallest（最小的）e.beginning（起始的）f.end（结束的）g.error（错误的）#include"librdkafka/rdkafka.h"//声明消费者实例rd_kafka_t*rk;//临时配置对象rd_kafka_conf_t*conf;conf=rd_kafka_conf_

一些背景知识:我正在研究我们团队中的其他开发人员将使用的一些python模块。每个模块的共同主题是一条或多条消息将发布到Kafka。我们现在打算使用ConfluentKafka客户端。在我们的组织中，我们对Python开发还很陌生——我们传统上是一家.NET商店。复杂性:虽然我们创建的代码将在Linux(rhel7)上运行，但大多数开发人员将在Windows上完成他们的工作。因此我们需要在每台开发人员机器上编译的librdkafkaC库(它有自己的依赖项，其中之一是OpenSSL)。然后confluent-kafka的pip安装应该可以正常工作，这意味着我们的软件包的pip安装可以正常