在0.82 Producer API和0.9 Consumer api中，您可以使用类似
Properties configProperties = new Properties();configProperties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");configProperties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.ByteArraySerializer");configProperties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");org.apache.kafka.clients.producer.Producer producer = new KafkaProducer(configProperties);producer.partitionsFor("test")
