我正在使用vert.x读取文件并进行转换，然后推送到kafka。
我正在使用2个顶点，而不使用任何工作线程（我不想更改文件中日志的顺序）。
Verticle 1 : Read the file and filter
Verticle 2 : Publish to kafka
每个文件包含大约120000行
但是，我观察到一段时间后，我不再观察第1层的原木。
我怀疑事件总线已满，因此消费者仍在使用，但是生产者线程正在等待事件总线变空。
所以我的问题是
1.事件总线的默认大小是多少？在文档中说
DEFAULT_ACCEPT_BACKLOG
The default accept backlog = 1024
2.如何确认怀疑发布者线程被阻止？
最佳答案
VertX在内部将Netty的SingleThreadEventLoop用于其事件总线maximum pending tasks allowed is Integer.MAX_VALUE，这可能是20亿条消息。
您可能必须尝试VertxOptions.setWarningExceptionTime(long warningExceptionTime)将该值设置为低于默认值（5秒），以查看是否有任何有关阻塞线程的警告。