checkpoint for KafkaProducer