standard

This example will listen for events from Flume on all ip addresses using the standard port. The received messages are written to the flume topic.

Configuration

{
  "connector.class" : "com.github.jcustenborder.kafka.connect.flume.FlumeAvroSourceConnector",
  "topic" : "flume"
}

Data similar to the following will be emitted by this connector.

Output

{
  "sourcePartition" : { },
  "sourceOffset" : { },
  "topic" : "flume",
  "valueSchema" : {
    "type" : "BYTES",
    "isOptional" : false
  },
  "value" : "Tm8gb25lIHdpbGwgcmVhZCB0aGlzIG1lc3NhZ2Uu",
  "timestamp" : 1586461064991,
  "headers" : [ {
    "name" : "flume.header",
    "schema" : {
      "type" : "STRING",
      "isOptional" : false
    },
    "storage" : "adsfasdf"
  } ]
}