Github user srdo commented on the pull request:

    https://github.com/apache/storm/pull/1335#issuecomment-216564619
  
    storm-kafka will probably support 0.10.0, I believe the Kafka developers 
version their APIs so new clusters can talk to old clients. That shouldn't 
affect the choice of configuration parameters though, since any 0.8.x support 
in 0.10.0 would expect 0.8.x configuration parameters.
    
    See 
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/api/ApiVersion.scala
 and how it's used in 
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/KafkaApis.scala
 if you're interested. The way I understand it is the client indicates which 
version of the API it wants to use, and then the broker uses that version of 
the API for requests/responses.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---

Reply via email to