详细说明：https://blog.csdn.net/a342874650/article/details/136026242 1、使用bootstrap、userName、password连接kafka。 2、可使用text、json格式发送topic消息。 3、异步producer、customer，收发消息畅通无阻。 Kafka生产者的主要作用是将应用程序产生的数据发送到Kafka集群的主题中。这个过程是异步的，允许应用程序在发送消息后继续执行其他任务。生产者还具有重试和错误处理机制，以确保消息在传输过程中不会丢失。 Kafka消费者则负责从主题中读取并处理这些消息。消费者可以并行地从多个分区读取消息，提高了处理大量数据的效率。此外，消费者还可以自动处理偏移量，以便在出现问题时能够重新开始消费。