这是一个警告,表示在 Kafka 中配置文件没有找到“internal.auto.downgrade.txn.commit”配置项。确保您在生产者代码中使用的 Kafka 版本与您的代码中引入的 Kafka 版本一致,并检查您的配置文件是否正确。
以下是一个示例代码,演示如何在 Kafka 生产者中配置该项:
Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
props.put(ProducerConfig.TRANSACTIONAL_ID_CONFIG, "my-transactional-id");
props.put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, true);
props.put("internal.auto.downgrade.txn.commit", false);
KafkaProducer producer = new KafkaProducer<>(props);
在上面的代码中,我们将“internal.auto.downgrade.txn.commit”设置为 false,表示我们不希望在事务提交失败时进行自动降级处理。你可以根据自己的需求来配置该项。