Kafka生产者。消息未被发送。

如果 Kafka 生产者中的消息没有被成功发送，可能是由于以下一些原因：Kafka 生产者配置错误、网络故障或 Kafka 服务器故障等。

以下是一个示例代码，可以用于解决 Kafka 生产者消息未被发送的问题：

from kafka import KafkaProducer
from kafka.errors import KafkaError

producer = KafkaProducer(bootstrap_servers=['localhost:9092'])

try:
    future = producer.send('test-topic', b'hello world')
    result = future.get(timeout=60)
    print(result)
except KafkaError as e:
    print(e)

在上面的代码中，我们首先创建一个 Kafka 生产者实例，然后使用 send() 方法将消息发送到指定的 Kafka 主题。在 try-except 块中，我们处理可能出现的 KafkaError 异常，并在控制台上打印错误消息。

通过使用以上代码示例，您可以确定消息未被发送的原因，以及进一步的调整 Kafka 生产者配置或检查网络故障、Kafka 服务器故障等因素，并解决 Kafka 生产者消息未被发送的问题。