Streams Processing meetup on Wednesday, February 5, 2020 at LinkedIn, Sunnyvale

*[bcc: (users,dev)@kafka.apache.org ]* Hello, The Streams Infra team invites you to attend the Streams Processing meetup to be held on Wednesday, February 5, 2020. This meetup will focus on Apache Kafka, Apache Samza and related streaming technologies. *Where*: Unify Con

KStreams in-memory state-store

Hi all, I have question about kafka-streams, particularly in-memory state-store (/org.apache.kafka.streams.state.internals.InMemoryKeyValueStore/). I believe that topology is irrelevant here, but let's say I have one source topic with single partition feeding data into one statefull processor a

RE: org.apache.kafka.common.KafkaException: org.apache.kafka.common.serialization.ByteArraySerializer is not an instance of org.apache.kafka.common.serialization.Serializer

Thanks for the reply, looks like half the message got deleted. Much appreciated! Extracts from the pom: org.springframework.boot spring-boot-starter-data-jpa spring-boot-starter-logging org.springframew

Re: org.apache.kafka.common.KafkaException: org.apache.kafka.common.serialization.ByteArraySerializer is not an instance of org.apache.kafka.common.serialization.Serializer

unsubscribe On Mon, Jan 27, 2020 at 8:51 AM wrote: > > > Hi, I would appreciate any help on this. > > Thanks a stack! > > Buks > > > > > org.apache.kafka > kafka-clients > ${kafka.version} > > > > > 2.3.1 > > > > > org.springframework.boot > spring-boot-starter-parent >

Re: Reg: Guidance for Machine Capacity Plan

Hi, Please help/guide me to identify the size of the cluster. Thanks and Regards, Gowtham S. On Fri, 24 Jan 2020 at 14:31, Gowtham S wrote: > Hi, > > We are in the process of deploying Kafka in our service. We need to decide > the machine capacity plan, we arrived at the below formulae for de

Re: org.apache.kafka.common.KafkaException: org.apache.kafka.common.serialization.ByteArraySerializer is not an instance of org.apache.kafka.common.serialization.Serializer

Hey Buks, On Mon, 27 Jan 2020 at 07:51, wrote: > > > Hi, I would appreciate any help on this. > > Thanks a stack! > > Buks > > > > > org.apache.kafka > kafka-clients > ${kafka.version} > > > > > 2.3.1 > > > > > org.springframework.boot > spring-boot-starter-parent > 2.