avoid direct exceptions from KafkaStream.write