jhipster-lite
jhipster-lite copied to clipboard
Published
20 hours ago •
jhipster
jhipster
Kafka: flaky tests for dummy producer and consumer
It comes from: Warning: Rule violated for class tech.jhipster.kafkaapp.dummy.infrastructure.secondary.kafka.producer.DummyProducer: lines covered ratio is 0.84, but expected minimum is 1.00
Here an extract of the stacktrace:
2022-05-05 12:31:17.247 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Received FETCH response from node 1 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-5, correlationId=20): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=1239086310, responses=[FetchableTopicResponse(topic='queue.kafkaapp.dummy', partitions=[PartitionData(partitionIndex=0, errorCode=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, divergingEpoch=EpochEndOffset(epoch=-1, endOffset=-1), currentLeader=LeaderIdAndEpoch(leaderId=-1, leaderEpoch=-1), snapshotId=SnapshotId(endOffset=-1, epoch=-1), abortedTransactions=null, preferredReadReplica=-1, records=MemoryRecords(size=0, buffer=java.nio.HeapByteBuffer[pos=0 lim=0 cap=3]))])])
2022-05-05 12:31:17.248 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Node 1 sent a full fetch response that created a new incremental fetch session 1239086310 with 1 response partition(s)
2022-05-05 12:31:17.249 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Fetch READ_UNCOMMITTED at offset 0 for partition queue.kafkaapp.dummy-0 returned fetch data PartitionData(partitionIndex=0, errorCode=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, divergingEpoch=EpochEndOffset(epoch=-1, endOffset=-1), currentLeader=LeaderIdAndEpoch(leaderId=-1, leaderEpoch=-1), snapshotId=SnapshotId(endOffset=-1, epoch=-1), abortedTransactions=null, preferredReadReplica=-1, records=MemoryRecords(size=0, buffer=java.nio.HeapByteBuffer[pos=0 lim=0 cap=3]))
2022-05-05 12:31:17.282 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Received FETCH response from node 1 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-2, correlationId=55): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=58244337, responses=[])
2022-05-05 12:31:17.283 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Node 1 sent an incremental fetch response with throttleTimeMs = 0 for session 58244337 with 0 response partition(s), 1 implied partition(s)
2022-05-05 12:31:17.284 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Added READ_UNCOMMITTED fetch request for partition queue.kafkaapp.dummy-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:49158 (id: 1 rack: null)], epoch=0}} to node localhost:49158 (id: 1 rack: null)
2022-05-05 12:31:17.285 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Built incremental fetch (sessionId=58244337, epoch=26) for node 1. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2022-05-05 12:31:17.285 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(queue.kafkaapp.dummy-0)) to broker localhost:49158 (id: 1 rack: null)
2022-05-05 12:31:17.286 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-2, correlationId=57) and timeout 30000 to node 1: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=58244337, sessionEpoch=26, topics=[], forgottenTopicsData=[], rackId='')
2022-05-05 12:31:17.298 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Added READ_UNCOMMITTED fetch request for partition queue.kafkaapp.dummy-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:49160 (id: 1 rack: null)], epoch=0}} to node localhost:49160 (id: 1 rack: null)
2022-05-05 12:31:17.299 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Built incremental fetch (sessionId=1239086310, epoch=1) for node 1. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2022-05-05 12:31:17.299 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(queue.kafkaapp.dummy-0)) to broker localhost:49160 (id: 1 rack: null)
2022-05-05 12:31:17.300 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-5, correlationId=21) and timeout 30000 to node 1: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=1239086310, sessionEpoch=1, topics=[], forgottenTopicsData=[], rackId='')
2022-05-05 12:31:17.353 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Received FETCH response from node 1 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-1, correlationId=108): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=378506570, responses=[])
2022-05-05 12:31:17.354 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Node 1 sent an incremental fetch response with throttleTimeMs = 0 for session 378506570 with 0 response partition(s), 1 implied partition(s)
2022-05-05 12:31:17.355 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Added READ_UNCOMMITTED fetch request for partition queue.kafkaapp.dummy-0 at position FetchPosition{offset=2, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[localhost:49154 (id: 1 rack: null)], epoch=0}} to node localhost:49154 (id: 1 rack: null)
2022-05-05 12:31:17.356 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Built incremental fetch (sessionId=378506570, epoch=70) for node 1. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2022-05-05 12:31:17.357 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(queue.kafkaapp.dummy-0)) to broker localhost:49154 (id: 1 rack: null)
2022-05-05 12:31:17.357 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-1, correlationId=109) and timeout 30000 to node 1: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=378506570, sessionEpoch=70, topics=[], forgottenTopicsData=[], rackId='')
2022-05-05 12:31:17.476 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending asynchronous auto-commit of offsets {queue.kafkaapp.dummy-0=OffsetAndMetadata{offset=2, leaderEpoch=0, metadata=''}}
2022-05-05 12:31:17.477 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending OFFSET_COMMIT request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-kafkaapp-1, correlationId=110) and timeout 30000 to node 2147483646: OffsetCommitRequestData(groupId='kafkaapp', generationId=1, memberId='consumer-kafkaapp-1-d8dce52f-e4aa-4a23-8e12-58070a88403f', groupInstanceId=null, retentionTimeMs=-1, topics=[OffsetCommitRequestTopic(name='queue.kafkaapp.dummy', partitions=[OffsetCommitRequestPartition(partitionIndex=0, committedOffset=2, committedLeaderEpoch=0, commitTimestamp=-1, committedMetadata='')])])
2022-05-05 12:31:17.482 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Received OFFSET_COMMIT response from node 2147483646 for request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-kafkaapp-1, correlationId=110): OffsetCommitResponseData(throttleTimeMs=0, topics=[OffsetCommitResponseTopic(name='queue.kafkaapp.dummy', partitions=[OffsetCommitResponsePartition(partitionIndex=0, errorCode=0)])])
2022-05-05 12:31:17.482 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Committed offset 2 for partition queue.kafkaapp.dummy-0
2022-05-05 12:31:17.483 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Completed asynchronous auto-commit of offsets {queue.kafkaapp.dummy-0=OffsetAndMetadata{offset=2, leaderEpoch=0, metadata=''}}
2022-05-05 12:31:17.721 ERROR 2409 --- [ main] o.z.problem.spring.common.AdviceTraits : Internal Server Error
java.lang.NullPointerException: java.lang.NullPointerException
at tech.jhipster.kafkaapp.technical.infrastructure.primary.exception.ExceptionTranslatorTestController.nullPointerException(ExceptionTranslatorTestController.java:39)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150)
at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808)
at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1067)
at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:963)
at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)
at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:655)
at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)
at org.springframework.test.web.servlet.TestDispatcherServlet.service(TestDispatcherServlet.java:72)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:764)
at org.springframework.mock.web.MockFilterChain$ServletFilterProxy.doFilter(MockFilterChain.java:167)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.web.filter.CorsFilter.doFilterInternal(CorsFilter.java:91)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:96)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.test.web.servlet.MockMvc.perform(MockMvc.java:199)
at tech.jhipster.kafkaapp.technical.infrastructure.primary.exception.ExceptionTranslatorIT.shouldHandleExceptionContainsPackageName(ExceptionTranslatorIT.java:187)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:84)
at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:128)
at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
2022-05-05 12:31:17.732 DEBUG 2409 --- [ main] c.j.jsonpath.internal.path.CompiledPath : Evaluating path: $['message']
2022-05-05 12:31:17.733 DEBUG 2409 --- [ main] c.j.jsonpath.internal.path.CompiledPath : Evaluating path: $['title']
2022-05-05 12:31:17.775 ERROR 2409 --- [ main] o.z.problem.spring.common.AdviceTraits : Internal Server Error
java.lang.NullPointerException: java.lang.NullPointerException
at tech.jhipster.kafkaapp.technical.infrastructure.primary.exception.ExceptionTranslatorTestController.nullPointerException(ExceptionTranslatorTestController.java:39)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150)
at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808)
at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1067)
at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:963)
at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)
at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:655)
at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)
at org.springframework.test.web.servlet.TestDispatcherServlet.service(TestDispatcherServlet.java:72)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:764)
at org.springframework.mock.web.MockFilterChain$ServletFilterProxy.doFilter(MockFilterChain.java:167)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.web.filter.CorsFilter.doFilterInternal(CorsFilter.java:91)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:96)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.springframework.mock.web.MockFilterChain.doFilter(MockFilterChain.java:134)
at org.springframework.test.web.servlet.MockMvc.perform(MockMvc.java:199)
at tech.jhipster.kafkaapp.technical.infrastructure.primary.exception.ExceptionTranslatorIT.shouldHandleExceptionContainsPackageNameWithNullPackages(ExceptionTranslatorIT.java:199)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:84)
at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:128)
at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
2022-05-05 12:31:17.790 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Received FETCH response from node 1 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-2, correlationId=57): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=58244337, responses=[])
2022-05-05 12:31:17.791 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Node 1 sent an incremental fetch response with throttleTimeMs = 0 for session 58244337 with 0 response partition(s), 1 implied partition(s)
2022-05-05 12:31:17.791 DEBUG 2409 --- [ main] c.j.jsonpath.internal.path.CompiledPath : Evaluating path: $['message']
2022-05-05 12:31:17.792 DEBUG 2409 --- [ main] c.j.jsonpath.internal.path.CompiledPath : Evaluating path: $['title']
2022-05-05 12:31:17.792 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Added READ_UNCOMMITTED fetch request for partition queue.kafkaapp.dummy-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:49158 (id: 1 rack: null)], epoch=0}} to node localhost:49158 (id: 1 rack: null)
2022-05-05 12:31:17.794 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Built incremental fetch (sessionId=58244337, epoch=27) for node 1. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2022-05-05 12:31:17.794 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(queue.kafkaapp.dummy-0)) to broker localhost:49158 (id: 1 rack: null)
2022-05-05 12:31:17.795 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-2, correlationId=58) and timeout 30000 to node 1: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=5242[8800](https://github.com/jhipster/jhipster-lite/runs/6305834100?check_suite_focus=true#step:9:8800), isolationLevel=0, sessionId=58244337, sessionEpoch=27, topics=[], forgottenTopicsData=[], rackId='')
2022-05-05 12:31:17.815 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Received FETCH response from node 1 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-5, correlationId=21): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=1239086310, responses=[])
2022-05-05 12:31:17.815 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Node 1 sent an incremental fetch response with throttleTimeMs = 0 for session 1239086310 with 0 response partition(s), 1 implied partition(s)
2022-05-05 12:31:17.816 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Added READ_UNCOMMITTED fetch request for partition queue.kafkaapp.dummy-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:49160 (id: 1 rack: null)], epoch=0}} to node localhost:49160 (id: 1 rack: null)
2022-05-05 12:31:17.817 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Built incremental fetch (sessionId=1239086310, epoch=2) for node 1. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2022-05-05 12:31:17.817 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(queue.kafkaapp.dummy-0)) to broker localhost:49160 (id: 1 rack: null)
2022-05-05 12:31:17.817 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-5, correlationId=22) and timeout 30000 to node 1: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=1239086310, sessionEpoch=2, topics=[], forgottenTopicsData=[], rackId='')
2022-05-05 12:31:17.852 WARN 2409 --- [ main] o.z.problem.spring.common.AdviceTraits : Bad Request: Required request parameter 'param' for method parameter type String is not present
2022-05-05 12:31:17.861 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Received FETCH response from node 1 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-1, correlationId=109): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=378506570, responses=[])
2022-05-05 12:31:17.862 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Node 1 sent an incremental fetch response with throttleTimeMs = 0 for session 378506570 with 0 response partition(s), 1 implied partition(s)
2022-05-05 12:31:17.862 DEBUG 2409 --- [ main] c.j.jsonpath.internal.path.CompiledPath : Evaluating path: $['message']
2022-05-05 12:31:17.862 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Added READ_UNCOMMITTED fetch request for partition queue.kafkaapp.dummy-0 at position FetchPosition{offset=2, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[localhost:49154 (id: 1 rack: null)], epoch=0}} to node localhost:49154 (id: 1 rack: null)
2022-05-05 12:31:17.863 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Built incremental fetch (sessionId=378506570, epoch=71) for node 1. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2022-05-05 12:31:17.863 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(queue.kafkaapp.dummy-0)) to broker localhost:49154 (id: 1 rack: null)
2022-05-05 12:31:17.863 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-1, correlationId=111) and timeout 30000 to node 1: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=378506570, sessionEpoch=71, topics=[], forgottenTopicsData=[], rackId='')
2022-05-05 12:31:18.299 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Received FETCH response from node 1 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-2, correlationId=58): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=58244337, responses=[])
2022-05-05 12:31:18.299 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Node 1 sent an incremental fetch response with throttleTimeMs = 0 for session 58244337 with 0 response partition(s), 1 implied partition(s)
2022-05-05 12:31:18.300 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Added READ_UNCOMMITTED fetch request for partition queue.kafkaapp.dummy-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:49158 (id: 1 rack: null)], epoch=0}} to node localhost:49158 (id: 1 rack: null)
2022-05-05 12:31:18.300 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Built incremental fetch (sessionId=58244337, epoch=28) for node 1. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2022-05-05 12:31:18.300 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(queue.kafkaapp.dummy-0)) to broker localhost:49158 (id: 1 rack: null)
2022-05-05 12:31:18.301 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-2, correlationId=59) and timeout 30000 to node 1: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=58244337, sessionEpoch=28, topics=[], forgottenTopicsData=[], rackId='')
2022-05-05 12:31:18.322 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Received FETCH response from node 1 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-5, correlationId=22): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=1239086310, responses=[])
2022-05-05 12:31:18.322 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Node 1 sent an incremental fetch response with throttleTimeMs = 0 for session 1239086310 with 0 response partition(s), 1 implied partition(s)
2022-05-05 12:31:18.323 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Added READ_UNCOMMITTED fetch request for partition queue.kafkaapp.dummy-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:49160 (id: 1 rack: null)], epoch=0}} to node localhost:49160 (id: 1 rack: null)
2022-05-05 12:31:18.323 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Built incremental fetch (sessionId=1239086310, epoch=3) for node 1. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2022-05-05 12:31:18.323 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(queue.kafkaapp.dummy-0)) to broker localhost:49160 (id: 1 rack: null)
2022-05-05 12:31:18.324 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-5, groupId=kafkaapp] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-5, correlationId=23) and timeout 30000 to node 1: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=1239086310, sessionEpoch=3, topics=[], forgottenTopicsData=[], rackId='')
2022-05-05 12:31:18.353 DEBUG 2409 --- [read | kafkaapp] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending Heartbeat request with generation 1 and member id consumer-kafkaapp-1-d8dce52f-e4aa-4a23-8e12-58070a[8840](https://github.com/jhipster/jhipster-lite/runs/6305834100?check_suite_focus=true#step:9:8840)3f to coordinator localhost:49154 (id: 2147483646 rack: null)
2022-05-05 12:31:18.354 DEBUG 2409 --- [read | kafkaapp] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending HEARTBEAT request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-kafkaapp-1, correlationId=112) and timeout 30000 to node 2147483646: HeartbeatRequestData(groupId='kafkaapp', generationId=1, memberId='consumer-kafkaapp-1-d8dce52f-e4aa-4a23-8e12-58070a88403f', groupInstanceId=null)
2022-05-05 12:31:18.356 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Received HEARTBEAT response from node 2147483646 for request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-kafkaapp-1, correlationId=112): HeartbeatResponseData(throttleTimeMs=0, errorCode=0)
2022-05-05 12:31:18.356 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Received successful Heartbeat response
2022-05-05 12:31:18.366 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Received FETCH response from node 1 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-1, correlationId=111): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=378506570, responses=[])
2022-05-05 12:31:18.371 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Node 1 sent an incremental fetch response with throttleTimeMs = 0 for session 378506570 with 0 response partition(s), 1 implied partition(s)
2022-05-05 12:31:18.372 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Added READ_UNCOMMITTED fetch request for partition queue.kafkaapp.dummy-0 at position FetchPosition{offset=2, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[localhost:49154 (id: 1 rack: null)], epoch=0}} to node localhost:49154 (id: 1 rack: null)
2022-05-05 12:31:18.372 DEBUG 2409 --- [cTaskExecutor-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Built incremental fetch (sessionId=378506570, epoch=72) for node 1. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2022-05-05 12:31:18.372 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(queue.kafkaapp.dummy-0)) to broker localhost:49154 (id: 1 rack: null)
2022-05-05 12:31:18.373 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-kafkaapp-1, correlationId=113) and timeout 30000 to node 1: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=378506570, sessionEpoch=72, topics=[], forgottenTopicsData=[], rackId='')
2022-05-05 12:31:18.435 DEBUG 2409 --- [ main] o.h.v.r.PlatformResourceBundleLocator : ValidationMessages not found.
2022-05-05 12:31:18.442 DEBUG 2409 --- [ main] o.h.v.r.PlatformResourceBundleLocator : ContributorValidationMessages not found.
2022-05-05 12:31:18.452 DEBUG 2409 --- [ main] o.h.v.r.PlatformResourceBundleLocator : org.hibernate.validator.ValidationMessages found.
2022-05-05 12:31:18.483 WARN 2409 --- [ main] o.z.problem.spring.common.AdviceTraits : Bad Request: Validation failed for argument [0] in public void tech.jhipster.kafkaapp.technical.infrastructure.primary.exception.ExceptionTranslatorTestController.methodArgument(tech.jhipster.kafkaapp.technical.infrastructure.primary.exception.ExceptionTranslatorTestController$TestDTO): [Field error in object 'testDTO' on field 'test': rejected value [null]; codes [NotNull.testDTO.test,NotNull.test,NotNull.java.lang.String,NotNull]; arguments [org.springframework.context.support.DefaultMessageSourceResolvable: codes [testDTO.test,test]; arguments []; default message [test]]; default message [must not be null]]
2022-05-05 12:31:18.500 DEBUG 2409 --- [ main] c.j.jsonpath.internal.path.CompiledPath : Evaluating path: $['message']
2022-05-05 12:31:18.506 DEBUG 2409 --- [ main] c.j.jsonpath.internal.path.CompiledPath : Evaluating path: $['fieldErrors'][0]['objectName']
2022-05-05 12:31:18.506 DEBUG 2409 --- [ main] c.j.jsonpath.internal.path.CompiledPath : Evaluating path: $['fieldErrors'][0]['field']
2022-05-05 12:31:18.506 DEBUG 2409 --- [ main] c.j.jsonpath.internal.path.CompiledPath : Evaluating path: $['fieldErrors'][0]['message']
[INFO] Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 12.608 s - in tech.jhipster.kafkaapp.technical.infrastructure.primary.exception.ExceptionTranslatorIT
2022-05-05 12:31:18.573 DEBUG 2409 --- [ Thread-10] o.a.k.c.c.i.ConsumerNetworkClient : [Consumer clientId=consumer-kafkaapp-3, groupId=kafkaapp] Received user wakeup
2022-05-05 12:31:18.577 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.i.ConsumerNetworkClient : [Consumer clientId=consumer-kafkaapp-3, groupId=kafkaapp] Raising WakeupException in response to user wakeup
2022-05-05 12:31:18.577 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-3, groupId=kafkaapp] Sending synchronous auto-commit of offsets {}
2022-05-05 12:31:18.578 DEBUG 2409 --- [read | kafkaapp] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-3, groupId=kafkaapp] Heartbeat thread has closed
2022-05-05 12:31:18.578 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-3, groupId=kafkaapp] Executing onLeavePrepare with generation Generation{generationId=2, memberId='consumer-kafkaapp-3-a34ca98f-6df1-4d19-b70b-eedb7a8e88bd', protocol='range'} and memberId consumer-kafkaapp-3-a34ca98f-6df1-4d19-b70b-eedb7a8e88bd
2022-05-05 12:31:18.578 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-3, groupId=kafkaapp] Member consumer-kafkaapp-3-a34ca98f-6df1-4d19-b70b-eedb7a8e88bd sending LeaveGroup request to coordinator localhost:49158 (id: 2147483646 rack: null) due to the consumer is being closed
2022-05-05 12:31:18.579 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-3, groupId=kafkaapp] Sending LEAVE_GROUP request with header RequestHeader(apiKey=LEAVE_GROUP, apiVersion=4, clientId=consumer-kafkaapp-3, correlationId=10) and timeout 30000 to node 2147483646: LeaveGroupRequestData(groupId='kafkaapp', memberId='', members=[MemberIdentity(memberId='consumer-kafkaapp-3-a34ca98f-6df1-4d19-b70b-eedb7a8e88bd', groupInstanceId=null)])
2022-05-05 12:31:18.580 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-3, groupId=kafkaapp] Resetting generation due to: consumer pro-actively leaving the group
2022-05-05 12:31:18.580 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-3, groupId=kafkaapp] Request joining group due to: consumer pro-actively leaving the group
2022-05-05 12:31:18.588 DEBUG 2409 --- [ Thread-13] o.a.k.c.c.i.ConsumerNetworkClient : [Consumer clientId=consumer-kafkaapp-4, groupId=kafkaapp] Received user wakeup
2022-05-05 12:31:18.589 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.i.ConsumerNetworkClient : [Consumer clientId=consumer-kafkaapp-4, groupId=kafkaapp] Raising WakeupException in response to user wakeup
2022-05-05 12:31:18.589 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-4, groupId=kafkaapp] Sending synchronous auto-commit of offsets {}
2022-05-05 12:31:18.589 DEBUG 2409 --- [read | kafkaapp] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-4, groupId=kafkaapp] Heartbeat thread has closed
2022-05-05 12:31:18.590 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-4, groupId=kafkaapp] Executing onLeavePrepare with generation Generation{generationId=2, memberId='consumer-kafkaapp-4-205768d9-db80-45ea-8007-41f3d424a807', protocol='range'} and memberId consumer-kafkaapp-4-205768d9-db80-45ea-8007-41f3d424a807
2022-05-05 12:31:18.590 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-4, groupId=kafkaapp] Member consumer-kafkaapp-4-205768d9-db80-45ea-8007-41f3d424a807 sending LeaveGroup request to coordinator localhost:49158 (id: 2147483646 rack: null) due to the consumer is being closed
2022-05-05 12:31:18.590 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-4, groupId=kafkaapp] Sending LEAVE_GROUP request with header RequestHeader(apiKey=LEAVE_GROUP, apiVersion=4, clientId=consumer-kafkaapp-4, correlationId=10) and timeout 30000 to node 2147483646: LeaveGroupRequestData(groupId='kafkaapp', memberId='', members=[MemberIdentity(memberId='consumer-kafkaapp-4-205768d9-db80-45ea-8007-41f3d424a807', groupInstanceId=null)])
2022-05-05 12:31:18.591 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-4, groupId=kafkaapp] Resetting generation due to: consumer pro-actively leaving the group
2022-05-05 12:31:18.593 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-4, groupId=kafkaapp] Request joining group due to: consumer pro-actively leaving the group
2022-05-05 12:31:18.599 INFO 2409 --- [ Thread-11] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-3] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
2022-05-05 12:31:18.600 DEBUG 2409 --- [ad | producer-3] o.a.k.clients.producer.internals.Sender : [Producer clientId=producer-3] Beginning shutdown of Kafka producer I/O thread, sending remaining records.
2022-05-05 12:31:18.607 INFO 2409 --- [ Thread-5] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
2022-05-05 12:31:18.610 DEBUG 2409 --- [ad | producer-1] o.a.k.clients.producer.internals.Sender : [Producer clientId=producer-1] Beginning shutdown of Kafka producer I/O thread, sending remaining records.
2022-05-05 12:31:18.610 DEBUG 2409 --- [ Thread-4] o.a.k.c.c.i.ConsumerNetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Received user wakeup
2022-05-05 12:31:18.610 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.i.ConsumerNetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Raising WakeupException in response to user wakeup
2022-05-05 12:31:18.611 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending synchronous auto-commit of offsets {queue.kafkaapp.dummy-0=OffsetAndMetadata{offset=2, leaderEpoch=0, metadata=''}}
2022-05-05 12:31:18.611 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending OFFSET_COMMIT request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-kafkaapp-1, correlationId=114) and timeout 30000 to node 2147483646: OffsetCommitRequestData(groupId='kafkaapp', generationId=1, memberId='consumer-kafkaapp-1-d8dce52f-e4aa-4a23-8e12-58070a88403f', groupInstanceId=null, retentionTimeMs=-1, topics=[OffsetCommitRequestTopic(name='queue.kafkaapp.dummy', partitions=[OffsetCommitRequestPartition(partitionIndex=0, committedOffset=2, committedLeaderEpoch=0, commitTimestamp=-1, committedMetadata='')])])
2022-05-05 12:31:18.615 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Received OFFSET_COMMIT response from node 2147483646 for request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-kafkaapp-1, correlationId=114): OffsetCommitResponseData(throttleTimeMs=0, topics=[OffsetCommitResponseTopic(name='queue.kafkaapp.dummy', partitions=[OffsetCommitResponsePartition(partitionIndex=0, errorCode=0)])])
2022-05-05 12:31:18.615 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Committed offset 2 for partition queue.kafkaapp.dummy-0
2022-05-05 12:31:18.615 DEBUG 2409 --- [read | kafkaapp] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Heartbeat thread has closed
2022-05-05 12:31:18.615 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Executing onLeavePrepare with generation Generation{generationId=1, memberId='consumer-kafkaapp-1-d8dce52f-e4aa-4a23-8e12-58070a88403f', protocol='range'} and memberId consumer-kafkaapp-1-d8dce52f-e4aa-4a23-8e12-58070a88403f
2022-05-05 12:31:18.615 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Revoke previously assigned partitions queue.kafkaapp.dummy-0
2022-05-05 12:31:18.616 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Member consumer-kafkaapp-1-d8dce52f-e4aa-4a23-8e12-58070a88403f sending LeaveGroup request to coordinator localhost:49154 (id: 2147483646 rack: null) due to the consumer is being closed
2022-05-05 12:31:18.616 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Sending LEAVE_GROUP request with header RequestHeader(apiKey=LEAVE_GROUP, apiVersion=4, clientId=consumer-kafkaapp-1, correlationId=115) and timeout 30000 to node 2147483646: LeaveGroupRequestData(groupId='kafkaapp', memberId='', members=[MemberIdentity(memberId='consumer-kafkaapp-1-d8dce52f-e4aa-4a23-8e12-58070a88403f', groupInstanceId=null)])
2022-05-05 12:31:18.616 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Resetting generation due to: consumer pro-actively leaving the group
2022-05-05 12:31:18.616 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-1, groupId=kafkaapp] Request joining group due to: consumer pro-actively leaving the group
2022-05-05 12:31:18.624 DEBUG 2409 --- [ Thread-7] o.a.k.c.c.i.ConsumerNetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Received user wakeup
2022-05-05 12:31:18.631 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.i.ConsumerNetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Raising WakeupException in response to user wakeup
2022-05-05 12:31:18.631 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Sending synchronous auto-commit of offsets {queue.kafkaapp.dummy-0=OffsetAndMetadata{offset=0, leaderEpoch=null, metadata=''}}
2022-05-05 12:31:18.632 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Sending OFFSET_COMMIT request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-kafkaapp-2, correlationId=60) and timeout 30000 to node 2147483646: OffsetCommitRequestData(groupId='kafkaapp', generationId=2, memberId='consumer-kafkaapp-2-3b5cc576-1b08-4c56-a662-161fd3266893', groupInstanceId=null, retentionTimeMs=-1, topics=[OffsetCommitRequestTopic(name='queue.kafkaapp.dummy', partitions=[OffsetCommitRequestPartition(partitionIndex=0, committedOffset=0, committedLeaderEpoch=-1, commitTimestamp=-1, committedMetadata='')])])
2022-05-05 12:31:18.638 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Received OFFSET_COMMIT response from node 2147483646 for request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-kafkaapp-2, correlationId=60): OffsetCommitResponseData(throttleTimeMs=0, topics=[OffsetCommitResponseTopic(name='queue.kafkaapp.dummy', partitions=[OffsetCommitResponsePartition(partitionIndex=0, errorCode=0)])])
2022-05-05 12:31:18.639 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Committed offset 0 for partition queue.kafkaapp.dummy-0
2022-05-05 12:31:18.639 DEBUG 2409 --- [read | kafkaapp] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Heartbeat thread has closed
2022-05-05 12:31:18.639 DEBUG 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Executing onLeavePrepare with generation Generation{generationId=2, memberId='consumer-kafkaapp-2-3b5cc576-1b08-4c56-a662-161fd3266893', protocol='range'} and memberId consumer-kafkaapp-2-3b5cc576-1b08-4c56-a662-161fd3266893
2022-05-05 12:31:18.639 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Revoke previously assigned partitions queue.kafkaapp.dummy-0
2022-05-05 12:31:18.639 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Member consumer-kafkaapp-2-3b5cc576-1b08-4c56-a662-161fd3266893 sending LeaveGroup request to coordinator localhost:49158 (id: 2147483646 rack: null) due to the consumer is being closed
2022-05-05 12:31:18.640 DEBUG 2409 --- [cTaskExecutor-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Sending LEAVE_GROUP request with header RequestHeader(apiKey=LEAVE_GROUP, apiVersion=4, clientId=consumer-kafkaapp-2, correlationId=61) and timeout 30000 to node 2147483646: LeaveGroupRequestData(groupId='kafkaapp', memberId='', members=[MemberIdentity(memberId='consumer-kafkaapp-2-3b5cc576-1b08-4c56-a662-161fd3266893', groupInstanceId=null)])
2022-05-05 12:31:18.645 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Resetting generation due to: consumer pro-actively leaving the group
2022-05-05 12:31:18.645 INFO 2409 --- [cTaskExecutor-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-kafkaapp-2, groupId=kafkaapp] Request joining group due to: consumer pro-actively leaving the group
2022-05-05 12:31:18.646 INFO 2409 --- [ Thread-8] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
2022-05-05 12:31:18.647 DEBUG 2409 --- [ad | producer-2] o.a.k.clients.producer.internals.Sender : [Producer clientId=producer-2] Beginning shutdown of Kafka producer I/O thread, sending remaining records.
2022-05-05 12:31:18.666 INFO 2409 --- [ Thread-14] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-4] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
2022-05-05 12:31:18.667 DEBUG 2409 --- [ad | producer-4] o.a.k.clients.producer.internals.Sender : [Producer clientId=producer-4] Beginning shutdown of Kafka producer I/O thread, sending remaining records.
2022-05-05 12:31:18.667 INFO 2409 --- [ Thread-18] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-5] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
2022-05-05 12:31:18.668 DEBUG 2409 --- [ad | producer-5] o.a.k.clients.producer.internals.Sender : [Producer clientId=producer-5] Beginning shutdown of Kafka producer I/O thread, sending remaining records.
[INFO]
[INFO] Results:
[INFO]
[INFO] Tests run: 21, Failures: 0, Errors: 0, Skipped: 0
[INFO]
[INFO]
[INFO] --- jacoco-maven-plugin:0.8.7:report-integration (post-integration-tests) @ kafkaapp ---
[INFO] Loading execution data file /tmp/jhlite/kafkaapp/target/jacoco-it.exec
[INFO] Analyzed bundle 'kafkaapp' with 17 classes
[INFO]
[INFO] --- jacoco-maven-plugin:0.8.7:merge (merge) @ kafkaapp ---
[INFO] Loading execution data file /tmp/jhlite/kafkaapp/target/jacoco.exec
[INFO] Loading execution data file /tmp/jhlite/kafkaapp/target/jacoco-it.exec
[INFO] Writing merged execution data to /tmp/jhlite/kafkaapp/target/jacoco/allTest.exec
[INFO]
[INFO] --- jacoco-maven-plugin:0.8.7:report (post-merge-report) @ kafkaapp ---
[INFO] Loading execution data file /tmp/jhlite/kafkaapp/target/jacoco/allTest.exec
[INFO] Analyzed bundle 'kafkaapp' with 17 classes
[INFO]
[INFO] --- jacoco-maven-plugin:0.8.7:check (check) @ kafkaapp ---
[INFO] Loading execution data file /tmp/jhlite/kafkaapp/target/jacoco/allTest.exec
[INFO] Analyzed bundle 'kafkaapp' with 17 classes
Warning: Rule violated for class tech.jhipster.kafkaapp.dummy.infrastructure.secondary.kafka.producer.DummyProducer: lines covered ratio is 0.84, but expected minimum is 1.00
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping kafkaapp
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 01:20 min
[INFO] Finished at: 2022-05-05T12:31:19Z
[INFO] ------------------------------------------------------------------------
Error: Failed to execute goal org.jacoco:jacoco-maven-plugin:0.8.7:check (check) on project kafkaapp: Coverage checks have not been met. See log for details. -> [Help 1]
Error:
Error: To see the full stack trace of the errors, re-run Maven with the -e switch.
Error: Re-run Maven using the -X switch to enable full debug logging.
Error:
Error: For more information about the errors and possible solutions, please read the following articles:
Error: [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException
Error: Process completed with exit code 1.
@pascalgrimaud I don't understand with the code coverage could be the cause because the code was passing all the controls before merging?
Fixed on your project with as you said @pascalgrimaud :
protected static AtomicBoolean kafkaContainerStarted = new AtomicBoolean(false);