[GitHub] flink pull request #5661: [FLINK-8896][kafka08] fix Kafka08Fetcher trying to...
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5661 ---
[GitHub] flink pull request #5661: [FLINK-8896][kafka08] fix Kafka08Fetcher trying to...
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5661 [FLINK-8896][kafka08] fix Kafka08Fetcher trying to look up topic "n/a" on partiton "-1" ## What is the purpose of the change `Kafka08Fetcher` uses a `MARKER` to make sure the main thread