apache-kafka - 启动 Kafka 流的第二个实例时出现 NullPointerException
问题描述
当我启动应用程序的第二个实例时,会发出 NPE。
11:54:16.042 [zgsolucoes-zeroglosa-nucleo-stream-6802b25b-521e-4f67-b5fe-c18269bcad32-StreamThread-3] ERROR o.a.k.s.p.internals.StreamThread - stream-thread [zgsolucoes-zeroglosa-nucleo-stream-6802b25b-521e-4f67-b5fe-c18269bcad32-StreamThread-3] Error caught during partition assignment, will abort the current process and re-throw at the end of rebalance
java.lang.NullPointerException: null
at org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:186)
at org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:115)
at org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.createTask(StreamThread.java:352)
at org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.createTask(StreamThread.java:310)
at org.apache.kafka.streams.processor.internals.StreamThread$AbstractTaskCreator.createTasks(StreamThread.java:295)
at org.apache.kafka.streams.processor.internals.TaskManager.addNewActiveTasks(TaskManager.java:160)
at org.apache.kafka.streams.processor.internals.TaskManager.createTasks(TaskManager.java:120)
at org.apache.kafka.streams.processor.internals.StreamsRebalanceListener.onPartitionsAssigned(StreamsRebalanceListener.java:77)
at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.invokePartitionsAssigned(ConsumerCoordinator.java:278)
at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:419)
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:439)
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:358)
at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:490)
at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1275)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1241)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216)
at org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:853)
at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:753)
at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:697)
at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:670)
所有消费和生产的主题都有 10 个分区
在 StreamTask:185:
分区 = zeroglosanucleo.public.sistema_financeiro-4
topology.sourcesByTopic = zeroglosanucleo.public.fibodefinicaomotivoglosa -> {SourceNode@8815} “KSTREAM-SOURCE-0000000036:主题:[zeroglosanucleo.public.fibodefinicaomotivoglosa]”
一审工作正常。
解决方案
推荐阅读
- php - 无法使用 fputcsv() 和 pg_fetch_xxx() 返回的数组获取 csv 文件
- c++ - 嵌套枚举类与否?
- mysql - 如何为每个外键获取 SQL AVG()
- angularjs - angular-ui-router 总是将应用程序附加到 url
- kotlin - 无法在命令行上运行 Kotlin 程序
- javascript - 在某些安卓设备上显示白屏而不是谷歌地图
- ffmpeg - 如何在 ffmpeg 中转换为良好的图像质量?
- mongodb - 如何修复:错误:身份验证失败
- tsql - How to count an occurance of a specific value in each partition?
- laravel - Eloquent hasManyThrough 与多个 Throughs 的关系