开源软件名称：

http-kafka-gateway

开源软件地址：

https://gitee.com/thinkpc/http-kafka-gateway

开源软件介绍：

http-kafka-gateway

an gateway for kafka by http

一个服务网关,使用Java实现
可以使用http获取消费kafka内数据
可以使用http批量发送数据给kafka
支持 kafka 0.9+ 协议
使用JAAS验证 SASL_PLAN
后续有空会持续维护

Protocol

consumer get http://127.0.0.1:9099/dk/log/massfetch?maxcount=1000&topic=topicname
producer post http://127.0.0.1:9099/dk/log/masspush topic=xxx&data=urlencode(xxxx) x-www-form-urlencoded

Start Server

nohup java -XX:-MaxFDLimit -Xms3750m -Xmx3750m -XX:ReservedCodeCacheSize=240m -XX:+UseCompressedOops -jar kafkagateway-0.0.1-SNAPSHOT.jar &

Option for startup

# you can change setting by startup with -- prefix# eg: --kg.user=jaas_accountxxxx --kg.kafkatopic=xxx,xxxx#logginglogging.path=./logs/logging.file=./logs/kafkagateway.loglogging.level.com.tal.kafkagateway=INFO # temp queue backupkg.queuedumppath=./dump/ # kafkakg.kafkatopic=topic_a,topic_bkg.kafkagroupid=kafkagateway_groupkg.kafkaserver=kafkabrokerip:kafkabrokerport,kafkabrokerip:kafkabrokerportkg.user=jaas_accountkg.passwd=jaas_pwd kg.securityprotocol=SASL_PLAINTEXTkg.saslmechanism=PLAIN