Re: Clarity on external/storm-kafka-client

2016-12-19 Thread Ambud Sharma
The Storm-External project has the Kafka Spouts and bolts; Storm doesn't
directly control the compatibility with Kafka, with that being said the
default version of Kafka integrations will work according to your list; so
the answer is Yes about the "compatibility"

However, it's still possible to use older version of Kafka with newer
version of Storm and vice-a-versa by either implementing your own Spouts /
Bolts or carefully working with selective dependency selection in your
topology.



On Wed, Nov 30, 2016 at 1:12 PM, Kristopher Kane 
wrote:

> I need some clarification on Kafka broker version support across Storm
> branches.
>
> storm-kafka-client uses the 'new' Kafka APIs
>
>
> The master branch README of storm-kafka-client says that it ONLY supports
> Kafka version .10 and later.
>
> The 1.x branch README of storm-kafka-client says that it ONLY supports
> Kafka version .10 and later.
>
> The 1.0.x branch README of storm-kafka-client says that it ONLY supports
> Kafka version .9 and later.
>
>
> Is it really true that 1.x and later only support Kafka version .10 and
> later or that it was tested on Kafka .10 but since it is the new API really
> still works on .9 as well  and the wording was never changed in the README?
>
> Thanks,
>
> Kris
>


Clarity on external/storm-kafka-client

2016-11-30 Thread Kristopher Kane
I need some clarification on Kafka broker version support across Storm
branches.

storm-kafka-client uses the 'new' Kafka APIs


The master branch README of storm-kafka-client says that it ONLY supports
Kafka version .10 and later.

The 1.x branch README of storm-kafka-client says that it ONLY supports
Kafka version .10 and later.

The 1.0.x branch README of storm-kafka-client says that it ONLY supports
Kafka version .9 and later.


Is it really true that 1.x and later only support Kafka version .10 and
later or that it was tested on Kafka .10 but since it is the new API really
still works on .9 as well  and the wording was never changed in the README?

Thanks,

Kris