mobai0/nginx-kafka repository overview

# 加载 ngx_http_kafka_module 模块
load_module modules/ngx_http_kafka_module.so;

worker_processes  auto;

events {
    worker_connections  1024;
}

# some other configs

kafka;

kafka_broker_list 127.0.0.1:9092 127.0.0.1:9093; # host:port ...

server {

    # some other configs

    location = /your/path/topic {
        # optional directive: kafka_partition [<partition-num> | auto]
        #
        # kafka_partition auto; # default value
        # kafka_partition 0;
        # kafka_partition 1;

        kafka_topic your_topic;
    }
}