如何关闭kafka producerconfig值

bmvo0sr5 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(448)

2018-03-22 11:50:29.175  INFO 12071 --- [io-26681-exec-1] o.a.k.clients.producer.ProducerConfig    : ProducerConfig values:
acks = 1
batch.size = 16384
bootstrap.servers = [ns014:9092]
buffer.memory = 33554432
client.id =
compression.type = none

在SpringBoot2.0中，当我发送消息时，图片值总是出现。如何关闭它？
我没有发现配置有任何变化。

apache-kafka spring-boot

来源：https://stackoverflow.com/questions/49420411/how-to-close-kafka-producerconfig-values

1条答案

按热度按时间

5anewei61#

如果使用kafkaproducer配置kafka，可以按如下方式关闭通道：

Producer<String, String> producer = new KafkaProducer<>(props);
  producer.send(new ProducerRecord<String, String>("my-topic", 
  Integer.toString("any Data"), Integer.toString(i)));

  producer.close();

如果您使用的是异步调用的kafkatemplate，则可以按以下方式执行：

ListenableFuture<SendResult<String, Payload>> sr = kafkaTemplate.send(topic, payload);
    kafkaTemplate.flush();

这将刷新特定Kafka制作人的所有设置。

赞(0）回复(0）举报 2021-06-07

我来回答

如何关闭kafka producerconfig值

1条答案

相关问题

热门标签

最新问答