我有几个表:人员、服务、计划和ProvidedServices。表计划包含每个服务的每个人的月计划。因此,我需要一个查询,返回服务的总价值,在特定时间段内,每个人在特定服务上提供服务,而在同一服务期间,计划工作量的汇总值。(BoRTargets.ServiceID = BoRServices.ID) AND (Bo
背景:我在生成prod主题时使用了错误的avro模式注册表,因此由于使用错误的模式id.So作为恢复计划的消息,我们希望将prod主题中的消息复制到测试主题中,然后将好消息写入我们面临的具有错误模式id的特定偏移量的hdfs.But,在从prod topic.Is读取时,有一种方法可以忽略这些偏移量。org.apache.kafka.streams.errors.StreamsException: Failed to deserialize value
for record. topic=xxxx, partition=9</e