Tlink

0 声望

这家伙太懒,什么都没留下

个人动态

Tlink 回复 ..... KafkaOffsetMonitor:监控消费者和延迟的队列 中 :
我用的21.1的版本跟你一样的情况,也是这个错误,web也只能看到topic
7天前
Tlink 回复 半兽人 KafkaOffsetMonitor:监控消费者和延迟的队列 中 :
2.1.1的版本offset在kafka上面吧,--offsetStorage kafka 也只能看到主题,其他的都没有
7天前
Tlink KafkaOffsetMonitor:监控消费者和延迟的队列 发表评论:
2019-08-16 10:02:27 WARN KafkaOffsetGetter$:89 - Failed to process one of the commit message due to exception. The 'bad' message will be skipped java.lang.RuntimeException: Unknown offset schema version 3 at com.quantifind.kafka.core.KafkaOffsetGetter$.schemaFor(KafkaOffsetGetter.scala:162) at com.quantifind.kafka.core.KafkaOffsetGetter$.readMessageValueStruct(KafkaOffsetGetter.scala:234) at com.quantifind.kafka.core.KafkaOffsetGetter$.com$quantifind$kafka$core$KafkaOffsetGetter$$readMessageValue(KafkaOffsetGetter.scala:204) at com.quantifind.kafka.core.KafkaOffsetGetter$$anonfun$startOffsetListener$1.apply$mcV$sp(KafkaOffsetGetter.scala:101) at com.quantifind.kafka.core.KafkaOffsetGetter$$anonfun$startOffsetListener$1.apply(KafkaOffsetGetter.scala:87) at com.quantifind.kafka.core.KafkaOffsetGetter$$anonfun$startOffsetListener$1.apply(KafkaOffsetGetter.scala:87) at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24) at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24) at scala.concurrent.impl.ExecutionContextImpl$$anon$3.exec(ExecutionContextImpl.scala:107) at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) jdk版本:jdk1.8.0_181 kafka 版本:kafka_2.12-2.1.1 zookeeper版本:zookeeper-3.4.14 KafkaOffsetMonitor启动命令 java -cp KafkaOffsetMonitor-assembly-0.3.0-SNAPSHOT.jar \ com.quantifind.kafka.offsetapp.OffsetGetterWeb \ --offsetStorage kafka \ --zk zkServer1:12181,zkServer2:12181 \ --port 8088 \ --refresh 10.seconds \ --retain 2.days 一直在刷这个错误,web端也没监控到任何生产和消费,不知道是scala版本还是kafka版本不对
7天前
半兽人 回复 Tlink Kafka安装和使用 -【视频】 中 :
2.11-2.0.0
10天前
Tlink Kafka安装和使用 -【视频】 发表评论:
这个视频对应的kafka是那个版本的
10天前

(゚∀゚ )
暂时没有任何数据