我在librd kafka consumer上有一个瘦 Package 器,它有一个单独的poll线程来调用consumer方法。当应用程序执行分叉时,轮询线程将暂停,一旦分叉完成,轮询线程将恢复。当线程恢复时,我看到poll线程内部出现故障-“local:broker transport failure”。我也找不到复制机。
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!