This PR updates Kafka go client to the latest version which includes fixes we need to create partitions.
While doing this update, we need to make some changes due to the changes in the interface of the client.
Finally, this PR also handles an error during observation, which would cause misleading outputs/errors in case we get some unexpected errors.
This PR updates Kafka go client to the latest version which includes fixes we need to create partitions. While doing this update, we need to make some changes due to the changes in the interface of the client. Finally, this PR also handles an error during observation, which would cause misleading outputs/errors in case we get some unexpected errors.
Signed-off-by: Hasan Turken turkenh@gmail.com