alexeyt820 commented on issue #7782: [FLINK-11693] Add KafkaSerializationSchema that directly uses ProducerRecord URL: https://github.com/apache/flink/pull/7782#issuecomment-466444683 Currently I use Kafka 1.0 with Kafka 0.11 connector (i’m still on Flink 1.6.x) I don’t use custom partitioning now, therefore none of the fields ‘KafkaSerializationSchema.PartitionInfo’ will be immediately used, but I have requirement for which I likely will need to know partitions or at least number of partitions for topic. ‘KafkaSerializationSchema.PartitionInfo’ were exposed to keep general parity with FlinkPartitioner. Regarding setting/unsettling producer - we can create PartitionInfo before calling serialize and keep map in Producer itself. Also we can make PartitionInfo as transient member of TransactionState, it seems more changes but this way it will have same lifetime as producer.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
