This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new e5df7f00f8 [Doc][Improve] Add Support Kerberos Auth For Kafka 
Connector #6653 (#6660)
e5df7f00f8 is described below

commit e5df7f00f8e21edcc5168c4f3dedfc7f85a4a150
Author: gitfortian <[email protected]>
AuthorDate: Mon Apr 8 14:56:51 2024 +0800

    [Doc][Improve] Add Support Kerberos Auth For Kafka Connector #6653 (#6660)
    
    
    
    ---------
    
    Co-authored-by: tianxy105 <lucas123.COM>
---
 docs/en/connector-v2/sink/Kafka.md   | 22 ++++++++++++++++++++++
 docs/en/connector-v2/source/kafka.md | 21 +++++++++++++++++++++
 2 files changed, 43 insertions(+)

diff --git a/docs/en/connector-v2/sink/Kafka.md 
b/docs/en/connector-v2/sink/Kafka.md
index 2919eab988..4a98c7d6a7 100644
--- a/docs/en/connector-v2/sink/Kafka.md
+++ b/docs/en/connector-v2/sink/Kafka.md
@@ -191,3 +191,25 @@ sink {
 }
 ```
 
+### Kerberos Authentication Example
+
+Sink Config
+
+```
+sink {
+    Kafka {
+        topic = "seatunnel"
+        bootstrap.servers = "127.0.0.1:9092"
+        format = json
+        semantics = EXACTLY_ONCE
+        kafka.config = {
+            security.protocol=SASL_PLAINTEXT
+            sasl.kerberos.service.name=kafka
+            sasl.mechanism=GSSAPI
+            java.security.krb5.conf="/etc/krb5.conf"
+            sasl.jaas.config="com.sun.security.auth.module.Krb5LoginModule 
required \n        useKeyTab=true \n        storeKey=true  \n        
keyTab=\"/path/to/xxx.keytab\" \n        principal=\"[email protected]\";"
+        }
+    }
+}
+```
+
diff --git a/docs/en/connector-v2/source/kafka.md 
b/docs/en/connector-v2/source/kafka.md
index 982c62e5fb..79bfc49b40 100644
--- a/docs/en/connector-v2/source/kafka.md
+++ b/docs/en/connector-v2/source/kafka.md
@@ -159,3 +159,24 @@ source {
 }
 ```
 
+### Kerberos Authentication Example
+
+Source Config
+
+```
+source {
+    Kafka {
+        topic = "seatunnel"
+        bootstrap.servers = "127.0.0.1:9092"
+        consumer.group = "seatunnel_group"
+        kafka.config = {
+            security.protocol=SASL_PLAINTEXT
+            sasl.kerberos.service.name=kafka
+            sasl.mechanism=GSSAPI
+            java.security.krb5.conf="/etc/krb5.conf"
+            sasl.jaas.config="com.sun.security.auth.module.Krb5LoginModule 
required \n        useKeyTab=true \n        storeKey=true  \n        
keyTab=\"/path/to/xxx.keytab\" \n        principal=\"[email protected]\";"
+        }
+    }
+}
+```
+

Reply via email to