Thanks Guozhang. I can confirm the issue is resolved.
Hamid
I have pushed a hotfix to both trunk and 0.10.1, could you check if the
issue is resolved by now?
On Mon, Oct 3, 2016 at 7:18 AM, Hamidreza Afzali <
hamidreza.afz...@hivestreaming.com> wrote:
> Thanks Guozhang. We use ProcessorTopologyTestDriver for unit tests.
>
> Hamid
>
>
> > On 28 Sep 2016, a
Thanks Guozhang. We use ProcessorTopologyTestDriver for unit tests.
Hamid
> On 28 Sep 2016, at 11:48 AM, Hamidreza Afzali
> wrote:
>
> Hi,
>
> We are using the latest Kafka 0.10.1 branch. The combination of
> ProcessorTopologyTestDriver and WindowedStreamPartitioner is resulting in a
> div
Thanks for reporting this Hamid. The ProcessorTopologyTestDriver is used
only in ProcessorTopologyTest and is currently not expected to use
otherwise, and hence that is why we overwrite the MockProducer's
partitionsFor function to only return the empty list. Is there any
particular reason that you
Hi,
We are using the latest Kafka 0.10.1 branch. The combination of
ProcessorTopologyTestDriver and WindowedStreamPartitioner is resulting in a
division by 0 exception because of the empty list of partitions:
https://github.com/apache/kafka/blob/0.10.1/streams/src/test/java/org/apache/kafka/tes
