Nathan

KafkaSourceProvider extends DataSourceRegister with StreamSourceProvider with StreamSinkProvider with RelationProvider with CreatableRelationProvider with SimpleTableProvider 这其中的RelationProvider，CreatableRelationProvider，SimpleTableProvider几个接口的用处一直没搞懂。 大佬有没有写过这方面的源码解析呀？求学习

这样做的话，ip很快会被那些网站屏蔽的

in the docker : ``` root@ab0b81f8bdd5:/tmp# socat -d -d - UNIX-LISTEN:/tmp/runner.sock 2022/07/03 14:50:22 socat[128] N reading from and writing to stdio 2022/07/03 14:50:22 socat[128] E "/tmp/runner.sock" exists 2022/07/03 14:50:22 socat[128]...

@ericluoliu Sorry, but I'm not sure I understand what you mean by"As you are on M1 mac, you may need to create a CentOS VM." I have to develop java-plugin...

+1

Hi @zhuizhuhaomeng Could you mind rewiew this PR :https://github.com/openresty/lua-resty-websocket/pull/80

@Prakhar0123 This may be due to incorrect 'sock:sslhandshake' usage

Sure.I have submit the PR.

One more thing, 在分布式环境中,是每一台机器得出报告然后整合吗

Hi yuz10. 感谢回复 a. 是的 b. nginx如何识别tcp连接的失效 , 并主动断开连接呢 ? 是使用 TCP默认keepalive机制吗? 那识别的间隔会太长了(默认2小时),在时间间隔内是否会返回 不可用的连接 , 写数据的时候才报错 c. " 会依赖包的顺序，接受的时候直接把opaque不同的包丢弃了 " 这句不太理解 , 记得TCP可以保证 数据的有序性