使用partitionsFor方法获取kafka 0.8.0中生产者的分区数量

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerConfig;
import java.util.Properties;

Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka-broker1:9092,kafka-broker2:9092");
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");

Producer<String, String> producer = new KafkaProducer<>(props);

import org.apache.kafka.common.PartitionInfo;
import java.util.List;

String topic = "your-topic";
List<PartitionInfo> partitions = producer.partitionsFor(topic);
int partitionCount = partitions.size();
System.out.println("分区数量：" + partitionCount);