Extend kafka-connect according to source/sink protocol kafka-connect-protocol.
It contains connectors:
- kafka-connect-protocol - protocol for source/sink connectors, data type and command type are defined in this module.
- kafka-connect-redis - sink to redis with redisson/redisson.
- kafka-connect-elasticsearch, thanks to confluentinc/kafka-connect-elasticsearch.
mvn clean package
Check Dockerfile for detail, you can use billryan/kafka-connect built by travis CI, change kafka broker address in connect-distributed.properties.