Re: Reading from lagging replicas

2021-09-20 Thread Michał Łowicki
> > https://kafka.apache.org/documentation/#brokerconfigs_replica.lag.time.max.ms > > Hope that helps. > > Thank you. > Luke > > On Mon, Sep 20, 2021 at 8:30 PM Michał Łowicki wrote: > > > Hey, > > > > When Java client is reading from replica then how is handled the

Reading from lagging replicas

2021-09-20 Thread Michał Łowicki
? (pointers to code, configuration options would be awesome). Thanks in advance. -- BR, Michał Łowicki

How is __consumer_offsets partitioned?

2021-09-03 Thread Michał Łowicki
Hey, Could someone please point me to the code / doc where I can find information what is used as key and how messages are spread across partitions for this internal topic? -- BR, Michał Łowicki

Possible race in handling IP address change

2021-05-19 Thread Michał Łowicki
cefully and those log with: log.info("Hostname for node {} changed from {} to {}.", id, > connectionState.host(), host); -- BR, Michał Łowicki

Re: Is bootstrap.servers resolved only once?

2021-05-17 Thread Michał Łowicki
r.com/ConfluentInc>[image: LinkedIn] > <https://www.linkedin.com/company/confluent/>[image: Slack] > <https://slackpass.io/confluentcommunity>[image: YouTube] > <https://youtube.com/confluent> > [image: Kafka Summit] <https://www.kafka-summit.org/> > > > On

Is bootstrap.servers resolved only once?

2021-05-17 Thread Michał Łowicki
o the cluster assuming that bootstrap.servers will resolve to new IPs? -- BR, Michał Łowicki

Re: Java client 2.4.1 doesn't always handle IP changes

2021-05-14 Thread Michał Łowicki
Checked Java DNS resolution caching: ``` sun.net.InetAddressCachePolicy.get(); sun.net.InetAddressCachePolicy.getNegative(); ``` and those return 30 and 10 respectively. So it seems fine and it shouldn't cache for too long. On 2021/05/14 12:55:00, Michał Łowicki wrote: > Hey, >

Java client 2.4.1 doesn't always handle IP changes

2021-05-14 Thread Michał Łowicki
ava 14). -- BR, Michał Łowicki

Mechanism similar to __consumer_offsets but for consumer.endOffsets

2020-10-28 Thread Michał Łowicki
fka/clients/consumer/Consumer.java#L239> is one option, but maybe it can be done in a different way. -- BR, Michał Łowicki