我正在尝试创建一个简单的Resttemplate,它将从模式注册表中获取模式,如果响应是200,它将获取模式ID,并将其与Avro格式的消息一起发送到kafka。implements CommandLineRunner{
String kafkarwsrproxyURL = String.format("%s/topics/%s", "https://kafka-rest-proxyregistary and g
我使用KafkaRest代理来生成和使用Azure APIM从Kafka主题消费,因此使用Rest代理的原因。我可以使用auto.offset.reset =最早的线性方式使用消息,所以每次调用KafkaRest都会给我最新的消息,这是很棒的,A1 is data requestor
B2is API that fulfil