THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Table of Contents |
---|
Status
Current state: Under DiscussionAcceptted
Discussion thread: here
JIRA: here
...
property | default value | description |
<cluster>. | org.apache.kafka.clients.admin.ForwardingAdminClient | The fully qualified name of class that extend ForwardingAdminClient. The class must have a contractor that accept configuration (Map<String, Object> config) to configure needed clients. |
In addition, forwarding admin class will be re-using the following existing configs:
property | description |
<cluster>.cluster.admin.* | overrides for the cluster forwarding admin config |
Example Configuration
Code Block |
---|
clusters = primary, backup primary.bootstrap.servers = A_localhost:9092 backup.bootstrap.servers = B_localhost:9092 // Common config for KafkaAdminClient in any ForwardingAdminClient admin.security.protocol = SASL_SSL admin.security.protocol=SASL_SSL admin.sasl.mechanism=PLAIN // Configure Primary org.apache.kafka.clients.admin.ForwardingAdminClient primary.admin.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="USERNAME1" password="PASSWORD1"; // Configure Target KafkaAdminClient in custom.package.admin.TargetForwardingAdminClient backup.admin.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="USERNAME2" password="PASSWORD2"; // Configure Target custom ResourceManagmentRESTClient in custom.mypackage.admin.TargetForwardingAdminClient backup.admin.resource.management.url = https://kafka.resource.manager.com backup.admin.resource.management.keystore.path = /path/keystore backup.admin.resource.management.truststore.path = /path/truststore/ca.pem |
...