SpringBoot Kafka 整合使用

这里关键的代码为 kafkaTemplate.send()方法,message是 Kafka 里的 topic ,这个 topic 在 Java 程序中是不需要提前在 Kafka 中设置的,因为它会在发送的时候自动创建你设置的 topic, gson.toJson(message)是消息内容,1.你能看到我这篇文章证明你对与springboot和kafka都有了解了所以也不d说什么了 在这里大家要
相关文章
相关标签/搜索