Re: serdeProps what does that mean

2019-10-31 Thread Bart van Deenen
an add any configuration you want to the global > `KafkaStreams` configuration and it will be forwarded. > > Hope this helps. > > > -Matthias > > On 10/28/19 5:34 AM, Bart van Deenen wrote: > > Hi all > > > > I need a custom serde for Kafka. Our serde n

serdeProps what does that mean

2019-10-28 Thread Bart van Deenen
Hi all I need a custom serde for Kafka. Our serde needs a SchemaStore instance with some state, and I'm trying to figure out how to get this into the serde. I'm trying to follow along with this example https://github.com/apache/kafka/blob/ad5f31c3e6868757eab9c8dd71efd5fd65f06ac6/streams/examples/

Re: Broker that stays outside of the ISR, how to recover

2019-10-26 Thread Bart van Deenen
eper and then start following the topic partition leaders for all the > > topic partition replicas assigned to it. > > > > -- Peter > > > > >> On Oct 18, 2019, at 12:16 AM, Bart van Deenen < > > bartvandee...@fastmail.fm> wrote: > > > H

Broker that stays outside of the ISR, how to recover

2019-10-18 Thread Bart van Deenen
Hi all We had a Kafka broker failure (too many open files, stupid), and now the partitions on that broker will no longer become part of the ISR set. It's been a few days (organizational issues), and we have significant amounts of data on the ISR partitions. In order to make the partitions on t