从端点我会得到JSON格式的数据，首先我会发布它在Kafka使用发射器，我需要得到它从Kafka主题在同一个API和存储它的数据库使用休眠，但当我收到消息，它会关闭池和返回到端点，然后激发传入的消息，因为这一点，我不能有示例的类和存储它的数据库。请给予建议我尝试使用@Incomming @channel（“kafka-in”）和fun（）来获取Kafka，当运行它时，它将停止运行并返回响应，
yjghlzjz1#
是的，Kafka可以是一个传入和传出通道，然而，这是你应该使用Kafka流而不是SmallRye的消费者/生产者通道模型的地方。对于数据库，apache-kafka-connect通常是更好的解决方案。
1条答案
按热度按时间yjghlzjz1#
是的，Kafka可以是一个传入和传出通道，然而，这是你应该使用Kafka流而不是SmallRye的消费者/生产者通道模型的地方。
对于数据库，apache-kafka-connect通常是更好的解决方案。