Kafka读取插件（**reader）

{
  "job": {
    "content": [
      {
        "reader": {
          "parameter": {
            "topic" : "yxabc",
            "codec" : "plain",
            "encoding" : "utf-8",
            "consumerSettings" : {
              "zookeeper.connect" : "127.0.0.1:2181/kafka",
              "group.id" : "default",
              "auto.commit.interval.ms" : "1000",
              "auto.offset.reset" : "smallest"
            }
          },
          "name": "kafka09reader"
        },
        "writer": {

        }
      }
    ],
    "setting": {
      "errorLimit": {
        "record": 1
      },
      "speed": {
        "bytes": 1048576,
        "channel": 1
      }
    }
  }
}