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

Reply via email to