Java中的Kafka无键生成器
Java中的Kafka无键生成器
提问于 2018-08-07 23:47:03
我是kafka生态系统的新手，在我的例子中，我使用的是Java生产者，但不需要将键与记录值一起发送，记录值是序列化的Avro。有没有一种方法可以构建一个Java生产者来不发送密钥，或者在Kafka中发送消息时需要密钥？
回答 2
Stack Overflow用户
回答已采纳
发布于 2018-08-08 00:23:36
ProducerRecord有several constructors，其中一个没有键的值，所以你不必指明它。
示例：
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();Stack Overflow用户
发布于 2018-08-08 00:38:35
就像@gasparms所说的那样，有一些内置的方法可以在不发送密钥的情况下生成。大多数人以这种方式使用Kafka，因为他们只希望能够发送消息流，而不需要密钥。只有在需要log compaction时才真正需要使用密钥
这里有一个非常好的解释-- https://stackoverflow.com/a/29515696/236528
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/51730797
复制相关文章
相似问题
腾讯云开发者
