kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guozhang Wang <wangg...@gmail.com>
Subject Re: Issue with KTable State Store
Date Wed, 03 Aug 2016 22:08:00 GMT
Hello Srinidhi,

Are you using RocksDB as well like in the WordCountDemo for your
aggregation operator?

Guozhang


On Tue, Aug 2, 2016 at 5:20 PM, Srinidhi Muppalla <srinidhim@trulia.com>
wrote:

> Hey All,
>
> We are having issues successfully storing and accessing a Ktable on our
> cluster which happens to be on AWS. We are trying to store a Ktable of
> counts of ’success' and ‘failure’ strings, similar to the WordCountDemo in
> the documentation. The Kafka Streams application that creates the KTable
> works locally, but doesn’t appear be storing the state on our cluster. Does
> anyone have any experience working with Ktables and AWS or knows what
> configs related to our Kafka brokers or Streams setup could be causing this
> failure on our server but not on my local machine? Any insight into what
> could be causing this issue would be helpful.
>
> Here is what the output topic we are writing the Ktable to looks like
> locally:
>
> SUCCESS 1
> SUCCESS 2
> FAILURE 1
> SUCCESS 3
> FAILURE 2
> FAILURE 3
> FAILURE 4.
>
> Here is what it looks like on our cluster:
>
> SUCCESS 1
> SUCCESS 1
> FAILURE 1
> SUCCESS 1
> FAILURE 1
> FAILURE 1
> FAILURE 1.
>
> Thanks,
> Srinidhi
>
>


-- 
-- Guozhang

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message