kafka客户端服务端版本

Kafka是目前最流行的分布式消息系统之一，它提供高性能、高可靠性、高扩展性的消息传递服务，支持多个消费者和生产者同时进行消息传递。在Kafka中，有客户端和服务端两个组件，不同版本的客户端和服务端之间也有一定的兼容性问题。

一、Kafka客户端版本

Kafka客户端主要分为Java客户端和Scala客户端，其中Java客户端向下兼容，但Scala客户端不是向下兼容。Java客户端分为两个版本：0.8版本和0.9版本。

（1）0.8版本

在0.8版本中，Kafka客户端使用了旧的Producer和Consumer API。如果使用0.8版本的Kafka客户端进行开发，需要注意以下几点：

1. ProducerConfig和ConsumerConfig的一些参数需要进行修改：

- serializer.class要改成serializer.class或key.serializer.class和value.serializer.class
- metadata.broker.list要改成bootstrap.servers
- request.required.acks要改成acks
- partitioner.class要改成partitioner.class或key.serializer.class和value.serializer.class

2. 使用旧的Producer API：

Producer<String, String> producer = new Producer<String, String>(new ProducerConfig(props));
KeyedMessage<String, String> message = new KeyedMessage<String, String>("my_topic", "key", "hello world");
producer.send(message);

3. 使用旧的Consumer API：

ConsumerConnector consumer = kafka.consumer.Consumer.createJavaConsumerConnector(new ConsumerConfig(props));
Map<String, Integer> topicCountMap = new HashMap<String, Integer>();
topicCountMap.put("my_topic", 1);
Map<String, List<KafkaStream<byte[], byte[]>>> consumerMap = consumer.createMessageStreams(topicCountMap);
List<KafkaStream<byte[], byte[]>> streams = consumerMap.get("my_topic");
for (KafkaStream<byte[], byte[]> stream : streams) {
    ConsumerIterator<byte[], byte[]> it = stream.iterator();
    while (it.hasNext()) {
        System.out.println(new String(it.next().message()));
    }
}

（2）0.9版本

在0.9版本中，Kafka客户端使用了新的Producer和Consumer API。如果使用0.9版本的Kafka客户端进行开发，需要注意以下几点：

1. 配置参数的修改：

- metadata.broker.list要改成bootstrap.servers
- partitioner.class要指定key.serializer.class或value.serializer.class的值