Introduction

Kafka-pipeline is a stand-alone kafka consumer group, which can consumer data then feed to other systems. Currently we implemented it as a pipeline to elasticsearch

Usage

  1. run sbt at project root
  2. In sbt shell, compile
  3. Do run /path/to/config.properties