Standard

This example will read Extended Log Format files and write them to Kafka.

Configuration

{
  "connector.class" : "com.github.jcustenborder.kafka.connect.spooldir.elf.SpoolDirELFSourceConnector",
  "finished.path" : "/tmp",
  "input.path" : "/tmp",
  "error.path" : "/tmp",
  "input.file.pattern" : "^server\\d+\\.log",
  "topic" : "users"
}