访问 Kafka

阅读(406) 标签: kafkacli,

1. kafka安装环境中找到连接kafka服务器的相关jar文件,放到产品外部库文件夹中;kafka外部库文件路径为:安装目录\ esProc\extlib\ KafkaCli;润乾核心jarkafkaCli.jar

kafka_2.11-1.1.0.jar

log4j-1.2.17.jar

kafka-clients-1.1.0.jar

slf4j-api-1.7.25.jar

slf4j-log4j12-1.7.25.jar

2.java环境要求为jre1.7以上版本,集算器自带的版本为jre1.6所以需要用户自己安装高版本jre并在:安装目录\ esProc\bin\config.txt文件中配置java_home如果用户在安装集算器时,已选择1.7及以上版本的jdk则此步可以省略。

3.当占用内存比较大时,用户可自己调整内存,目前windows下有两种方式,使用exe启动时在config.txt里修改内存,使用bat启动时是在bat文件中修改内存。Linux下是在sh文件中修改内存大小。

windows下修改config.txt方法如下:

java_home=C:\ProgramFiles\Java\jdk1.7.0_11;esproc_port=48773;jvm_args=-Xms256m-XX:PermSize=256M-XX:MaxPermSize=512M-Xmx9783m-Duser.language=zh

4. 访问Kafka系统可使用的外部库函数有kafka_subscribe ()kafka_close ()kafka_poll ()kafka_commit ()。函数用法请参考【帮助】-【函数参考】。