Hi Fabian, Here we are: https://issues.apache.org/jira/browse/FLINK-24622 <https://issues.apache.org/jira/browse/FLINK-24622>
Feel free to modify the description as I lazily copied and pasted our discussion here. Best, Mason > On Oct 22, 2021, at 3:31 AM, Fabian Paul <fabianp...@ververica.com> wrote: > > Hi Mason, > > This seems to be a bug with the current KafkaSource and also the unified > Sources in general. Can you open a bug ticket in jira? I think the enumerator > should take of first joining all the async threads before closing the > enumerator. > > Best, > Fabian
