Configuration module for KafkaEx.

Configuration Options

Add to your config/config.exs:

config :kafka_ex,
  # Required: List of broker addresses
  brokers: [{"localhost", 9092}],

  # Connection settings
  use_ssl: false,
  ssl_options: [],
  # sasl: %{mechanism: :plain, username: "user", password: "pass"},

  # Client settings
  client_id: "kafka_ex",
  sync_timeout: 3000,

  # Consumer group (used for offset storage)
  default_consumer_group: "kafka_ex",

  # Partitioner for produce requests (when partition is nil)
  partitioner: KafkaEx.Producer.Partitioner.Default,

  # Application settings
  disable_default_worker: false,
  max_restarts: 10,
  max_seconds: 60,

  # GenConsumer settings
  commit_interval: 5_000,
  commit_threshold: 100,
  auto_offset_reset: :none

Broker Configuration

Brokers can be configured in several formats:

# List of tuples
brokers: [{"host1", 9092}, {"host2", 9092}]

# CSV string
brokers: "host1:9092,host2:9092"

# Dynamic (MFA or function)
brokers: {MyModule, :get_brokers, []}
brokers: fn -> [...] end

SASL Authentication

config :kafka_ex,
  use_ssl: true,  # Required for SASL
  sasl: %{
    mechanism: :scram,  # :plain or :scram
    username: System.get_env("KAFKA_USER"),
    password: System.get_env("KAFKA_PASS"),
    mechanism_opts: %{algorithm: :sha256}  # For SCRAM
  }