как настроить Kafka- Python client.dns.lookup = "use_all_dns_ips"

Question

Я хочу настроить моего python производителя / потребителя с client.dns.lookup = "use_all_dns_ips", но ни один из python клиентов kafka, таких как kafka- python (2.0.1) и confluent-kafka (1.3. 0) поддержите это

Вот так у меня есть генерирующий объект производителя

producer = KafkaProducer({
'bootstrap_servers': [localhost:1234,localhost:1235,localhost:1236],
"client.dns.lookup" = "use_all_dns_ips"
})

Я получил ниже сообщение об ошибке

cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "client.dns.lookup""}

Есть ли способ использовать этот конфиг?

Answer 1

Kafka- python (2.0.1) и confluent-kafka (1.3.0) также не поддерживают параметр client.dns.lookup . Пожалуйста, обратитесь к списку ниже.

Список опций поддержки Kafka- python (KafkaProducer)

url: https://kafka-python.readthedocs.io/en/master/apidoc/KafkaProducer.html

• bootstrap_servers
• client_id (str)
• key_serializer (вызываемый)
• value_serializer (вызываемый)
• сжатый_тип (str)
• повторов (int)
• batch_size (int)
• linger_ms (int)
• разделитель (вызываемый)
• buffer_memory (int)
• connections_max_idle_ms
• max_block_ms (int)
• max_request_size (int)
• metadata_max_age_ms (int)
• retry_backoff_ms (int)
• request_timeout_ms (int)
• receive_buffer_bytes (int)
• send_buffer_bytes (int)
• socket_options (список)
• reconnect_backoff_ms (int)
• reconnect_backoff_max_ms (int)
• max_in_flight_requests_per_connection (int)
• security_protocol (str)
• с sl_context (ssl.SSLContext)
• ssl_check_hostname (bool)
• ssl_cafile (str)
• ssl_certfile (str)
• ssl_keyfile (str) 1070 * ssl_password (str)
• ssl_crlfile (str)
• ssl_ciphers (str)
• api_version (кортеж)
• api_version_auto_timeout_ms (int)
• metric_reporters (список)
• metrics_num_samples (int)
• metrics_sample_window_ms (int)
• селектор (selectors.BaseSelector)
• sasl_mechanism (str)
• sasl_plain_username (str)
• sasl_plain_password (str)
• sasl_kerberos_service_name (str)
• sasl_kerberos_domain_name (str)

Список опций поддержки Confluent-kafka (KafkaProducer)

url: https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md

• транзакционный. id
• транзакция.timeout.ms
• enable.idempotence
• queue.buffering.max.messages
• queue.buffering.max.kbytes
• queue.buffering.max.ms
• linger.ms
• message.send.max.retries
• повторы
• retry.backoff.ms
• queue.buffering.backpressure.threshold
• сжатие.код c
• сжатие.тип
• batch.num.messages
• delivery.report.only.error
• dr_cb ​​
• dr_msg_cb
• request.required.acks
• acks
• request.timeout.ms
• message.timeout.ms
• delivery.timeout.ms
• queuing.strategy
• yield.offset.report
• разделитель
• partitioner_cb
• msg_order_cmp
• сжатие.код c
• сжатие.тип
• сжатие.уровень
• builtin.features
• client.id
• metadata.broker.list
• bootstrap .servers * 1 180 *
• message.max.bytes
• message.copy.max. байты
• receive.message.max.bytes
• max.in.flight.requests.per.connection
• max.in.flight
• метаданные. request.timeout.ms
• topi c .metadata.refre sh .interval.ms
• metadata.max.age.ms
• topi c. metadata.refre sh .fast.interval.ms
• topi c .metadata.refre sh .fast.cnt
• topi c .metadata.refre sh .sparse
• topi c .blacklist
• отладка
• socket.timeout.ms
• socket.blocking.max.ms
• socket.send.buffer.bytes
• socket.receive.buffer.bytes
• socket.keepalive.enable
• socket.nagle.disable
• сокет .max.fails
• broker.address.ttl
• broker.address.family
• reconnect.backoff.jitter.ms
• reconnect.backoff.ms
• reconnect.backoff.max.ms
• statistics.interval.ms
• enabled_events
• error_cb
• throttle_cb
• stats_cb
• log_cb
• log_level
• log.queue
• log.thread.name
• включить .random.seed
• log.connection.close
• background_event_cb
• socket_cb
• connect_cb
• closesocket_cb
• open_cb
• непрозрачный
• default_topic_conf
• internal.termination.signal
• api.version.request
• api.version.request.timeout. ms
• api.version.fallback.ms
• broker.version.fallback
• security.protocol
• ssl.cipher.suites
• ssl.curves.list
• ssl.sigalgs.list
• ssl.key.location
• ssl.key.password
• ssl.key.pem
• ssl_key
• ssl.certificate.location
• ssl.certificate.pem
• ssl_certificate
• ssl.ca.location
• ssl_ca
• ssl.crl.location
• ssl.keystore .location
• ssl.keystore.password
• enable.ssl.certificate.verification
• ssl.endpoint.identification.algorithm
• ssl.certificate.verify_cb
• sasl.mechanisms
• sasl.mechanism
• sasl.kerberos.service.name
• sasl.kerberos.principal
• sasl. kerberos.kinit.cmd
• sasl.kerberos.keytab
• sasl.kerberos.min.time.before.relogin
• sasl. имя пользователя
• sasl.password
• sasl.oauthbearer.config
• enable.sasl.oauthbearer.unsecure.jwt
• oauthbearer_token_refresh_cb
• плагин .library.paths
• перехватчики
• client.rack
• непрозрачный