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

Check compatible librdkafka at runtime #88

Closed
kevinburke opened this issue Aug 24, 2017 · 3 comments
Closed

Check compatible librdkafka at runtime #88

kevinburke opened this issue Aug 24, 2017 · 3 comments

Comments

@kevinburke
Copy link

The consumer_example.go has this example for a Consumer:

	c, err := kafka.NewConsumer(&kafka.ConfigMap{
		"bootstrap.servers":    broker,
		"group.id":             group,
		"session.timeout.ms":   6000,
		"default.topic.config": kafka.ConfigMap{"auto.offset.reset": "earliest"}}

I had to change "earliest" to kafka.OffsetBeginning to get it to work. Currently the Kafka consumer is failing on No such configuration property: "session.timeout.ms". I'm not sure what's going on there, I'm currently trying to debug it.

@kevinburke
Copy link
Author

The odd thing is these work locally (on Mac) but not in my CI environment (ubuntu). I installed librdkafka by running add-apt-repository "deb [arch=amd64] http://packages.confluent.io/deb/3.3 stable main" && apt-get update && apt-get install librdkafka1.

@kevinburke
Copy link
Author

Ah, turns out I was using librdkafka 0.8.4 or so on that machine..

@edenhill
Copy link
Contributor

So old!
We'll add a runtime check to verify the librdkafka version.

@edenhill edenhill changed the title Not sure the consumer examples work Check compatible librdkafka at runtime Aug 25, 2017
edenhill added a commit that referenced this issue Sep 6, 2017
Build and run-time checking of librdkafka version (#88)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants