Hi,
其实报错信息已经说清楚了你用的方式的问题了，这个host方法是需要传入三个参数的，第一个是你的hostname，第二个是你的port，第三个是你使用的protocol。
可以采用下面这种方式试一下
.host("es9223.db.58dns.org", 9223, "http")
Best,
Xingbo
guaishushu1...@163.com <guaishushu1...@163.com> 于2020年8月17日周一 下午5:12写道：
> PyFlink 从kafka写入ES 抛这个异常，但是host是正确的有哪位知道吗
> File "main-0-8.py", line 74, in <module>
> .host("http://es9223.db.58dns.org:9223";)
> TypeError: host() missing 2 required positional arguments: 'port' and
> 'protocol'
>
>
>
>
> guaishushu1...@163.com
>
