Skip to content

Support SSL transports in KafkaFixture #2806

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
dpkp merged 12 commits into from
Apr 2, 2026
Merged

Support SSL transports in KafkaFixture #2806

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
939a475
SSL fixtures (4.0.0 only)
dpkp Apr 2, 2026
dbe07f0
Fix env_kafka_version() when KAFKA_VERSION=trunk
dpkp Apr 2, 2026
102aac7
sasl_enabled via transport; sasl_enabled requires sasl_mechanism
dpkp Apr 2, 2026
a501b77
No ssl support prior to 0.9
dpkp Apr 2, 2026
a88c5ea
Support 1.0 / 4.0 defaults; add {ssl_config}
dpkp Apr 2, 2026
225b0e9
use defaults for zookeeper.properties, log4j.properties, kafka_server…
dpkp Apr 2, 2026
2b914b4
pylint
dpkp Apr 2, 2026
063fdeb
fixup broker version check; skip ssl tests for < 0.9
dpkp Apr 2, 2026
2fefd81
Fixup sasl_enabled; avoid crash on close() when asserts fail
dpkp Apr 2, 2026
ef33a6f
acl_config
dpkp Apr 2, 2026
6a562db
Use simple metadata check for ssl integration (supports 0.9)
dpkp Apr 2, 2026
efe6eaf
Address tls warning; requires py3.7+
dpkp Apr 2, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 1 addition & 6 deletions servers/0.10.0.0/resources/kafka.properties
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,7 @@ listeners={transport}://{host}:{port}
security.inter.broker.protocol={transport}

{sasl_config}

ssl.keystore.location={ssl_dir}/kafka.server.keystore.jks
ssl.keystore.password=foobar
ssl.key.password=foobar
ssl.truststore.location={ssl_dir}/kafka.server.truststore.jks
ssl.truststore.password=foobar
{ssl_config}

# The port the socket server listens on
#port=9092
Expand Down
4 changes: 0 additions & 4 deletions servers/0.10.0.0/resources/kafka_server_jaas.conf
View file
Open in desktop

This file was deleted.

25 changes: 0 additions & 25 deletions servers/0.10.0.0/resources/log4j.properties
View file
Open in desktop

This file was deleted.

21 changes: 0 additions & 21 deletions servers/0.10.0.0/resources/zookeeper.properties
View file
Open in desktop

This file was deleted.

7 changes: 1 addition & 6 deletions servers/0.10.0.1/resources/kafka.properties
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,7 @@ listeners={transport}://{host}:{port}
security.inter.broker.protocol={transport}

{sasl_config}

ssl.keystore.location={ssl_dir}/kafka.server.keystore.jks
ssl.keystore.password=foobar
ssl.key.password=foobar
ssl.truststore.location={ssl_dir}/kafka.server.truststore.jks
ssl.truststore.password=foobar
{ssl_config}

# The port the socket server listens on
#port=9092
Expand Down
4 changes: 0 additions & 4 deletions servers/0.10.0.1/resources/kafka_server_jaas.conf
View file
Open in desktop

This file was deleted.

25 changes: 0 additions & 25 deletions servers/0.10.0.1/resources/log4j.properties
View file
Open in desktop

This file was deleted.

21 changes: 0 additions & 21 deletions servers/0.10.0.1/resources/zookeeper.properties
View file
Open in desktop

This file was deleted.

7 changes: 1 addition & 6 deletions servers/0.10.1.1/resources/kafka.properties
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,7 @@ listeners={transport}://{host}:{port}
security.inter.broker.protocol={transport}

{sasl_config}

ssl.keystore.location={ssl_dir}/kafka.server.keystore.jks
ssl.keystore.password=foobar
ssl.key.password=foobar
ssl.truststore.location={ssl_dir}/kafka.server.truststore.jks
ssl.truststore.password=foobar
{ssl_config}

# The port the socket server listens on
#port=9092
Expand Down
4 changes: 0 additions & 4 deletions servers/0.10.1.1/resources/kafka_server_jaas.conf
View file
Open in desktop

This file was deleted.

25 changes: 0 additions & 25 deletions servers/0.10.1.1/resources/log4j.properties
View file
Open in desktop

This file was deleted.

21 changes: 0 additions & 21 deletions servers/0.10.1.1/resources/zookeeper.properties
View file
Open in desktop

This file was deleted.

7 changes: 1 addition & 6 deletions servers/0.10.2.1/resources/kafka.properties
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,7 @@ listeners={transport}://{host}:{port}
security.inter.broker.protocol={transport}

{sasl_config}

ssl.keystore.location={ssl_dir}/kafka.server.keystore.jks
ssl.keystore.password=foobar
ssl.key.password=foobar
ssl.truststore.location={ssl_dir}/kafka.server.truststore.jks
ssl.truststore.password=foobar
{ssl_config}

# The port the socket server listens on
#port=9092
Expand Down
4 changes: 0 additions & 4 deletions servers/0.10.2.1/resources/kafka_server_jaas.conf
View file
Open in desktop

This file was deleted.

25 changes: 0 additions & 25 deletions servers/0.10.2.1/resources/log4j.properties
View file
Open in desktop

This file was deleted.

21 changes: 0 additions & 21 deletions servers/0.10.2.1/resources/zookeeper.properties
View file
Open in desktop

This file was deleted.

7 changes: 1 addition & 6 deletions servers/0.10.2.2/resources/kafka.properties
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,7 @@ listeners={transport}://{host}:{port}
security.inter.broker.protocol={transport}

{sasl_config}

ssl.keystore.location={ssl_dir}/kafka.server.keystore.jks
ssl.keystore.password=foobar
ssl.key.password=foobar
ssl.truststore.location={ssl_dir}/kafka.server.truststore.jks
ssl.truststore.password=foobar
{ssl_config}

# The port the socket server listens on
#port=9092
Expand Down
4 changes: 0 additions & 4 deletions servers/0.10.2.2/resources/kafka_server_jaas.conf
View file
Open in desktop

This file was deleted.

25 changes: 0 additions & 25 deletions servers/0.10.2.2/resources/log4j.properties
View file
Open in desktop

This file was deleted.

21 changes: 0 additions & 21 deletions servers/0.10.2.2/resources/zookeeper.properties
View file
Open in desktop

This file was deleted.

4 changes: 0 additions & 4 deletions servers/0.11.0.0/resources/kafka_server_jaas.conf
View file
Open in desktop

This file was deleted.

25 changes: 0 additions & 25 deletions servers/0.11.0.0/resources/log4j.properties
View file
Open in desktop

This file was deleted.

21 changes: 0 additions & 21 deletions servers/0.11.0.0/resources/zookeeper.properties
View file
Open in desktop

This file was deleted.

Loading
Loading