Releases: optiopay/kafka
Releases · optiopay/kafka
Subdirectory v2 for go modules compatibility
Go modules support
Merge pull request #122 from optiopay/go-modules Init go modules
Fixed bug in protocol
Kafka server sends a length of a headers array in a wrong format.
Remove long log line, update cerificate
Merge pull request #106 from optiopay/remove-metadata-log Remove multiline log message which pollutes the log
TLS config hotfix
When empty strings are passed for the TLS configuration initiate a normal connection.
Support all error codes
Now driver can handle all error codes returned by kafka.
Hotfix in OffsetResponse
Fixed small bug in OffsetResponse implementation
Support versioned requests/responses
- Now kafka driver negotiate version protocol when it established connection and send all request accordingly.
- CreateTopic command added.
TLS support
Add tls (#85) * add TLS encryption * accept TLS certificates directly, not though files * send ReplicaID = -1 * fix after review * add test for TLS * fix testserver * fix data race