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]\";"
+ }
+ }
+}
+```
+