Hello Nitay,
I have not heard someone else reporting similar things that may point to a
bug still.. Maybe you could try to reproduce the issue by first starting a
brand new app in 2.5, and then follow the upgrade path (with config
overrides) to 2.6 and see if it is easily reproducible, and if yes
Bumping for the off chance that during this time some sort of a bug was
reported that might explain this behaviour.. i will feel more comfortable
bumping our kafka versions this way :)
On Wed, Feb 24, 2021 at 12:48 PM Nitay Kufert wrote:
> I guess it's possible but very unlikely because it
I guess it's possible but very unlikely because it works perfectly with all
the previous versions and the current one? (2.5.1)
Why did a change in the version introduce NULLS there?
On Tue, Feb 23, 2021 at 9:16 PM Guozhang Wang wrote:
> Is it possible that the flattened values contain `null`
Is it possible that the flattened values contain `null` and hence `_.split`
throws?
On Tue, Feb 23, 2021 at 8:23 AM Nitay Kufert wrote:
> Hey, missed your replay - but the code i've shared above the logs is the
> code around those lines (removed some identifiers to make it a little bit
> more
Hey, missed your replay - but the code i've shared above the logs is the
code around those lines (removed some identifiers to make it a little bit
more generic):
> inputStream.flatMapValues(_.split).peek((k, v) => {val _ = $k ->
> ${v.printForDebug}")}) # return type KStream[Windowed[String],
>
Could you share your code around
>
com.app.consumer.Utils$.$anonfun$buildCountersStream$1(ServiceUtils.scala:91)
That seems to be where NPE is thrown.
On Wed, Jan 13, 2021 at 5:46 AM Nitay Kufert wrote:
> Hey,
> *Without any code change*, just by bumping the kafka version from 2.5.1 to
>
Hey,
*Without any code change*, just by bumping the kafka version from 2.5.1 to
2.6.1 (clients only) - my stream application started throwing
NullPointerException (sometimes, not in a predicted pattern).
Maybe it's worth mentioning that I also removed the "UPGRADE_FROM" conf
that was forgotten
