kafka入门三几种消费方式

Kafka是一个分布式的消息队列系统，它具有高吞吐量、可扩展性和容错性。 在Kafka中，有三种消费方式，它们分别是简单消费者、高级消费者和流式处理消费者。 下面我们来逐一介绍这三种消费方式的具体实现方法。

1.简单消费者

简单消费者是消费Kafka消息的最简单方式。它主要通过轮询的方式从Kafka服务器上获取消息，并逐一处理每一条消息。 当Kafka服务器没有数据时，简单消费者会一直在等待，直到有新数据产生为止。

代码示例：

import java.util.*;
import org.apache.kafka.clients.consumer.*;
import org.apache.kafka.common.serialization.*;

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

2.高级消费者

相比于简单消费者，高级消费者可以实现更复杂的消费逻辑。 它能够从Kafka服务器上获取指定的消息，按照一定规则对消息进行分区，实现多线程并发消费，提高消费效率。 此外，高级消费者还支持对消息进行手动确认和批量消费。

代码示例：

import java.util.*;
import org.apache.kafka.clients.consumer.*;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.serialization.*;

public class AdvancedKafkaConsumer {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("group.id", "test");
        props.put("enable.auto.commit", "false");
        props.put("key.deserializer