回答情况：
提问时间：
问题标签：
", "async")
val producer = new Producer我还注意到如果我删除声明没有数据丢失。这是否意味着producer.close()在将数据放入缓冲区之前中断了producer.send()，因为缓冲区中没有将特定的元组发送给使用者？如果是的话，我该如何在不损失数据的情况下关闭生
浏览 9修改于2016-05-30得票数 0
回答已采纳
try { $producer= Kafka::Producer->new( Connection => $kafka_connection ); my $partition= 0;
浏览 4修改于2016-02-29得票数 2
回答已采纳
;import kafka.producer.ProducerConfig;
at kafka.producer.Producer.<init>(Producer.scala:73)
at kafka.javaapi.producer.<e
浏览 0提问于2016-03-11得票数 5
回答已采纳
根据文档，对于每个通道，RabbitMQ都有一个线程池(而不是通道)。
如果是这样的话，每次对sendMessage的调用都会使用线程池吗？
浏览 1修改于2014-07-30得票数 0
我需要发送几批消息，并确保每批中的所有消息都在同一批中一起到达消费者。我使用spark structured-streaming来消费消息。生产者是否应该将所有消息(每批)放在一个列表中，并将该列表发送给kafka？谢谢
浏览 3修改于2018-07-09得票数 0
根据kafka confluent issue的说法，当我使用producer.flush()时，它可以工作，但性能很差，但正如我建议的那样，我使用producer.poll(0)，但不会向主题生成任何消息self.producer.produce(topic.value, data.encode('utf-8'), callback=self.delivery_report)
self.pro
浏览 248修改于2019-12-04得票数 1
Inject * (non-Javadoc) at injection point [BackedAnnotatedField] @Inject org.bala.java.jee.cdi.producer.boundary.LoggerServiceImpl.loggerat or
浏览 1修改于2017-07-10得票数 0
回答已采纳
在使用Kafka集群的kerberized设置中，我可以很容易地强制主题X，用户A和B有权产生消息，而对于主题Y，用户C有权产生消息。有没有为每条消息添加标签的选项？也许有一句话，我不想在生产者端这样做，但我想在代理端强制执行它，所以我有一个绝对的保证，这个用户信息是存在的。
浏览 0修改于2018-02-22得票数 2
回答已采纳
根据文档，我可以看到kafka producer是线程安全的。这是否意味着我可以拥有Kafka producer的单个实例，并由不同的线程( web请求)使用它，在我的情况下，每个线程都会打开和关闭producer。这会产生什么问题吗？
浏览 2提问于2016-03-24得票数 17
回答已采纳
/kafka-console-producer.sh --broker-list localhost:9092 --topic test [2016-06-29 15:00:44,069sending message to topic test with key: null, value: 11 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback
浏览 2提问于2016-06-29得票数 6
我尝试导入kafka.javaapi.producer.Producer而不是kafka.producer.Producer；但仍然不起作用package sources;import java.io.InputStreamReader;import
浏览 5修改于2019-11-17得票数 0
latest',) bootstrap_servers=host+':'+broker_portfuture = producer.send(topic,json.dumps
浏览 16提问于2019-09-16得票数 0
package com.java.thread.self.practice;
producer_Consumer.startThreads();invocation :::::: ");
producer<
浏览 0修改于2017-02-16得票数 1
因此，我使用以下代码： try (Producer<Void, String> producer = createProducer(kafkaContainerBootstrapServers)) {producer.initTransactions(); Arrays.stream(messages).forEach(
message -> producer
浏览 34提问于2019-03-20得票数 1
回答已采纳
/kafka-console-producer.sh --broker-list ec2-ip.eu-central-1.compute.amazonaws.com:9093 -topic test --producer.config ../config/producer.properties时，我得到：
ERROR [Producer clientId=console-producer] Connection to node -1 (ec2多亏了mazaneiche，我才能
浏览 8修改于2019-08-23得票数 3
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号