此日志可通过confluent-kafka-python producer client for confluent cloud中的debug=all配置获得。如何解析rtt的ProduceResponse？可以使用on_delivery回调来完成吗？|RECV|rdkafka#producer-1| [thrd:sasl_ssl://b4-confluent-cloud-broker</
浏览 21提问于2021-07-28得票数 1
我正在使用rest api从confluent云上的kafka实例获取主题 我正在使用下面的curl命令 curl "http://(myhost):9092/topics/(topicname)"
浏览 20提问于2020-11-05得票数 0
我在一个项目中使用kafka，具体来说，我使用的是合流云的托管kafka。他们的在线控制台没有提供任何方法让我看到，我已经尝试使用他们专有的“confluent”CLI，声称能够完成我想要的事情(通过：)，但是我必须向该工具传递一个URL才能执行特定的命令(其他命令运行良好，但是，为了完整起见，我尝试运行的命令有以下形式：
confluent kafka broker update
浏览 9提问于2022-11-30得票数 0
回答已采纳
我使用kafka-python包将消息发布到kafka confluent云集群。我的代码如下所示： from kafka import KafkaProducer bootstrap_servers='pkc-epgnk.us-central1.gcp.confluent.cloud:9092',
security_prot
浏览 21提问于2019-01-25得票数 2
Kafka connect是Kafka connect worker (confluent-3.2.0)的一部分。我在机器A上启动并运行了一个Kafka代理(confluent-3.2.0)。我想在另一台机器B上设置Kafka-connect-sink连接器，以使用自定义的Kafka-connect-sink连接器jar消费消息。假设机器A上的Kafka broker和Zoo keeper端口对机器B开放。那么，我是否应该通过将classpath设置为Kafka
浏览 1提问于2017-06-09得票数 0
我一直在尝试与kafka-avro-console-consumer从Confluent连接到我们的遗留Kafka集群，该集群是在没有Confluent Schema Registry的情况下部署的。我使用如下属性显式地提供了模式： --topic test \--property key.schema='{"type"
浏览 2提问于2018-09-19得票数 6
回答已采纳
与Avro一样序列化的记录。我试图使用消息本身中的确切模式来反序列化该值，但得到了一个格式错误的记录异常。下面是我的代码： Dataset<Row> load = sparkSession .format("kafka")load.select(from_avro(col("value"), schema)).write().json("/tmp/spark/j
浏览 48提问于2021-08-30得票数 0
在使用spring-cloud-stream-binder-kafka时，我在配置到Confluent的连接时遇到问题。也许有人能看到哪里出了问题？当我使用来自的示例时，它工作得很好，并且我可以在Confluent Cloud上看到消息
但是，当使用spring-cloud-stream-binder-kafka配置添加相同的连接详细信息时，它会返回未经授权的错误
浏览 0提问于2020-05-27得票数 2
1回答
我与Avro一起使用合流模式注册表，我想在一个Kafka主题中使用多个模式。
默认主题命名策略TopicNameStrategy不允许这样做，因为它将模式主题名称耦合到主题名称。因此，您现在可以选择使用confluent.key.subject.name.strategy和confluent.value.subject.name.strategy将模式主题键和值配置为默认的命名策略而不是默认的命名策略在Confluent中，使用--c
浏览 11提问于2020-10-31得票数 2
回答已采纳
2回答
##
# instructions at https://docs.confluent.io/current/cloud/using/api-keys.html.=true
#confluent.telemetry.api.key=<<
浏览 4提问于2021-11-10得票数 2
回答已采纳
我使用使用kafka_2.11-0.10.1.1的confluent-kafka-0.9.2 (主分支) python绑定来运行librdkafka-0.9.2。我运行confluent producer示例如下：$ python producer.py localhost:9095 confluent-01
first messa
浏览 3提问于2017-01-27得票数 0
回答已采纳
我已经在应用程序中创建了一个kafka流，并且可以解析任何通过它产生的文本。kafkaStream = KafkaUtils.createStream(ssc, zkQuorum, "spark-streaming-consumer", {topic: 1}) reader = DataFileReader(open("customer.avro", "r&quo
浏览 4提问于2015-05-20得票数 4
1回答
我正在开发一个项目，我的消息传递system.The项目有两个方面，一个用SegementIO.Normally编写的后端，它由使用Confluent Kafka客户端编写的Kafka消费者和生产者组成，另一个是用Go编写的机器代理，它使用来自SegementIO.Normally卡夫卡的卡夫卡- Go客户端在端口9092下运行，我的两个应用程序都运行为expected.The，我现在遇到的问题是，在安装了机器代理<
浏览 4提问于2021-08-20得票数 0
1回答
我有一个码头组成文件来建立卡夫卡的基础设施。我只是想更新一下，这个问题不是常量的，我无法找出根本原因。附注：我是卡夫卡码头的新手，请帮忙！下面是来自cnfldemos/cp-serv
浏览 1提问于2020-04-03得票数 2
回答已采纳
我正在尝试创建一个基于requirements.txt的conda环境： 运行命令： conda create --name kafka-consumer --file requirements.txtfailed
- confluent-kafka[version='>=1.4.2'] 来自https://gith
浏览 91提问于2020-08-26得票数 0
回答已采纳
卡夫卡消费工具没有连接到码头命令提供第三个VM生成一个新主题topic，并将消息推送到该主题上并尝试使用。前两个命令似乎正常工作，不会发出任何错误。然而，kafka-console-consumer失败了，似乎没有使用什么配置参数。Broker may not be available.CONFLUENT_METRICS_REPORTER_B
浏览 0提问于2019-10-07得票数 0
回答已采纳
我是python中kafka客户机的初学者，我需要一些帮助来描述使用该客户机的主题。我能够使用以下代码列出我所有的kafka主题：-
consumer = kafka.KafkaConsumer(group_id='test', bootstrap_servers=['kafka1']
浏览 3提问于2019-05-22得票数 4
回答已采纳
1回答
泉云流kafka事务配置
、、、
我以前没有使用过kafka，因此需要帮助，以防kafka中需要任何配置更改。</groupId> <version>${spring-cloud.versionConfigs:
Topic: employee-details Partition: 0 Leader: 0 Replicas: 0
浏览 5提问于2020-11-21得票数 0
回答已采纳
我正在开发一个Spring Cloud Stream Kafka应用程序。我只添加了消费者来使用来自主题的消息，并使用FIX协议将它们传递给第三方。从remoteHost broker到本地主机的bootstrap.servers配置更改，并开始显示以下错误：spring.cloud.stre
浏览 7提问于2020-07-30得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
