我是kafka生态系统的新手,在我的例子中,我使用的是一个java生产者,但不需要发送一个键以及序列化avro的记录值。有没有一种方法可以构建一个不发送密钥的java生产者,或者在kafka中发送消息时需要密钥?
jdg4fx2g1#
就像@gasparms所说的,有一些内置的方法可以在不发送钥匙的情况下进行生产。大多数人都是这样使用Kafka的,因为他们只希望能够发送一个没有密钥的消息流。只有在需要日志压缩时才真正需要使用密钥这是一个很好的解释-https://stackoverflow.com/a/29515696/236528
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();
2条答案
按热度按时间jdg4fx2g1#
就像@gasparms所说的,有一些内置的方法可以在不发送钥匙的情况下进行生产。大多数人都是这样使用Kafka的,因为他们只希望能够发送一个没有密钥的消息流。只有在需要日志压缩时才真正需要使用密钥
这是一个很好的解释-https://stackoverflow.com/a/29515696/236528
r7knjye22#
producerrecord有几个构造函数,其中一个没有键的值,因此您不必指出它。
例子: