Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

chore(examples): update kafka-go #649

Merged
merged 1 commit into from
Apr 30, 2021
Merged

chore(examples): update kafka-go #649

merged 1 commit into from
Apr 30, 2021

Conversation

dominicbarnes
Copy link
Contributor

@dominicbarnes dominicbarnes commented Apr 30, 2021

Currently, simply running docker-compose up in examples/ doesn't work 100% correctly. When starting up docker-compose containers, it doesn't expose any mechanism to wait on a particular host to respond in a particular way, and kafka has a tendency to boot up pretty slowly.

In the producer-random example, it produces a message every second. One would expect that even if kafka isn't reachable right away, it would eventually succeed once kafka fully boots up. Unfortunately, the older version of kafka-go seems to hold on to the initial error, never able to succeed after failing to start.

By updating kafka-go, this seems to clear up all the problems reported in #637, and thus should fix that issue. It turns out we had pretty old versions of kafka-go hanging around, so they've all been updated to the latest (v0.4.15).

Currently, simply running `docker-compose up` in `examples/` doesn't
work 100% correctly. When starting up docker-compose containers, it
doesn't expose any mechanism to wait on a particular host to respond in
a particular way, and kafka has a tendency to boot up pretty slowly.

In the producer-random example, it produces a message every second. One
would expect that even if kafka isn't reachable right away, it would
eventually succeed once kafka fully boots up. Unfortunately, the older
version of kafka-go seems to hold on to the initial error, never able to
succeed after failing to start.

By updating kafka-go, this seems to clear up all the problems reported
in #637, and thus should fix that issue.
Copy link
Contributor

@achille-roussel achille-roussel left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🙌

@achille-roussel achille-roussel self-assigned this Apr 30, 2021
@dominicbarnes dominicbarnes merged commit d15a635 into master Apr 30, 2021
@dominicbarnes dominicbarnes deleted the fix-examples branch April 30, 2021 22:11
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants