我想用client.dns.lookup=“use \u all \u dns \u ips”配置我的python生产者/消费者，但是像kafka python（2.0.1）和confluent kafka（1.3.0）这样的python kafka客户端都不支持这一点
我就是这样生成producer对象的
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""}有没有办法使用这个配置？
1条答案
按热度按时间wljmcqd81#
kafka python（2.0.1）和confluent kafka（1.3.0）都不支持client.dns.lookup选项。请参考下面的列表。
kafka python（kafkaproducer）支持选项列表
网址：https://kafka-python.readthedocs.io/en/master/apidoc/kafkaproducer.html
引导服务器
客户id（str）
密钥序列化程序（可调用）
值序列化程序（可调用）
压缩型（str）
重试次数（int）
批量大小（int）
逗留时间（内景）
分区器（可调用）
缓冲区内存（int）
连接\u最大\u空闲\u毫秒
最大块（int）
最大请求大小（int）
元数据\u max\u age \u ms（int）
重试\u退避\u ms（int）
请求超时\u ms（int）
接收缓冲区字节（int）
发送缓冲区字节（int）
插座选项（列表）
重新连接\u后退\u ms（int）
重新连接\u后退\u最大\u毫秒（int）
每个连接的最大航班请求数（int）
安全协议（str）
ssl\u上下文（ssl.sslcontext）
ssl\检查\主机名（bool）
ssl文件（str）
ssl\证书文件（str）
ssl密钥文件（str）
ssl\ U密码（str）
ssl\文件（str）
ssl密码（str）
api\版本（元组）
api \版本\自动\超时\毫秒（int）
公制单位（列表）
度量\u num \u样本（int）
度量\u示例\u窗口\u ms（int）
选择器（selectors.baseselector）
sasl\ U机构（str）
普通用户名（str）
普通密码（str）
sasl\ kerberos\服务\名称（str）
sasl\u kerberos\u域名（str）
sasl\u oauth\u token\u提供程序（abstracttokenprovider）
合流kafka（kafkaproducer）支持选项列表
网址：https://github.com/edenhill/librdkafka/blob/master/configuration.md
事务id
事务.timeout.ms
使能.幂等
无缝隙保证
queue.buffering.max.消息
queue.buffering.max.kbytes最大值
queue.buffering.max.ms最大值
玲儿女士
message.send.max.重试次数
重试
重试.backoff.ms
队列.缓冲.背压.阈值
压缩.codec
压缩类型
batch.num.消息
delivery.report.only.error错误
卡布医生
医生\u msg \u cb
请求.required.acks
阿克斯
请求.timeout.ms
message.timeout.ms
delivery.timeout.ms
排队策略
生成.offset.report
分割器
分区器\u cb
消息\u订单\u cmp
压缩.codec
压缩类型
压缩级
内置功能
客户端id
元数据.broker.list
bootstrap.servers服务器
message.max.字节
message.copy.max.字节
receive.message.max.字节
每个连接的最大飞行请求数
最大飞行中
metadata.request.timeout.ms
topic.metadata.refresh.interval.ms
metadata.max.age.ms
topic.metadata.refresh.fast.interval.ms
主题.metadata.refresh.fast.cnt
topic.metadata.refresh.稀疏
topic.blacklist黑名单
调试
socket.timeout.ms
插座阻塞最大ms
socket.send.buffer.bytes
socket.receive.buffer.bytes
socket.keepalive.enable启用
套接字.nagle.disable
socket.max.失败
broker.address.ttl代理地址
broker.address.family公司
重新连接.backoff.jitter.ms
重新连接.backoff.ms
重新连接.backoff.max.ms
统计.interval.ms
启用的\u事件
错误\u cb
节气门开度
状态\u cb
日志\u cb
日志级别
日志队列
log.thread.name文件
启用.random.seed
日志连接关闭
背景事件
插座\断路器
连接\u cb
闭合插座
打开\u cb
不透明的
默认主题配置
内部终端信号
api.version.request请求
api.version.request.timeout.ms
api.version.fallback.ms
broker.version.fallback
安全协议
ssl.cipher.suites包
ssl.curves.list文件
ssl.sigalgs.list文件
ssl.key.location
ssl.key.password密码
ssl.key.pem
ssl\U密钥
ssl.certificate.location
ssl.certificate.pem证书
ssl\U证书
ssl.ca.位置
ssl\卡
ssl.crl.location位置
ssl.keystore.location
ssl.keystore.password密码
启用.ssl.certificate.verification
ssl.endpoint.identification.algorithm算法
ssl.certificate.verify\u cb证书
sasl机构
sasl机构
sasl.kerberos.service.name
sasl.kerberos.principal文件
sasl.kerberos.kinit.cmd
sasl.kerberos.keytab
sasl.kerberos.min.time.before.relogin
sasl.用户名
sasl.密码
sasl.oauthbearer.config文件
enable.sasl.oauthbearer.unsecure.jwt
oauthbearer\u token\u refresh\u cb
plugin.library.paths路径
拦截器
客户端.rack
不透明的