doc: https://docs.confluent.io/3.1.1/connect/connect-jdbc/docs/sink_connector.html github code: https://github.com/confluentinc/kafka-connect-jdbc
I glance over the code. Seems the actually worker is JdbcSinkTask. After put(Collection<SinkRecord> records) It will generate sql and execute it I try to implement it using java code instead of kafka connect configuration. Receive avro serialized kafka record and sent to JdbcSinkTask. Is there any document that will tells me some details or some example code? Thanks, Lei wangl...@geekplus.com.cn
