subject:"\[GitHub\] \[flink\] JingsongLi edited a comment on pull request #18412\: \[FLINK\-25696\]\[datastream\] Introduce MetadataPublisher interface to SinkWriter"

[GitHub] [flink] JingsongLi edited a comment on pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

2022-01-25 Thread GitBox

JingsongLi edited a comment on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1020739383 > From a Kafka connector side, the subscriber is not updated on every record, and just when the KafkaProducer is flushed it is only updated for a bulk of records

[GitHub] [flink] JingsongLi edited a comment on pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

2022-01-24 Thread GitBox

JingsongLi edited a comment on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1020739383 > From a Kafka connector side, the subscriber is not updated on every record, and just when the KafkaProducer is flushed it is only updated for a bulk of records