ight (what I assume Connect does -- not
> sure if there might be a concrete connector dependency?) there should
> not be out-of-order data.
>
> But I hope that some Connect expert can chime in...
>
>
> -Matthias
>
> On 1/28/21 12:24 AM, nitin agarwal wrote:
&g
Assuming the configurations are as follows:
max.inflight.requests.per.connection=1
enable.idempotence=false
Thanks,
Nitin
On Thu, Jan 28, 2021 at 1:53 PM nitin agarwal
wrote:
> Thanks for quick reply, I have understood this behaviour now.
> I have another follow up question.
>
rdering is guaranteed even with
> multiple in-flight requests per connection though.
>
>
>
> -Matthias
>
> On 1/27/21 11:35 AM, nitin agarwal wrote:
> > Hi All,
> >
> > I see that max.inflight.requests.per.connection is set to 1 explicitly in
> > Kafka C
Hi All,
I see that max.inflight.requests.per.connection is set to 1 explicitly in
Kafka Connect but there is a way to override it. I want to understand the
impact of setting its value > 1.
As per my understanding, it will lead to data loss in some cases. Is it
correct ?
Thank you,
Nitin
hen there are consumer groups to
> replicate. Try creating a consumer group that matches the groups whitelist.
>
> Hope that helps!
>
> Ryanne
>
> On Tue, Jun 16, 2020 at 8:45 AM nitin agarwal
> wrote:
>
> > Hi,
> >
> > I have a few questions regarding Mirror
Hi,
I have a few questions regarding MirrorMaker 2.0.
Q1. Is there JIRA for adding HeartbeatMessageFormatter and
CheckpointMessageFormatter? I want to read messages of the
topic source.checkpoints.internal.
Q2. While running MirrorMaker 2.0, I couldn't find the MBeans
for MirrorCheckpointConnect
What value of zookeeper.connect is specified in server.properties of the
broker. If it is having IPs rather than hostname then it is expected
behaviour as all three Zookeeper nodes are destroyed and broker will not be
able to communicate with Zookeeper.
Thanks,
Nitin
On Tue, Apr 7, 2020 at 8:44 P
Hi,
I have graduated from IIT Hyderabad in 2014. I am currently working as
Software Development Engineer in Flipkart. I want to contribute in Kafka
project, can you please add my username as contributor in Kafka project.
Username: nitin1891
Thanks,
Nitin
