Hi All,
I am looking for an help to resolve a MirrorMaker2 issue. Here is the exception
I am receiving at the kafka connect end during launch.
2020-06-19 05:21:45,006 INFO [Worker clientId=connect-1,
groupId=mirrormaker2-cluster] Cluster ID: UYTj0E0PQOmG9PAb6axowg
(org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1]
2020-06-19 05:21:45,008 ERROR [Worker clientId=connect-1,
groupId=mirrormaker2-cluster] Uncaught exception in herder work thread,
exiting: (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
[DistributedHerder-connect-1]
org.apache.kafka.common.errors.GroupAuthorizationException: Not authorized to
access group: mirrormaker2-cluster
This group is something which is internally created/used by the MirrorMaker and
I am not sure how do we give the auth permission as my MM CR looks as shown.
apiVersion: kafka.strimzi.io/v1alpha1
kind: KafkaMirrorMaker2
metadata:
name: brcm-mirror-maker2
spec:
version: 2.4.0
replicas: 1
connectCluster: "mm-backup-cluster"
clusters:
- alias: "mm-src-cluster"
authentication:
certificateAndKey:
certificate: user.crt
key: user.key
secretName: mm-consumer-user
type: tls
bootstrapServers: mm-src-cluster-kafka-bootstrap.kafka-mirror-src.svc:9093
tls:
trustedCertificates:
- certificate: ca.crt
secretName: mm-src-cluster-cluster-ca-cert
- alias: "mm-backup-cluster"
authentication:
certificateAndKey:
certificate: user.crt
key: user.key
secretName: mm-producer-user
type: tls
bootstrapServers: mm-backup-cluster-kafka-bootstrap.kafka-mirror.svc:9093
config:
config.storage.replication.factor: 1
offset.storage.replication.factor: 1
status.storage.replication.factor: 1
offset.storage.topic: mm-backup-cluster-offsets
config.storage.topic: mm-backup-cluster-configs
status.storage.topic: mm-backup-cluster-status
tls:
trustedCertificates:
- certificate: ca.crt
secretName: mm-backup-cluster-cluster-ca-cert
mirrors:
- sourceCluster: "mm-src-cluster"
targetCluster: "mm-backup-cluster"
sourceConnector:
config:
replication.factor: 1
offset-syncs.topic.replication.factor: 1
sync.topic.acls.enabled: "false"
offset.storage.topic: mirrormaker2-cluster-offsets
config.storage.topic: mirrormaker2-cluster-configs
status.storage.topic: mirrormaker2-cluster-status
heartbeatConnector:
config:
heartbeats.topic.replication.factor: 1
checkpointConnector:
config:
checkpoints.topic.replication.factor: 1
topicsPattern: ".*"
groupsPattern: ".*"
Help on this is much appreciated.
Wishes,
Viswanadh.
This message (including any attachments) contains confidential information
intended for a specific individual and purpose, and is protected by law. If you
are not the intended recipient, you should delete this message and any
disclosure, copying, or distribution of this message, or the taking of any
action based on it, by you is strictly prohibited.
Deloitte refers to a Deloitte member firm, one of its related entities, or
Deloitte Touche Tohmatsu Limited ("DTTL"). Each Deloitte member firm is a
separate legal entity and a member of DTTL. DTTL does not provide services to
clients. Please see www.deloitte.com/about to learn more.
v.E.1
