项目作者: gcjenkinson

项目描述 :
Kafka Connect sink using Unix domain sockets
高级语言: Java
项目地址: git://github.com/gcjenkinson/kafka-connect-unix-socket-sink.git


Kafka Connect Unix Socket Sink

The connector is used to write data from Kafka to a Unix Socket.

Building

You can build the connector with Maven using the standard lifecycle phases:

  1. mvn clean
  2. mvn package

Sample Configuration

  1. name=unix-socket-connector
  2. connector.class=uk.cl.cam.ac.uk.cadets.UnixSocketSinkConnector
  3. tasks.max=1
  4. topics=topic_name
  5. schema.name=socketschema
  6. pathname=socket_name