ConfluentConfig = TypedDict(
"ConfluentConfig",
{
"compression.codec": Union[CompressionCodec, str],
"compression.type": Union[CompressionType, str],
"client.dns.lookup": Union[ClientDNSLookup, str],
"offset.store.method": Union[
OffsetStoreMethod, str
],
"isolation.level": Union[IsolationLevel, str],
"sasl.oauthbearer.method": Union[
SASLOAUTHBearerMethod, str
],
"security.protocol": Union[SecurityProtocol, str],
"broker.address.family": Union[
BrokerAddressFamily, str
],
"builtin.features": Union[BuiltinFeatures, str],
"debug": Union[Debug, str],
"group.protocol": Union[GroupProtocol, str],
"client.id": str,
"metadata.broker.list": str,
"bootstrap.servers": str,
"message.max.bytes": int,
"message.copy.max.bytes": int,
"receive.message.max.bytes": int,
"max.in.flight.requests.per.connection": int,
"max.in.flight": int,
"topic.metadata.refresh.interval.ms": int,
"metadata.max.age.ms": int,
"topic.metadata.refresh.fast.interval.ms": int,
"topic.metadata.refresh.fast.cnt": int,
"topic.metadata.refresh.sparse": bool,
"topic.metadata.propagation.max.ms": int,
"topic.blacklist": str,
"socket.timeout.ms": int,
"socket.blocking.max.ms": int,
"socket.send.buffer.bytes": int,
"socket.receive.buffer.bytes": int,
"socket.keepalive.enable": bool,
"socket.nagle.disable": bool,
"socket.max.fails": int,
"broker.address.ttl": int,
"socket.connection.setup.timeout.ms": int,
"connections.max.idle.ms": int,
"reconnect.backoff.jitter.ms": int,
"reconnect.backoff.ms": int,
"reconnect.backoff.max.ms": int,
"statistics.interval.ms": int,
"enabled_events": int,
"error_cb": Callable[..., Any],
"throttle_cb": Callable[..., Any],
"stats_cb": Callable[..., Any],
"log_cb": Callable[..., Any],
"log_level": int,
"log.queue": bool,
"log.thread.name": bool,
"enable.random.seed": bool,
"log.connection.close": bool,
"background_event_cb": Callable[..., Any],
"socket_cb": Callable[..., Any],
"connect_cb": Callable[..., Any],
"closesocket_cb": Callable[..., Any],
"open_cb": Callable[..., Any],
"resolve_cb": Callable[..., Any],
"opaque": str,
"default_topic_conf": str,
"internal.termination.signal": int,
"api.version.request": bool,
"api.version.request.timeout.ms": int,
"api.version.fallback.ms": int,
"broker.version.fallback": str,
"allow.auto.create.topics": bool,
"ssl.cipher.suites": str,
"ssl.curves.list": str,
"ssl.sigalgs.list": str,
"ssl.key.location": str,
"ssl.key.password": str,
"ssl.key.pem": str,
"ssl_key": str,
"ssl.certificate.location": str,
"ssl.certificate.pem": str,
"ssl_certificate": str,
"ssl.ca.location": str,
"ssl.ca.pem": str,
"ssl_ca": str,
"ssl.ca.certificate.stores": str,
"ssl.crl.location": str,
"ssl.keystore.location": str,
"ssl.keystore.password": str,
"ssl.providers": str,
"ssl.engine.location": str,
"ssl.engine.id": str,
"ssl_engine_callback_data": str,
"enable.ssl.certificate.verification": bool,
"ssl.endpoint.identification.algorithm": str,
"ssl.certificate.verify_cb": Callable[..., Any],
"sasl.mechanisms": str,
"sasl.mechanism": str,
"sasl.kerberos.service.name": str,
"sasl.kerberos.principal": str,
"sasl.kerberos.kinit.cmd": str,
"sasl.kerberos.keytab": str,
"sasl.kerberos.min.time.before.relogin": int,
"sasl.username": str,
"sasl.password": str,
"sasl.oauthbearer.config": str,
"enable.sasl.oauthbearer.unsecure.jwt": bool,
"oauthbearer_token_refresh_cb": Callable[..., Any],
"sasl.oauthbearer.client.id": str,
"sasl.oauthbearer.client.secret": str,
"sasl.oauthbearer.scope": str,
"sasl.oauthbearer.extensions": str,
"sasl.oauthbearer.token.endpoint.url": str,
"plugin.library.paths": str,
"interceptors": str,
"group.id": str,
"group.instance.id": str,
"partition.assignment.strategy": str,
"session.timeout.ms": str,
"heartbeat.interval.ms": str,
"group.protocol.type": str,
"group.remote.assignor": str,
"coordinator.query.interval.ms": int,
"max.poll.interval.ms": int,
"enable.auto.commit": bool,
"auto.commit.interval.ms": int,
"enable.auto.offset.store": bool,
"queued.min.messages": int,
"queued.max.messages.kbytes": int,
"fetch.wait.max.ms": int,
"fetch.queue.backoff.ms": int,
"fetch.message.max.bytes": int,
"max.partition.fetch.bytes": int,
"fetch.max.bytes": int,
"fetch.min.bytes": int,
"fetch.error.backoff.ms": int,
"consume_cb": Callable[..., Any],
"rebalance_cb": Callable[..., Any],
"offset_commit_cb": Callable[..., Any],
"enable.partition.eof": bool,
"check.crcs": bool,
"client.rack": str,
"transactional.id": str,
"transaction.timeout.ms": int,
"enable.idempotence": bool,
"enable.gapless.guarantee": bool,
"queue.buffering.max.messages": int,
"queue.buffering.max.kbytes": int,
"queue.buffering.max.ms": float,
"linger.ms": float,
"message.send.max.retries": int,
"retries": int,
"retry.backoff.ms": int,
"retry.backoff.max.ms": int,
"queue.buffering.backpressure.threshold": int,
"batch.num.messages": int,
"batch.size": int,
"delivery.report.only.error": bool,
"dr_cb": Callable[..., Any],
"dr_msg_cb": Callable[..., Any],
"sticky.partitioning.linger.ms": int,
},
total=False,
)