Wei Liu

这个问题看上去是因为kafka的版本提高了，有了一个新的配置项，而librdkafka比较老，没有这个对应配置项，导致的警告。这个项目我已经很久没有维护了，所以这个警告信息不太好解决。

In my opinion, it is a good way using `ngx_lua` to solve this problem. Creating several locations that each location binds one partition specific and using `ngx_lua` route requests to...

@dkinon Assume you config kafka with 3 partitions, the following code maybe help you: # create 3 internal locations associate to one existing partition location = /kafka_partition/0 { internal; kafka_topic...

@dkinon The PR you mentioned is welcomed. You can first read the source code and then learn some basic knowledge about nginx module development. And we can discuss technical questions...

Thanks for your notification, I'll focus on this issue as soon as possibile

This module is depends on [librdkafka](https://github.com/edenhill/librdkafka), and those parameters can be set by librdkafka api when initializing kafka producer. So, the solution is to pass those parameters via nginx config...

I have add this issue into TODO LIST.

@lifehacking yep, I cannot agree more. PR is welcomed :)

@dkinon Yes, using lua_nginx_module injecting ngx variables into $request_body is easy to work, and I am an openresty user. But I still want to do some works to pass variables...

Could you please give me a whole test case, including the nginx configuration. > 在 2019年6月25日，下午4:31，1349236893 写道： > > When I was testing,crul localhost/ kafka-d "this is a test data",kafka...