Hey,
Following https://issues.apache.org/jira/browse/KAFKA-7918 I had to change
the current implementation of our unit tests.
Before the change, I created a store using:
new InMemoryKeyValueStore[String, BigDecimal](
countersStoreName, Serdes.String, SpecificSerdes.bigDecimalSerde
)
It seems that post the change, I need to do:
Stores.keyValueStoreBuilder(
Stores.inMemoryKeyValueStore(countersStoreName), Serdes.String,
SpecificSerdes.bigDecimalSerde
).build()
But when I do, and I try to use the "put" command like so:
countersStore.put("unique_key_1", BigDecimal(9.87))
I get:
An exception or error caused a run to abort.
java.lang.NullPointerException
at
org.apache.kafka.streams.state.internals.MeteredKeyValueStore.put(MeteredKeyValueStore.java:160)
When digging a little into the code, it seems that the "init" function is
not called, which in turn keep putTime un-initialized.
Am I missing something?
--
Nitay Kufert
Backend Developer
[image: ironSource] <http://www.ironsrc.com>
email nita...@ironsrc.com
mobile +972-54-5480021
fax +972-77-5448273
skype nitay.kufert.ssa
9 Ehad Ha'am st. Tel- Aviv
ironsrc.com <http://www.ironsrc.com>
[image: linkedin] <https://www.linkedin.com/company/ironsource> [image:
twitter] <https://twitter.com/ironsource> [image: facebook]
<https://www.facebook.com/ironSource> [image: googleplus]
<https://plus.google.com/+ironsrc>
This email (including any attachments) is for the sole use of the intended
recipient and may contain confidential information which may be protected
by legal privilege. If you are not the intended recipient, or the employee
or agent responsible for delivering it to the intended recipient, you are
hereby notified that any use, dissemination, distribution or copying of
this communication and/or its content is strictly prohibited. If you are
not the intended recipient, please immediately notify us by reply email or
by telephone, delete this email and destroy any copies. Thank you.
