========
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.



.. code-block:: json
    :caption: Configuration

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

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

.. code-block:: json
    :caption: 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"
      } ]
    }