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
Support for new Producer/Consumer without Zookeeper connection #37
Comments
@barrycommins did you find a way around this? I am seeing the same issue and was wondering if you found a workaround |
@mbogoevici can we get some love here? Is there any way currently to bypass using zookeeper? |
@nitantbhartia Hi, I've only gotten back to looking at this today, and it looks like there's a very simple solution. just set I've tried this on |
@barrycommins Thanks for checking and responding! I suppose we can close this issue now? |
@mbogoevici Sure, I'll close it now, thanks. |
One thing that might be worth noting though is that even if This is default behaviour in Kafka unless |
Yes - this is documented in the setting description (see http://docs.spring.io/spring-cloud-stream/docs/Brooklyn.BUILD-SNAPSHOT/reference/htmlsingle/#_configuration_options_2) . That is the behaviour of the Kafka broker and there's nothing that can be do on our side to control it - so the only thing we can do is to document it. |
Oops, RTFM I guess :-) |
No worries! Thanks for staying in touch! Looking forward to more :)! |
Just a heads up if you, like me, came upon this issue and still have problems... @barrycommins made a small typo in the property - 'kakfa.binder' should of course be 'kafka.binder'. Serves me right for blindly copy-pasting but hopefully this saves somebody else the 15 minutes I spent wondering why this didn't work. |
@jensdt Sorry about that, I'd say I'd type 'kakfa' instead of 'kafka' about 50% of the time! I've updated the original comment now to correct it. |
Thanks for |
Just to close this out; the upcoming 2.0 release has no dependencies on zookeeper at all. Even though the bindings have used the pure java client for a long time now, we still needed to go via Zookeeper to provision topics. There is now a pure Java |
@garyrussell is this part of any of the current milestones? As of M5 I am still seeing zookeeper connections being opened. |
There is no M5; what do you mean? 2.0.0.M4 was released last week and no longer has zookeeper dependencies. This commit: 50b8955 As you can see from the tag it is in M4 |
Sorry I was not being accurate, M5 was referring to Spring Cloud Finchley.M5 release train. |
See the project page. Finchley.M5 includes Elmhurst.M3; you need to override the stream dependencies to Elmhurst.M4. Presumably it will be in the next Finchley milestone. |
Hi,
is there any plan to support using the new Consumer / new Producer configuration without having to specify the connection to Zookeeper? http://kafka.apache.org/documentation.html#producerconfigs
It looks like it will default to localhost in
KafkaBinderConfigurationProperties
, and is an expected setting.In some Kafka configurations, particularly when using ACLs, the connection to Zookeeper will be firewalled and the producer/consumer will only be allowed to connect to Kafka. This is often the case when management of topics is restricted.
The text was updated successfully, but these errors were encountered: