Skip to content

Commit e5df7f0

Browse files
authored
[Doc][Improve] Add Support Kerberos Auth For Kafka Connector #6653 (#6660)
--------- Co-authored-by: tianxy105 <lucas123.COM>
1 parent 20b62f3 commit e5df7f0

File tree

2 files changed

+43
-0
lines changed

2 files changed

+43
-0
lines changed

Diff for: docs/en/connector-v2/sink/Kafka.md

+22
Original file line numberDiff line numberDiff line change
@@ -191,3 +191,25 @@ sink {
191191
}
192192
```
193193

194+
### Kerberos Authentication Example
195+
196+
Sink Config
197+
198+
```
199+
sink {
200+
Kafka {
201+
topic = "seatunnel"
202+
bootstrap.servers = "127.0.0.1:9092"
203+
format = json
204+
semantics = EXACTLY_ONCE
205+
kafka.config = {
206+
security.protocol=SASL_PLAINTEXT
207+
sasl.kerberos.service.name=kafka
208+
sasl.mechanism=GSSAPI
209+
java.security.krb5.conf="/etc/krb5.conf"
210+
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]\";"
211+
}
212+
}
213+
}
214+
```
215+

Diff for: docs/en/connector-v2/source/kafka.md

+21
Original file line numberDiff line numberDiff line change
@@ -159,3 +159,24 @@ source {
159159
}
160160
```
161161

162+
### Kerberos Authentication Example
163+
164+
Source Config
165+
166+
```
167+
source {
168+
Kafka {
169+
topic = "seatunnel"
170+
bootstrap.servers = "127.0.0.1:9092"
171+
consumer.group = "seatunnel_group"
172+
kafka.config = {
173+
security.protocol=SASL_PLAINTEXT
174+
sasl.kerberos.service.name=kafka
175+
sasl.mechanism=GSSAPI
176+
java.security.krb5.conf="/etc/krb5.conf"
177+
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]\";"
178+
}
179+
}
180+
}
181+
```
182+

0 commit comments

Comments
 (0)