docker 中的kafka java 怎么调用

要在 Docker 中调用 Kafka Java，您需要执行以下步骤：

1. 在 Docker 中安装 Kafka。
2. 启动 Kafka 服务器。
3. 使用 Kafka 客户端 API 编写 Java 应用程序。

以下是一个简单的示例，演示如何使用 Kafka Java 客户端 API 从 Kafka 主题中读取消息：

import java.util.Properties;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;

public class KafkaConsumerExample {
   public static void main(String[] args) throws Exception {
      String topicName = "my-topic";
      Properties props = new Properties();
      props.put("bootstrap.servers", "localhost:9092");
      props.put("group.id", "test-group");
      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);
      consumer.subscribe(Arrays.asList(topicName));

      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());
         }
      }
   }
}

在这个例子中，我们使用 KafkaConsumer 对象创建一个消费者，订阅 'my-topic' 主题，并使用 poll() 方法从 Kafka 中读取消息。每个消息都包含一个偏移量、键和值。在这里，我们只是简单地打印出这些值，但是您可以根据您的需要对它们执行其他操作。

这是一个非常简单的示例，但它应该可以帮助您开始使用 Kafka Java 客户端 API。