search

Morningstar / kafka-offset-monitor

A small web app to monitor the progress of kafka consumers and their lag wrt the log.
Apache License 2.0
282 stars 108 forks source link

Not able to use with kafka 0.10.2 #9

Closed ronakkothari closed 7 years ago

ronakkothari commented 7 years ago

We are using the version of kafka 0.10.2 and would like to use this tool. I have tried the command mentioned in wiki after downloading the latest release,

java -Djava.security.auth.login.config=conf/server-client-jaas.conf \ -cp KafkaOffsetMonitor-assembly-0.4.1.jar \ com.quantifind.kafka.offsetapp.OffsetGetterWeb \ --offsetStorage kafka \ --kafkaBrokers kafkabroker01:6667,kafkabroker02:6667 \ --zk zkserver01,zkserver02 \ --port 8081 \ --refresh 10.seconds \ --retain 2.days \ --dbName offsetapp_kafka

However, it doesn't show any data. Does this tool work with 0.10.2?

Rohlik commented 7 years ago

We using this tool with Kafka version 0.10.2.1 and we can see data on the web page.

ronakkothari commented 7 years ago

Hello Rohlik, have you made any specific changes as I could see in build.sbt the kafka version is ' "org.apache.kafka" %% "kafka" % "0.9.0.1" '. Have you guys made any specific changes?

ronakkothari commented 7 years ago

I think, I got the answer, this fork - https://github.com/kadaan/kafka-offset-monitor - works.

Rohlik commented 7 years ago

I using this parameters:

java -Xmx512m -cp KafkaOffsetMonitor-assembly-0.4.1-SNAPSHOT.jar \
     com.quantifind.kafka.offsetapp.OffsetGetterWeb \
     --zk $ZK01,$ZK02,$ZK03 \
     --port $PORT \
     --refresh $REFRESH \
     --retain $RETAIN >> $LOG_DIR/$LOG_FILE 2>&1 &