Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-3314

Flume kafka source/channel throws NPE when migrateOffsets() is called on nonexistent topics

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 1.8.0
    • Fix Version/s: 1.9.0, 2.0.0
    • Component/s: None
    • Labels:
      None

      Description

      KafkaConsumer.partitionsFor(topicStr) returns null if the topic does not exist and auto.create.topics.enabled has been set to false on Kafka side.
      This case is not handled in the Flume code which leads to NPE.

      Null check needs to be added and warning message should be logged instead of the exception stacktrace.

        Attachments

          Activity

            People

            • Assignee:
              turcsanyip Peter Turcsanyi
              Reporter:
              turcsanyip Peter Turcsanyi
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: