开源中国 2018 年度最后一场技术盛会邀你来约~错过就要等明年啦!点此立即预约

thinkpc / http-kafka-gatewayJavaApache-2.0

指数
0
Watch 16 Star 30 Fork 9
加入码云
与超过 300 万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
http协议消费生产数据网关,(kafka代理) 展开 收起

取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README.md

http-kafka-gateway

an gateway for kafka by http

  • 一个服务网关,使用Java实现

  • 可以使用http获取消费kafka内数据

  • 可以使用http批量发送数据给kafka

  • 支持 kafka 0.9+ 协议

  • 使用JAAS验证 SASL_PLAN

  • 后续有空会持续维护

Protocol

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
#logging
logging.path=./logs/
logging.file=./logs/kafkagateway.log
logging.level.com.tal.kafkagateway=INFO 

# temp queue backup
kg.queuedumppath=./dump/ 

# kafka
kg.kafkatopic=topic_a,topic_b
kg.kafkagroupid=kafkagateway_group
kg.kafkaserver=kafkabrokerip:kafkabrokerport,kafkabrokerip:kafkabrokerport
kg.user=jaas_account
kg.passwd=jaas_pwd 
kg.securityprotocol=SASL_PLAINTEXT
kg.saslmechanism=PLAIN

项目点评 ( 0 )

你可以在登录后,发表评论

搜索帮助