java - 无法连接到 Neo4j 用户定义过程中的 Apace Kafka

Question

我创建了一个用户定义的存储过程，并试图在该过程中向 Kafka 生成消息。我收到以下错误：

[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) 已断开连接

这是我的代码，当我在示例项目中运行它时它可以完美运行

class KafkaProducer(topic: String, message: String) {
    init {
        val properties = Properties()

        properties[ProducerConfig.BOOTSTRAP_SERVERS_CONFIG] = "localhost:9092"
        properties[ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG] = StringSerializer::class.java.name
        properties[ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG] = StringSerializer::class.java.name

        val producer = KafkaProducer<String, String>(properties)

        val record = ProducerRecord(topic, "key", message)

        producer.send(record)

        producer.flush()
        producer.close()
    }
}

标签： javaapache-kafkaneo4j