java.lang.RuntimeException: Fetching topic metadata from all brokers failed. See log warning for more information. at gobblin.source.extractor.extract.kafka.KafkaWrapper$KafkaOldAPI. getFilteredMetadataList(KafkaWrapper.java:274) at gobblin.source.extractor.extract.kafka.KafkaWrapper$ KafkaOldAPI.getFilteredTopics(KafkaWrapper.java:233) at gobblin.source.extractor.extract.kafka.KafkaWrapper.getFilteredTopics( KafkaWrapper.java:135) at gobblin.source.extractor.extract.kafka.KafkaSource. getFilteredTopics(KafkaSource.java:381) at gobblin.source.extractor.extract.kafka.KafkaSource. getWorkunits(KafkaSource.java:105)

GitHub | chavdar | 6 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    GitHub comment 1245#243671047

    GitHub | 6 months ago | chavdar
    java.lang.RuntimeException: Fetching topic metadata from all brokers failed. See log warning for more information. at gobblin.source.extractor.extract.kafka.KafkaWrapper$KafkaOldAPI. getFilteredMetadataList(KafkaWrapper.java:274) at gobblin.source.extractor.extract.kafka.KafkaWrapper$ KafkaOldAPI.getFilteredTopics(KafkaWrapper.java:233) at gobblin.source.extractor.extract.kafka.KafkaWrapper.getFilteredTopics( KafkaWrapper.java:135) at gobblin.source.extractor.extract.kafka.KafkaSource. getFilteredTopics(KafkaSource.java:381) at gobblin.source.extractor.extract.kafka.KafkaSource. getWorkunits(KafkaSource.java:105)

    Root Cause Analysis

    1. java.lang.RuntimeException

      Fetching topic metadata from all brokers failed. See log warning for more information. at gobblin.source.extractor.extract.kafka.KafkaWrapper$KafkaOldAPI. getFilteredMetadataList(KafkaWrapper.java:274) at gobblin.source.extractor.extract.kafka.KafkaWrapper$ KafkaOldAPI.getFilteredTopics(KafkaWrapper.java:233) at gobblin.source.extractor.extract.kafka.KafkaWrapper.getFilteredTopics( KafkaWrapper.java:135) at gobblin.source.extractor.extract.kafka.KafkaSource. getFilteredTopics(KafkaSource.java:381) at gobblin.source.extractor.extract.kafka.KafkaSource. getWorkunits(KafkaSource.java:105)

      at gobblin.runtime.SourceDecorator.getWorkunits()
    2. gobblin.runtime
      SourceDecorator.getWorkunits
      1. gobblin.runtime.SourceDecorator.getWorkunits(SourceDecorator.java:54)
      1 frame