[
https://issues.apache.org/jira/browse/STORM-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268881#comment-15268881
]
ASF GitHub Bot commented on STORM-1646:
---------------------------------------
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.
> Intermittent test failures in storm-kafka unit tests
> ----------------------------------------------------
>
> Key: STORM-1646
> URL: https://issues.apache.org/jira/browse/STORM-1646
> Project: Apache Storm
> Issue Type: Bug
> Reporter: Paul Poulosky
> Assignee: Paul Poulosky
>
> We have been seeing intermittent test failures in KafkaUtilsTest on slow
> hardware and lightly resourced VMs, as well as an intermittent race condition
> when running the storm-kafka ExponentialBackoffManager unit test.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
