Skip to content

Commit

Permalink
[Doc][Improve] Add Support Kerberos Auth For Kafka Connector apache#6653
Browse files Browse the repository at this point in the history
 (apache#6660)



---------

Co-authored-by: tianxy105 <lucas123.COM>
  • Loading branch information
gitfortian authored and chaorongzhi committed Aug 21, 2024
1 parent 893c90b commit 309a9d8
Show file tree
Hide file tree
Showing 2 changed files with 43 additions and 0 deletions.
22 changes: 22 additions & 0 deletions docs/en/connector-v2/sink/Kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -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=\"user@xxx.com\";"
}
}
}
```

21 changes: 21 additions & 0 deletions docs/en/connector-v2/source/kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -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=\"user@xxx.com\";"
}
}
}
```

0 comments on commit 309a9d8

Please sign in to comment.