java 连接k8s中kafka 生产消息

要在Java中连接Kafka并生产消息，您需要执行以下步骤：

1. 首先，您需要在Java项目中添加Kafka客户端依赖。例如，如果您使用Maven，则可以在pom.xml文件中添加以下依赖项：

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>2.8.1</version>
</dependency>

2. 接下来，您需要创建一个Kafka生产者实例，用于将消息发送到Kafka集群。您可以使用以下代码创建一个Kafka生产者实例：

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;

import java.util.Properties;

public class KafkaProducerExample {

    public static void main(String[] args) {
        String topicName = "my-topic";
        String bootstrapServers = "localhost:9092";

        // 配置Kafka生产者
        Properties props = new Properties();
        props.put("bootstrap.servers", bootstrapServers);
        props.put("acks", "all");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        // 创建Kafka生产者
        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<>(topicName, key, value);
            producer.send(record);
        }

        // 关闭Kafka生产者
        producer.close();
    }
}

在上面的代码中，我们使用KafkaProducer类创建一个Kafka生产者实例。我们还为生产者设置了一些配置，例如Kafka集群的引导服务器地址、确认级别、序列化器等。然后，我们使用ProducerRecord类创建一个要发送到Kafka主题的消息记录，并使用producer.send()方法发送该记录。最后，我们关闭了Kafka生产者实例。

3. 最后，您需要确保您的Java项目能够连接到正确的Kafka集群。在Kubernetes中，您需要使用Kubernetes API或Kubernetes命令行工具（kubectl）来查找Kafka集群的地址和端口，并在Java代码中使用它们作为Kafka生产者的引导服务器地址。如果您使用的是Kubernetes集群中的Kafka，您可以使用Kubernetes服务来公开Kafka集群的地址和端口。例如，如果您的Kafka集群部署在名为"kafka"的Kubernetes服务上，则可以使用以下引导服务器地址：

String bootstrapServers = "kafka:9092";

这样就可以在Java中连接Kafka并生产消息了。请注意，上面的代码只是一个简单的示例，您需要根据您的具体需求进行修改和优化。