Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5882

NullPointerException in StreamTask

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.11.0.0, 0.11.0.1, 0.11.0.2
    • Fix Version/s: 1.1.1
    • Component/s: streams
    • Labels:
      None

      Description

      It seems bugfix KAFKA-5073 is made, but introduce some other issue.
      In some cases (I am not sure which ones) I got NPE (below).

      I would expect that even in case of FATAL error anythink except NPE is thrown.

      2017-09-12 23:34:54 ERROR ConsumerCoordinator:269 - User provided listener org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener for group streamer failed on partition assignment
      java.lang.NullPointerException: null
              at org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:123) ~[myapp-streamer.jar:?]
              at org.apache.kafka.streams.processor.internals.StreamThread.createStreamTask(StreamThread.java:1234) ~[myapp-streamer.jar:?]
              at org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.createTask(StreamThread.java:294) ~[myapp-streamer.jar:?]
              at org.apache.kafka.streams.processor.internals.StreamThread$AbstractTaskCreator.retryWithBackoff(StreamThread.java:254) ~[myapp-streamer.jar:?]
              at org.apache.kafka.streams.processor.internals.StreamThread.addStreamTasks(StreamThread.java:1313) ~[myapp-streamer.jar:?]
              at org.apache.kafka.streams.processor.internals.StreamThread.access$1100(StreamThread.java:73) ~[myapp-streamer.jar:?]
              at org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener.onPartitionsAssigned(StreamThread.java:183) ~[myapp-streamer.jar:?]
              at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:265) [myapp-streamer.jar:?]
              at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:363) [myapp-streamer.jar:?]
              at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:310) [myapp-streamer.jar:?]
              at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:297) [myapp-streamer.jar:?]
              at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1078) [myapp-streamer.jar:?]
              at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1043) [myapp-streamer.jar:?]
              at org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:582) [myapp-streamer.jar:?]
              at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:553) [myapp-streamer.jar:?]
              at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:527) [myapp-streamer.jar:?]
      2017-09-12 23:34:54 INFO  StreamThread:1040 - stream-thread [streamer-3a44578b-faa8-4b5b-bbeb-7a7f04639563-StreamThread-1] Shutting down
      2017-09-12 23:34:54 INFO  KafkaProducer:972 - Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
      

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              habdank Seweryn Habdank-Wojewodzki
            • Votes:
              4 Vote for this issue
              Watchers:
              8 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: