Re: KTable Suppress not working

2020-01-18 Thread Sushrut Shivaswamy
Hey John, I tried following the docs here about the configs: `streamsConfiguration.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 10 * 1024 * 1024L); // Set commit interval to 1 second. streamsConfiguration.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 1000);` https://kafka.apache.org/10/docum

Re: MirrorMaker 2

2020-01-18 Thread Vishal Santoshi
Last question .. so if I set the global property on the destination cluster, would that be overridden by the per topic retention ? I look at the zk config for the specific topic I do not see the specific overrides that I generally do so I would assume it is honoring the destination global retention

Re: MirrorMaker 2

2020-01-18 Thread Ryanne Dolan
I think that's right. If there is no per-topic retention configured, Kafka will use the cluster default. Ryanne On Sat, Jan 18, 2020, 10:21 AM Vishal Santoshi wrote: > Last question .. so if I set the global property on the > destination cluster, would that be overridden by the per topic retent