草庐IT

SchemRegistry

全部标签

java - KafkaConnect HDFS 连接器与 SchemRegistry

我引用了以下链接来了解HDFSConnectforKafkahttps://docs.confluent.io/2.0.0/connect/connect-hdfs/docs/index.html我能够通过配置单元集成将数据从kafka导出到HDFS。现在我正在尝试借助Java程序将avro记录写入kafkapublicstaticvoidmain(String[]args)throwsInterruptedException,IOException,RestClientException{Propertiesprops=newProperties();props.put("boots