[WIP] Kafka Logger.

[Akayeshmantha]

Adding kafka plugin.

Issues resolved

Fix #1259

[Akayeshmantha]

Hi @membphis @moonming this will be the basic kafka logger with one broker support.

I think it's better to give the ability to define more brokers with object type ?

broker = {
"127.0.0.1" : "8080",
"127.0.0.1" : "8090",
}

And below as the schema

broker = {type = "object"}, timeout = { -- timeout in milliseconds type = "integer", minimum = 1, default= 2000 }, kafka_topic = {type = "string"}, async = { type = "boolean", default = false }, key = {type = "string"}, max_retry = {type = "integer", minimum = 0 , default = 3},

Also will fix the tests when schema is finalized

[moonming]

Hi @membphis @moonming this will be the basic kafka logger with one broker support.

I think it's better to give the ability to define more brokers with object type ?

broker = {

"127.0.0.1" : "8080",

"127.0.0.1" : "8090",

}

And below as the schema

`

    broker = {type = "object"},

    timeout = {   -- timeout in milliseconds

        type = "integer", minimum = 1, default= 2000

    },

    kafka_topic = {type = "string"},

    async =  { type = "boolean", default = false },

    key = {type = "string"},

    max_retry = {type = "integer", minimum = 0 , default = 3},

`

Also will fix the tests when schema is finalized

LGTM

[membphis]

the conf. broker_list is a hash object, we need to use table.nkeys to fetch the number of attributes.

# is useful for array tables.

[membphis]

We should install dependencies in specific scripts, eg: https://github.com/apache/incubator-apisix/blob/master/.travis/linux_openresty_runner.sh#L35

It may be a little between different os, eg: Linux and OSX.