1. 从kafka安装环境中找到连接kafka服务器的相关jar文件,放到产品外部库文件夹中;kafka外部库文件路径为:安装目录\ esProc\extlib\ KafkaCli;润乾核心jar为kafkaCli.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 ()。函数用法请参考【帮助】-【函数参考】。