gabriel-farache opened a new issue, #2113:
URL: https://github.com/apache/incubator-kie-issues/issues/2113
When `kogito.events.grouping.binary` is set to `true`, the Data Index
crashes with the following error:
```
2025-09-23 10:43:55,219 ERROR [io.sma.rea.mes.provider]
(vert.x-eventloop-thread-0) SRMSG00201: Error caught while processing a message
in method
org.kie.kogito.index.service.messaging.BlockingMessagingEventConsumer#onProcessInstanceEvent:
java.lang.UnsupportedOperationException: Unrecognized event type
at
org.kie.kogito.event.serializer.MultipleProcessInstanceDataEventDeserializer.getCloudEvent(MultipleProcessInstanceDataEventDeserializer.java:164)
at
org.kie.kogito.event.serializer.MultipleProcessInstanceDataEventDeserializer.readFromBytes(MultipleProcessInstanceDataEventDeserializer.java:141)
at
org.kie.kogito.event.serializer.MultipleProcessDataInstanceConverterFactory.deserialize(MultipleProcessDataInstanceConverterFactory.java:74)
at
org.kie.kogito.event.serializer.MultipleProcessDataInstanceConverterFactory.lambda$fromCloudEvent$1(MultipleProcessDataInstanceConverterFactory.java:54)
at org.kie.kogito.event.DataEventFactory.from(DataEventFactory.java:58)
at
org.kie.kogito.index.service.messaging.KogitoIndexEventConverter.buildProcessInstanceDataEventVariant(KogitoIndexEventConverter.java:184)
at
org.kie.kogito.index.service.messaging.KogitoIndexEventConverter.convert(KogitoIndexEventConverter.java:156)
at
org.kie.kogito.index.service.messaging.KogitoIndexEventConverter_ClientProxy.convert(Unknown
Source)
at
io.smallrye.reactive.messaging.providers.helpers.ConverterUtils$1.apply(ConverterUtils.java:57)
at
io.smallrye.reactive.messaging.providers.helpers.ConverterUtils$1.apply(ConverterUtils.java:31)
at
io.smallrye.context.impl.wrappers.SlowContextualFunction.apply(SlowContextualFunction.java:21)
at
io.smallrye.mutiny.operators.multi.MultiMapOp$MapProcessor.onItem(MultiMapOp.java:42)
at
io.smallrye.mutiny.operators.multi.MultiOnItemInvoke$MultiOnItemInvokeProcessor.onItem(MultiOnItemInvoke.java:41)
at
io.smallrye.mutiny.operators.multi.MultiOperatorProcessor.onItem(MultiOperatorProcessor.java:100)
at
io.smallrye.reactive.messaging.providers.locals.ContextOperator$ContextMulti$ContextProcessor.onItem(ContextOperator.java:74)
at
io.smallrye.reactive.messaging.providers.locals.ContextOperator$ContextMulti$ContextProcessor.onItem(ContextOperator.java:37)
at
io.smallrye.mutiny.operators.multi.MultiMapOp$MapProcessor.onItem(MultiMapOp.java:50)
at
io.smallrye.mutiny.operators.multi.MultiOnItemInvoke$MultiOnItemInvokeProcessor.onItem(MultiOnItemInvoke.java:41)
at
io.smallrye.mutiny.operators.multi.builders.BufferItemMultiEmitter.drain(BufferItemMultiEmitter.java:123)
at
io.smallrye.mutiny.operators.multi.builders.BufferItemMultiEmitter.emit(BufferItemMultiEmitter.java:37)
at
io.smallrye.mutiny.operators.multi.builders.SerializedMultiEmitter.onItem(SerializedMultiEmitter.java:50)
at
io.smallrye.mutiny.operators.multi.builders.SerializedMultiEmitter.emit(SerializedMultiEmitter.java:140)
at
io.quarkus.reactivemessaging.http.runtime.ReactiveHttpHandlerBean.handleRequest(ReactiveHttpHandlerBean.java:64)
at
io.quarkus.reactivemessaging.http.runtime.ReactiveHandlerBeanBase.handle(ReactiveHandlerBeanBase.java:29)
at
io.quarkus.reactivemessaging.http.runtime.ReactiveHttpHandler.handle(ReactiveHttpHandler.java:16)
at
io.quarkus.reactivemessaging.http.runtime.ReactiveHttpHandler.handle(ReactiveHttpHandler.java:6)
at io.vertx.ext.web.impl.RouteState.handleContext(RouteState.java:1281)
at
io.vertx.ext.web.impl.RoutingContextImplBase.iterateNext(RoutingContextImplBase.java:177)
at
io.vertx.ext.web.impl.RoutingContextImpl.next(RoutingContextImpl.java:151)
at
io.vertx.ext.web.handler.impl.BodyHandlerImpl.handle(BodyHandlerImpl.java:141)
at
io.vertx.ext.web.handler.impl.BodyHandlerImpl.handle(BodyHandlerImpl.java:45)
at
io.quarkus.vertx.http.runtime.VertxHttpRecorder$16.handle(VertxHttpRecorder.java:1572)
at
io.quarkus.vertx.http.runtime.VertxHttpRecorder$16.handle(VertxHttpRecorder.java:1543)
at io.vertx.ext.web.impl.RouteState.handleContext(RouteState.java:1281)
at
io.vertx.ext.web.impl.RoutingContextImplBase.iterateNext(RoutingContextImplBase.java:140)
at
io.vertx.ext.web.impl.RoutingContextImpl.next(RoutingContextImpl.java:151)
at
io.vertx.ext.web.handler.impl.BodyHandlerImpl.handle(BodyHandlerImpl.java:141)
at
io.vertx.ext.web.handler.impl.BodyHandlerImpl.handle(BodyHandlerImpl.java:45)
at
io.quarkus.vertx.http.runtime.VertxHttpRecorder$16.handle(VertxHttpRecorder.java:1572)
at
io.quarkus.vertx.http.runtime.VertxHttpRecorder$16.handle(VertxHttpRecorder.java:1543)
at io.vertx.ext.web.impl.RouteState.handleContext(RouteState.java:1281)
at
io.vertx.ext.web.impl.RoutingContextImplBase.iterateNext(RoutingContextImplBase.java:140)
at
io.vertx.ext.web.impl.RoutingContextImpl.next(RoutingContextImpl.java:151)
at
io.vertx.ext.web.handler.impl.BodyHandlerImpl$BHandler.doEnd(BodyHandlerImpl.java:362)
at
io.vertx.ext.web.handler.impl.BodyHandlerImpl$BHandler.end(BodyHandlerImpl.java:339)
at io.vertx.core.impl.ContextInternal.dispatch(ContextInternal.java:270)
at io.vertx.core.impl.ContextInternal.dispatch(ContextInternal.java:252)
at
io.vertx.core.http.impl.HttpEventHandler.handleEnd(HttpEventHandler.java:76)
at
io.vertx.core.http.impl.Http1xServerRequest.onEnd(Http1xServerRequest.java:640)
at
io.vertx.core.http.impl.Http1xServerRequest.lambda$pendingHandler$0(Http1xServerRequest.java:375)
at
io.vertx.core.streams.impl.InboundBuffer.handleEvent(InboundBuffer.java:279)
at
io.vertx.core.streams.impl.InboundBuffer.write(InboundBuffer.java:157)
at
io.vertx.core.http.impl.Http1xServerRequest.handleEnd(Http1xServerRequest.java:617)
at io.vertx.core.impl.ContextImpl.execute(ContextImpl.java:327)
at
io.vertx.core.impl.DuplicatedContext.execute(DuplicatedContext.java:158)
at
io.vertx.core.http.impl.Http1xServerConnection.onEnd(Http1xServerConnection.java:215)
at
io.vertx.core.http.impl.Http1xServerConnection.onContent(Http1xServerConnection.java:206)
at
io.vertx.core.http.impl.Http1xServerConnection.handleOther(Http1xServerConnection.java:189)
at
io.vertx.core.http.impl.Http1xServerConnection.handleMessage(Http1xServerConnection.java:176)
at io.vertx.core.net.impl.ConnectionBase.read(ConnectionBase.java:159)
at
io.vertx.core.net.impl.VertxHandler.channelRead(VertxHandler.java:153)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:289)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1357)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:868)
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:796)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:732)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:658)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
at
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:998)
at
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:840)
2025-09-23 10:43:59,989 INFO [io.qua.rea.htt.run.HttpCloudEventHelper]
(vert.x-eventloop-thread-0) Unrecognized CE attribute Ce-Kogitoprocid, assuming
extension
2025-09-23 10:43:59,989 INFO [io.qua.rea.htt.run.HttpCloudEventHelper]
(vert.x-eventloop-thread-0) Unrecognized CE attribute Ce-Partitionkey, assuming
extension
2025-09-23 10:44:00,431 INFO [io.qua.rea.htt.run.HttpCloudEventHelper]
(vert.x-eventloop-thread-0) Unrecognized CE attribute Ce-Kogitoprocid, assuming
extension
2025-09-23 10:44:00,431 INFO [io.qua.rea.htt.run.HttpCloudEventHelper]
(vert.x-eventloop-thread-0) Unrecognized CE attribute Ce-Partitionkey, assuming
extension
2025-09-23 10:44:05,018 INFO [io.qua.rea.htt.run.HttpCloudEventHelper]
(vert.x-eventloop-thread-0) Unrecognized CE attribute Ce-Kogitoprocid, assuming
extension
2025-09-23 10:44:05,018 INFO [io.qua.rea.htt.run.HttpCloudEventHelper]
(vert.x-eventloop-thread-0) Unrecognized CE attribute Ce-Partitionkey, assuming
extension
2025-09-23 10:44:05,428 INFO [io.qua.rea.htt.run.HttpCloudEventHelper]
(vert.x-eventloop-thread-0) Unrecognized CE attribute Ce-Kogitoprocid, assuming
extension
2025-09-23 10:44:05,429 INFO [io.qua.rea.htt.run.HttpCloudEventHelper]
(vert.x-eventloop-thread-0) Unrecognized CE attribute Ce-Partitionkey, assuming
extension
2025-09-23 10:44:05,510 INFO [io.sma.health] (vert.x-eventloop-thread-0)
SRHCK01001: Reporting health down status:
{"status":"DOWN","checks":[{"name":"Database connections health
check","status":"UP","data":{"<default>":"UP"}},{"name":"SmallRye Reactive
Messaging - readiness
check","status":"DOWN","data":{"application-org.kie.kogito.index.service.messaging.BlockingMessagingEventConsumer#onProcessInstanceEvent":"[KO]
- Unrecognized event type "}}]}
2025-09-23 10:44:05,510 INFO [io.sma.health] (vert.x-eventloop-thread-1)
SRHCK01001: Reporting health down status:
{"status":"DOWN","checks":[{"name":"SmallRye Reactive Messaging - liveness
check","status":"DOWN","data":{"application-org.kie.kogito.index.service.messaging.BlockingMessagingEventConsumer#onProcessInstanceEvent":"[KO]
- Unrecognized event type "}}]}
```
This cause the workflow to wait indefinitely (until it restarts once the
Data Index is back online) and causes timeout to the caller.
When disabling the binary mode, the workflow ends successfully.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
