在虚拟机中使用Docker与Kafka建立连接

在虚拟机中使用Docker与Kafka建立连接，可以按照以下步骤进行：

1. 安装Docker和Docker Compose：在虚拟机中安装Docker和Docker Compose，可以根据虚拟机的操作系统选择合适的安装方式。

2. 创建Docker Compose文件：创建一个名为docker-compose.yml的文件，并将以下内容添加到文件中：

version: '3'
services:
  zookeeper:
    image: zookeeper
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      - KAFKA_ADVERTISED_HOST_NAME=kafka
      - KAFKA_CREATE_TOPICS=test-topic:1:1
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
    depends_on:
      - zookeeper

该文件定义了两个服务：zookeeper和kafka。zookeeper是Kafka的依赖服务，kafka是Kafka消息代理服务。

3. 启动Kafka容器：在虚拟机中运行以下命令，启动Kafka容器：

docker-compose up -d

该命令会下载并启动zookeeper和kafka容器。

4. 在代码中使用Kafka：在你的代码中，可以使用Kafka客户端库与Kafka建立连接并进行消息传递。以下是使用Java语言的示例代码：

import org.apache.kafka.clients.producer.*;
import org.apache.kafka.common.serialization.StringSerializer;

import java.util.Properties;

public class KafkaProducerExample {
    private static final String TOPIC_NAME = "test-topic";
    private static final String BOOTSTRAP_SERVERS = "localhost:9092";

    public static void main(String[] args) {
        Properties props = new Properties();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, BOOTSTRAP_SERVERS);
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

        Producer<String, String> producer = new KafkaProducer<>(props);
        for (int i = 0; i < 10; i++) {
            String key = "key-" + i;
            String value = "value-" + i;
            ProducerRecord<String, String> record = new ProducerRecord<>(TOPIC_NAME, key, value);
            producer.send(record, new Callback() {
                @Override
                public void onCompletion(RecordMetadata metadata, Exception exception) {
                    if (exception != null) {
                        exception.printStackTrace();
                    } else {
                        System.out.println("Sent message: " + value + ", Offset: " + metadata.offset());
                    }
                }
            });
        }

        producer.close();
    }
}

这是一个简单的Kafka生产者示例代码，它将10条消息发送到名为test-topic的Kafka主题中。

注意：根据你的代码语言和Kafka客户端库，代码示例可能会有所不同。以上示例仅供参考。

5. 运行代码：在虚拟机中运行你的代码，确保能够与Kafka建立连接并发送消息。

这样，你就可以在虚拟机中使用Docker与Kafka建立连接了。