Kafka Connect sink using Unix domain sockets
The connector is used to write data from Kafka to a Unix Socket.
You can build the connector with Maven using the standard lifecycle phases:
mvn clean
mvn package
name=unix-socket-connector
connector.class=uk.cl.cam.ac.uk.cadets.UnixSocketSinkConnector
tasks.max=1
topics=topic_name
schema.name=socketschema
pathname=socket_name