flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java (1 line): - line 91: // TODO empty - wait for FLINK-31748 to implement it.