doc-laowu commented on issue #34890: URL: https://github.com/apache/beam/issues/34890#issuecomment-2865623636
I am using the 2.61.0 version of the beam, but I noticed that in the latest 2.64.0 version, the FlinkSourceSplitAnalyzer # start function has been checked to determine if it has not been initialized before execution. But I still have other questions, can Kafka consumption still be normal when the parallelism of Flink tasks changes or the number of partitions in Kafka is increased? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
