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