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

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

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 1.8.0
    • 1.9.0, 2.0.0
    • None
    • 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
          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

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

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment