kafka接口项目 consumer堆外内存管理
kafka
之前有过一次提问，见：https://www.orchome.com/10576 （kafka频繁报 OutOfMemoryError: Direct buffer memory 异常）
后来发现可能不是写入端的问题，而是consumer消费造成的问题
[http-nio[http-nio-10020-exec-404] ERROR] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer memory] with root cause
java.lang.OutOfMemoryError: Direct buffer memory
at java] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with] ERROR o.a] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] ERROR o.a.c.c.C.[.[localhost] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer memory] with] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path] ERROR o] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() forERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: DirectR o] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer memory] with root cause
java] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer memory] with root] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServletERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with pathR o] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatchERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer memory] with] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() forERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] ERROR] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context] ERRORR o.a] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer memory] with] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer memory] with] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer memory] with root cause
java] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servletRROR o] ERROR o.a.c.c.C.[.[localhost].[/].[dispatcherServlet] | Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Handler dispatch failed; nested exception is java.lang.OutOfMemoryError: Direct buffer memory] with root cause
java.lang.OutOfMemoryError: Direct buffer memory
at java.nio.Bits.reserveMemory(Bits.java:694)
at java.nio.DirectByteBuffer.<init>(DirectByteBuffer.java:123)
at java.nio.ByteBuffer.allocateDirect(ByteBuffer.java:311)
at sun.nio.ch.Util.getTemporaryDirectBuffer(Util.java:241)
at sun.nio.ch.IOUtil.read(IOUtil.java:195)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
at org.apache.kafka.common.network.PlaintextTransportLayer.read(PlaintextTransportLayer.java:104)
at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:117)
at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:335)
at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:296)
at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:560)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:496)
at org.apache.kafka.common.network.Selector.poll(Selector.java:425)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:510)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:271)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1247)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1187)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1154)
at com.xd.newkafka.utils.KafkaConsumerUtils.consumerAssin(KafkaConsumerUtils.java:105)
at com.xd.newkafka.controller.KafkaController.kafkaRead(KafkaController.java:200)
想请教一下：
1、在当前的模式下，每从controller层进来一个请求，就根据其所传参数创建一个consumer进行数据拉取，拉取完毕后关闭consumer，这样的模式是否合理?
2、接口项目的consumer需要保持长连接么？
public
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int
public static List<KafkaBasePojo> consumerAssin(String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition,Integer consumerNum, long offset, int autoOffset) {
List
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition,Integer
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition,Integer consumerNum, long offset, int autoOffset) {
List<KafkaBasePojo> kafkaBasePojoList = new ArrayList
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, Stringpublic static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition,Integer consumerNum, long offset, int
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition,Integer consumerNum, long offset, int autoOffset) {
List<KafkaBasePojo> kafkaBasePojoList = new ArrayList
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition,Integer consumerNum, long offsetpublic static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition,Integer consumerNum, long offset, int autoOffset) {
List<KafkaBasePojo
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition,Integer consumerNum, long offset
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition,Integer consumerNum, long offset, int autoOffset) {
List<KafkaBasePojo
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName
public static List<KafkaBasePojo> consumerAssin(String topicName, String
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName
public static List<KafkaBasePojo> consumerAssin(String topicName, String hostName, String consumerName, int partition,Integer consumerNum, long offset, int autoOffset) {
List<KafkaBasePojo> kafkaBasePojoList = new ArrayList<>();
Properties props = new Properties();
props.put("bootstrap.servers", hostName);
props.put("group.id", consumerName);
props, consumerName);
props.put("enable.auto.commit", isAutoCommitBool);
props.put("auto.commit.interval.ms", "1000");
Integer maxSize = Integer.valueOf);
Integer maxSize = Integer.valueOf(GetCommon.getBusinessConfigMapValue("kafka.max.fetch.bytes", "2097152"));
props.put("fetch.max.bytes", maxSize);
props.put("fetch.message.max.bytes", maxSize);
props, maxSize);
props.put("max.partition.fetch.bytes", maxSize, maxSize);
props.put("max.poll.records", MAX_POLLSIZE);
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props);
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put(ConsumerConfig.DEFAULT_API_TIMEOUT_MS_CONFIG);
props.put(ConsumerConfig.DEFAULT_API_TIMEOUT_MS_CONFIG, 50 * 1000);
props.put(ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG, 50 * 1000);
try {
KafkaConsumer<String, String);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
...
...
try {
ConsumerRecords<String, String> records = consumer.poll(Duration);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
...
...
try);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
...
...
try);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
...
...
try);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
...
...
try);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
...
...
try);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
...
...
try);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
try {
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
...
...
try {
ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(700));
...
...
consumer.close(Duration.ofMillis(5000));
}
}
return ...;
}