.....的主页 - OrcHome

发表了写一个kafka的工具类，返回所需要的信息，这样return会对kafka有影响吗？

5年前

Tlink 回复 ..... 在 KafkaOffsetMonitor：监控消费者和延迟的队列中：

我用的21.1的版本跟你一样的情况，也是这个错误，web也只能看到topic

5年前

..... 回复半兽人在 KafkaOffsetMonitor：监控消费者和延迟的队列中：

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 2
        at com.quantifind.kafka.core.KafkaOffsetGetter$.schemaFor(KafkaOffsetGetter.scala:162)
        at com.quantifind.kafka.core.KafkaOffsetGetter$.com$quantifind$kafka$core$KafkaOffsetGetter$$readMessageKey(KafkaOffsetGetter.scala:187)
        at com.quantifind.kafka.core.KafkaOffsetGetter$$anonfun$startOffsetListener$1.apply$mcV$sp(KafkaOffsetGetter.scala:100)
        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)

用的是2.2.0的版本，消费者启动后出现这个错误，用zk储存位置启动时，出现消费者组，但不是我创建的，kafka储存位置启动时还是什么都没有。zk和kafka一直显示的只有topic

5年前

半兽人回复 ..... 在 KafkaOffsetMonitor：监控消费者和延迟的队列中：

消费者启动了吗？另外你看下offset的位置是在Kafka还是zk上，上面有介绍

5年前

..... 在 KafkaOffsetMonitor：监控消费者和延迟的队列发表评论：

大佬！kafkaMonitor的数据只能看到topic，其他的都没有，cmd命令能查看到，这是怎么回事

5年前

半兽人回复 ..... 在 kafka消费者Java客户端中：

你用的什么代码跑的？提供一下

5年前

订阅了 kafka 主题！ · 5年前