OptionalclientClient identifier reported to the broker.
OptionalbrokersSeed broker list, e.g. ['localhost:9092'].
OptionalsslEnable TLS, or pass a kafkajs TLS options object.
OptionalsaslSASL authentication configuration.
OptionalclientA pre-built kafkajs Kafka instance. When provided, connect() uses it
directly and does not require('kafkajs').
Connection options for
RedpandaStore.Mirrors kafkajs's
Kafkaconstructor options.brokersis the list ofhost:portseed brokers (Redpanda broker addresses). A pre-built kafkajsKafkainstance can be injected viaclient, in which caseconnect()uses it directly and skips loading the driver (this is how tests inject a mock).