Message #97 from 2023-10-26 20:00:50
>
> Failed to send message:
> KafkaError{code=_MSG_TIMED_OUT,val=-192,str="Local: Message timed out"}.
> Message content: Message #98 from 2023-10-26 20:00:51
>
>
> The container clocks are a little out of sync, but both unavailability
> windows match to around one minute.
>
>
>
> Thanks a lot for your time, and looking forward to hearing from you.
>
>
>
>
>
>
>
--
Thanks & Regards,
Hemanth Savasere
f4d1dabc40ed5fab0bb/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java#L169
>> [6]:
>> https://github.com/apache/kafka/blob/0912ca27e2a229d2ebe02f4d1dabc40ed5fab0bb/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTa
erval.seconds=5
emit.checkpoints.interval.seconds=5
Wanted to know how the translation of consumer group happens from source to
destination cluster, especially need to know "how current offset and log
end offset translation happens from source to destination kafka cluster"
Thanks in advance.
--
Regards,
Hemanth Savasere
& Regards,
Hemanth Savasere
We have stumbled upon an issue on a running cluster with multiple
source/sink connectors:
1. One of our connectors was a JDBC sink connector connected to an SQL
Server database (using the oracle JDBC driver).
2. It turns out that the DB instance had a problem causing all queries
to be
Initially, I created a topic named "quickstart-events" and then produced
some messages into it, then consumed it from the kafka-console-consumer
with consumer group "quickstartGroup" and now I want to replicate the group
from source to destination.
When I run describe command to describe the group
t testing, a value greater than 1
is recommended to ensure availability such as 3.
offset.storage.replication.factor=1
status.storage.replication.factor=1
config.storage.replication.factor=1
# customize as needed
# replication.policy.separator = _
# sync.topic.acls.enabled = false
# emit.heartb
