[ https://issues.apache.org/jira/browse/KAFKA-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159365#comment-17159365 ]
Brian Forkan commented on KAFKA-10205: -------------------------------------- [~mjsax] this fix appears to do the trick. I will keep monitoring of course and will let you know if we see it again. Thanks for your help everyone. > NullPointerException in StreamTask > ---------------------------------- > > Key: KAFKA-10205 > URL: https://issues.apache.org/jira/browse/KAFKA-10205 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 2.5.0 > Reporter: Brian Forkan > Assignee: John Roesler > Priority: Minor > > In our Kafka Streams application we have been experiencing a > NullPointerException when deploying a new version of our application. This > does not happen during a normal rolling restart. > The exception is: > {code:java} > Error caught during partition assignment, will abort the current process and > re-throw at the end of > rebalance","stack_trace":"java.lang.NullPointerException: nullError caught > during partition assignment, will abort the current process and re-throw at > the end of rebalance","stack_trace":"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:1243) > at > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1173) > at brave.kafka.clients.TracingConsumer.poll(TracingConsumer.java:86) at > brave.kafka.clients.TracingConsumer.poll(TracingConsumer.java:80) 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) > {code} > And the relevant lines of code - > [https://github.com/apache/kafka/blob/2.5/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java#L184-L196] > I suspect "topology.source(partition.topic());" is returning null. > Has anyone experienced this issue before? I suspect there is a problem with > our topology but I can't replicate this on my machine so I can't tell. > -- This message was sent by Atlassian Jira (v8.3.4#803005)