java中的Kafka无钥匙制作人

4ioopgfo  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(305)

我是kafka生态系统的新手,在我的例子中,我使用的是一个java生产者,但不需要发送一个键以及序列化avro的记录值。有没有一种方法可以构建一个不发送密钥的java生产者,或者在kafka中发送消息时需要密钥?

jdg4fx2g

jdg4fx2g1#

就像@gasparms所说的,有一些内置的方法可以在不发送钥匙的情况下进行生产。大多数人都是这样使用Kafka的,因为他们只希望能够发送一个没有密钥的消息流。只有在需要日志压缩时才真正需要使用密钥
这是一个很好的解释-https://stackoverflow.com/a/29515696/236528

r7knjye2

r7knjye22#

producerrecord有几个构造函数,其中一个没有键的值,因此您不必指出它。
例子:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("linger.ms", 1);
props.put("buffer.memory", 33554432);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

Producer<String, String> producer = new KafkaProducer<>(props);
for(int i = 0; i < 100; i++)
    producer.send(new ProducerRecord<>("my-topic", "myValue"));

producer.close();

相关问题