但由于错误而失败:
2020-02-01 21:16:11,750在任务到-pg-0任务中遇到错误.使用类io.confluent.connect.avro.Avro转换器执行阶段'VALUE_CONVERTERAvro: at io.confluent.connect.avro.AvroConverter.toConnectData(AvroConverter.java:110) at org.apache.kafka.
序列化和模式注册表将该数据帧发送到kafka主题。我相信我快到了,但是我似乎不能通过Task not serializable错误。我知道kafka有一个接收器,但它不会与模式注册表通信,这是必需的。: kafka.utils.VerifiableProperties): org.apache.avro.Schema = {
val ser = new KafkaAvroEncoder(vProps): org.apache.kafka
我已经在本地启动了Kafka (2.8.0版),并且正在运行Connectconnect-distributed.sh ..Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResourceDue to constraint configuration problems the provider org.apache.kaf