Now that makes sense :) Thanks On Tue, Jul 9, 2019 at 1:43 AM Sophie Blee-Goldman <sop...@confluent.io> wrote:
> Hi Nitay, > > InMemoryKeyValueStore is in the internal package, not part of the public > API, so it is not meant to be used directly since it's implementation may > change at any time (as has happened here). It's intended that you use the > store builders/suppliers to get a new state store, but as you noticed this > means you do have to call init yourself. You can just use a > MockProcessorContext to do so (see the unit tests of these stores for an > example) > > Best, > Sophie > > On Mon, Jul 8, 2019 at 5:14 AM Nitay Kufert <nita...@ironsrc.com> wrote: > > > 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. > > > -- 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.
