{"repo":"137-rick/http-kafka-gateway","free":true,"listed":false,"github":"https://github.com/137-rick/http-kafka-gateway","clone":"git clone https://github.com/137-rick/http-kafka-gateway.git","description":"an gateway for kafka by http","language":"Java","stars":21,"topics":["kafka","http","gateway","jaas"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"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 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","default_branch":null,"files":null,"tree":[],"storefront":"/r/137-rick","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/137-rick/http-kafka-gateway/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}