version 1.0.28

• Properly handle ETIMEDOUT socket error when communicating with Kafka brokers and make socket error log messages more informative.
• Minor unit test code cleanup.