使用弹簧靴从kafka使用者获取数据

Question

我有一个Mysql数据库，使用kafka-avro console-consumer获得了json。现在，我想在spring-boot控制台中获取json。下一步怎么办？

Answer 1

您只需要创建一个使用者：

@Service
public class Consumer {

    private final Logger logger = LoggerFactory.getLogger(Producer.class);

    @KafkaListener(topics = "myTopic", groupId = "myTopic-consumer-group")
    public void consume(String message) throws IOException {
        logger.info(String.format("Message: %s", message));
    }
}