我正在学习kafka,我想把我的应用程序分成两个微服务。首先,将所有传入的消息从KafkaConsumer保存到数据库,然后根据给定的id选择entity。第二,提供REST来保存和获取实体。他们之间的互动提供了卡夫卡。如何使用kafka从REST中的db接收存储的ID?这是在POST请求时调用生产者的示例代码。String, byte[]> result = resultFuture.get();
L
背景:我在生成prod主题时使用了错误的avro模式注册表,因此由于使用错误的模式id.So作为恢复计划的消息,我们希望将prod主题中的消息复制到测试主题中,然后将好消息写入我们面临的具有错误模式id的特定偏移量的hdfs.But,在从prod topic.Is读取时,有一种方法可以忽略这些偏移量。Exception in thread "Stream