我正在使用 Kafka Producer Api 将文件中的消息写入 kafka 主题，但 kafka 主题的日志显示为空？

Question

我正在使用以下 Producer API 代码将消息写入 Kafka 主题，但无法将消息写入主题：

import java.util.Properties
import com.typesafe.config.ConfigFactory
import org.apache.kafka.clients.producer.{KafkaProducer, ProducerConfig, ProducerRecord}
import scala.io.Source

object KafkaProducerDemo {

    def main(args: Array[String]): Unit = {

        val props = new Properties()
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092")
        props.put(ProducerConfig.CLIENT_ID_CONFIG, "KafkaProducerDemo")
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer")
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer")

        val producer = new KafkaProducer[Nothing, String](props)


        val logMessages = Source.
          fromFile("/opt/gen_logs/logs/access.log").
          getLines.
          toList

        logMessages.foreach(message => {
          val record = new ProducerRecord("retail-multi", message)
          producer.send(record)
        })
    }
}

Answer 1

根据您在 cmets (java.lang.ArrayIndexOutOfBoundsException: 18) 中提到的错误，我会说您的客户端库版本和代理版本不匹配。客户端库应该是

因此，请仔细检查您要连接的代理版本，然后再仔细检查您的客户端库版本。一旦它们匹配或兼容，您就可以开始使用了！

Answer 2

嗨，我这可能是因为一些 kafka 版本不匹配。我已经重新安装了 kafka 和 sbt。现在它开始正常工作了。