KafkaHandler: allow customizing timeouts