kafka 如何创建小肥猪 kafka 如何创建小肥猪 kafka 如何创建消费者

很抱歉，您的问题似乎将Kafka与一个不相关的场景混淆了。在Kafka中，“创建小肥猪”并不是一个标准操作术语。实际上，您提到的是创建Kafka的消费者（Consumer）。以下是创建Kafka消费者的典型步骤：

1. **设置依赖**：首先确保你已经有一个运行良好的Kafka集群，并且知道其地址（如`localhost:9092`）。

2. **添加依赖**：如果你使用Java，可以在项目中引入Kafka的客户端库（如`org.apache.kafka.clients.consumer.KafkaConsumer`）。

3. **初始化消费者**：创建一个新的消费者实例，指定需要连接的bootstrap服务器列表、group ID（消费者组）、以及解析消息内容所需的配置，例如自动偏移量获取策略（auto-offset-reset）：

   Properties props = new Properties();
   props.put("bootstrap.servers", "localhost:9092");
   props.put("group.id", "my-consumer-group");
   props.put("enable.auto.commit", "true"); // 或者"false"
   props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
   props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

   KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

4. **订阅主题**：调用`consumer.subscribe(Arrays.asList("my-topic"))`来订阅指定的主题。

5. **开始消费**：使用`consumer.poll()`循环等待新消息并处理它们。

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(100); // 每隔100毫秒检查一次
    for (ConsumerRecord<String, String> record : records) {
        System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
    }
}