Skip to main content

Configuration

Connection Setup​

import fluss

config = fluss.Config({"bootstrap.servers": "127.0.0.1:9123"})
conn = await fluss.FlussConnection.create(config)

The connection also supports context managers:

with await fluss.FlussConnection.create(config) as conn:
    ...

Connection Configurations​

Configuration options can be set either via dict keys in the Config() constructor, or via Python property setters.

See the Config section in the API Reference for the full list of options, their config keys, and descriptions.

SASL Authentication​

To connect to a Fluss cluster with SASL/PLAIN authentication enabled:

config = fluss.Config({
    "bootstrap.servers": "127.0.0.1:9123",
    "security.protocol": "sasl",
    "security.sasl.mechanism": "PLAIN",
    "security.sasl.username": "admin",
    "security.sasl.password": "admin-secret",
})
conn = await fluss.FlussConnection.create(config)

Connection Lifecycle​

Remember to close the connection when done:

conn.close()