返回到文章

采纳

编辑于

kafka java api自动创建topic

kafka

我的kafka集群配置设置了

auto.create.topics.enable=false

集群版本kafka_2.11-0.10.0.0

kafka集群虽然配置了auto.create.topics.enable=false,但是通过api produce 仍然会自动创建不存在的topic

以下是api:

public class Producer {
    public static void main(String[] args) {
         Properties props = new Properties();
         props.put("bootstrap.servers", "10.5.11.11:9093");
         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<String, String>("test", Integer.toString(i), Integer.toString(i)));
         producer.close();
    }
}