之前用过老的api,但是最近在写消费的时候，发现之前老的api很多方法都out了，又去官网看了下最新的0.10.x的api.

1，producer


     			
      
       org.apache.kafka
      			
      
       kafka-clients
      			
      
       0.10.1.0

public static void main(String[] args) {        Properties props = new Properties();        props.put("bootstrap.servers", "192.168.1.31: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
     
       producer = new KafkaProducer<>(props);        for(int i = 0; i < 100; i++)            producer.send(new ProducerRecord
      
       ("defaultTopic", Integer.toString(i), String.valueOf(i)));        producer.close();    }

2,Comsumer


      			
       
        org.apache.kafka
       			
       
        kafka-clients
       			
       
        0.10.1.0

public static void main(String[] args) {        Properties props = new Properties();        props.put("bootstrap.servers", "192.168.1.31:9092");        props.put("group.id", "test");        props.put("enable.auto.commit", "true");        props.put("auto.commit.interval.ms", "1000");        props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");        props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");        KafkaConsumer
      
        consumer = new KafkaConsumer<>(props);        consumer.subscribe(Arrays.asList("defaultTopic"));        while (true) {            ConsumerRecords
       
         records = consumer.poll(10);            for (ConsumerRecord
        
          record : records)                System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());        }    }

写完java api，可以try一下spring-intergeted，方便，一些池操作可以屏蔽掉，专注业务。