Kafka生产者启用事务后会发送重复消息。

在Kafka生产者程序中，启用事务后可能会遇到消息发送重复的问题。这可能是因为在事务回滚时，已经发送的消息没有被正确处理。

为了解决这个问题，我们需要在代码中增加一些处理逻辑，以确保每条消息只会发送一次。具体的解决方法如下：

1. 设置Kafka生产者的ack级别为all，并将max.in.flight.requests.per.connection设置为1，以确保消息只被发送一次。

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("max.in.flight.requests.per.connection", "1");

Producer<String, String> producer = new KafkaProducer<>(props);

2. 在事务提交之前，检查消息是否已经被发送。如果消息已经被发送，则不需要再次发送。

producer.initTransactions();

try {
  producer.beginTransaction();

  for (String message : messages) {
    // check if message has already been sent
    if (!sentMessages.contains(message)) {
      producer.send(new ProducerRecord<String, String>("my_topic", message));
      sentMessages.add(message);
    }
  }

  producer.commitTransaction();
} catch (Exception e) {
  producer.abortTransaction();
}

通过以上解决方法，我们可以消除Kafka生产者启用事务后发送重复消息的问题。