kafka-go
kafka-go copied to clipboard
#726 make message safetyTimeout configurable
PR makes message safetyTimeout configurable because SetReadDeadline for msg could differentiate based on the network and make it configurable instead of opinionated configuration