I am testing MM2. I got the connector working but it is creating topics in the
downstream cluster like this mm-poc-src.grp1-top1 which is the
alias.. How can I create the downstream topic to be the exact name
as the source?
Also, do you provide commercial support for open source kafka? Or
Hi guys,
We are using Kafka Connect to do Kafka to Kafka data replication between
DCs.
For this config item *producer.max.in.flight.requests.per.connection* the
default value in KafkaProducer (Kafka client) is 5 and can still
maintain idempotence, but in Kafka Connect the default value of this is
Hello,
Has anyone experienced this scenario before when having a distributed connect
cluster:
[kafka-coordinator-heartbeat-thread | connect-cluster] INFO
org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Worker
clientId=connect-1, groupId=connect-cluster] Member
Congratulations, Randall!
best,
Colin
On Wed, Apr 21, 2021, at 09:51, Mickael Maison wrote:
> Congratulations Randall, well deserved!
>
> On Mon, Apr 19, 2021 at 10:55 PM Konstantine Karantasis
> wrote:
> >
> > Congratulations Randall!
> >
> > Konstantine
> >
> > On Mon, Apr 19, 2021 at 1:14
Hi Ran,
As part of the KRaft work outlined in KIP-500, we are planning on creating an
authorizer that does not rely on ZooKeeper. This work is not included in the
2.8 release, however.
regards,
Colin
On Mon, Apr 19, 2021, at 13:02, Ran Lupovich wrote:
> Hello, Maybe I missed it in the
Guozhang,
What does this mean if the changelog topic was disabled ? If thread 2 and
thread 4 are running in two different nodes and a rebalance occurs, thread 2
will not realize it is a zombie without the write to the changelog topic, right
? I am trying to understand the cases under which the