FlumeAvroSourceConnector¶
com.github.jcustenborder.kafka.connect.flume.FlumeAvroSourceConnector
Connector is used to emulate a Flume Avro Source to allow Flume Agents to forward events to a Kafka Connect pipeline.
Important
This connector listens on a network port. Running more than one task or running in distributed mode can cause some undesired effects if another task already has the port open. It is recommended that you run this connector in Standalone Mode.
Configuration¶
General¶
port¶
Port to bind to.
Importance: HIGH
Type: INT
Default Value: 4545
Validator: ValidPort{start=1025, end=65535}
compression¶
The compression type. This must match on both flume agent and the connector. DEFLATE - Compress messages with the deflate algorithm., NONE - No compression
Importance: LOW
Type: STRING
Default Value: NONE
Validator: Matches: DEFLATE, NONE
worker.threads¶
The number of worker threads to spawn.
Importance: LOW
Type: INT
Default Value: 10
Validator: [1,…,1000]
SSL¶
ssl.enabled¶
Flag to determine if ssl should be configured for the connection.
Importance: MEDIUM
Type: BOOLEAN
ssl.keystore.password¶
The password for the java keystore containing the certificate.
Importance: MEDIUM
Type: PASSWORD
Default Value: [hidden]
ssl.keystore.path¶
The path to the keystore on the local file system.
Importance: MEDIUM
Type: STRING
Validator: Empty String or Absolute path to a file that exists.
ssl.keystore.type¶
The type of keystore.
Importance: MEDIUM
Type: STRING
Default Value: PKCS12
Validator: [PKCS12, JKS]