JingsongLi opened a new pull request #28: URL: https://github.com/apache/flink-table-store/pull/28
StoreSink is a hybrid sink. We need: - Introduce LocalCommitterOperator, kafka can only use the same produceId when committing, because starting multiple instances of a producer with a single produceId is not allowed by the kafka server. So we have to reuse the producer instance within the same process to commit. - Committable can not be serialized, Kafka reuses producer instance in Committable. and where the producer will not be serialized. - Integrate log store to StoreSink. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
