Daniel Kinon

pmorch's solution worked for me as well with one exception. The jmdns.jar download link provided points to an older version of the jar file that caused me to get the...

Let me know if this should be a separate issue. I tried to workaround my issue by processing a key-based partition assignment in nginx lua and then settings a variable...

@brg-liuwei thanks. The config is relatively simple at this point: ``` location /events { access_by_lua_file /etc/nginx/conf.d/kafka.lua; kafka_partition 0; kafka_topic events; } ``` I understand what you mean by having a...

This is working for me, thanks. It would be nice to have a more dynamic configuration for this where `kafka_partition` could accept an nginx variable rather than a fixed number....

If anyone here is looking for a workaround in the interim, I am successfully injecting nginx variables into the $request_body using the [lua nginx module](https://github.com/openresty/lua-nginx-module).

@adridi http headers are actually the ngx variables (ngx.req.get_headers()) I'm injecting into the $request_body. Since they are just another ngx variable, I don't see why they couldn't technically be included....

@adridi I was also referring to the existing module, I merely used my lua_ngx module pseudocode example to illustrate one of the many formatted ways this could be done within...