Custom Event Cannot be Deserialized

[EmirBoyaci]

Describe the bug
After upgrading Spring Boot to 4 and Spring Cloud to 2025.1.0, I am getting similar error in logs as spring-cloud/spring-cloud-bus#284 but in my case for custom events. I can confirm, with Spring Boot 3.5.7 and Spring Cloud 2025.0.0 it works as expected and no error thrown. I am adding samples as below, in my current setup event publisher and listener are different spring boot applications connected to the same RabbitMQ.
P.S: First I bumped versions for the event publisher, and listener was able to receive custom events without any problem. After bumped versions for event listener, it started failing to deserialize.

Sample

Event class definition:

import lombok.EqualsAndHashCode;
import lombok.Getter;
import org.springframework.cloud.bus.event.RemoteApplicationEvent;

@EqualsAndHashCode(callSuper = true)
public class TestEvent extends RemoteApplicationEvent {
  @Getter
  private String key;

  public TestEvent() {
  }

  public TestEvent(Object source, String originService, String destination, String key) {
    super(source, originService, () -> destination);
    this.key = key;
  }
}

Spring boot application entrypoint:

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.bus.jackson.RemoteApplicationEventScan;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.data.mongodb.config.EnableMongoAuditing;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;

@SpringBootApplication
@EnableMongoRepositories
@ComponentScan(basePackages = {"org.test"})
@EnableMongoAuditing(auditorAwareRef = "auditorProvider")
@RemoteApplicationEventScan(basePackages = {"org.test"})
@EnableFeignClients
public class TestServiceApplication {
  public static void main(String[] args) {
    SpringApplication.run(TestServiceApplication.class, args);
  }
}

Event listener:

import lombok.extern.slf4j.Slf4j;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class TestEventListener {
  @EventListener
  public void onTestEvent(TestEvent event) {
    log.info("Received TestEvent {}", event);
  }

Event publisher:

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.bus.BusProperties;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;

@Service
@Slf4j
@RequiredArgsConstructor
public class PublisherService {
  private final ApplicationEventPublisher applicationEventPublisher;
  private final BusProperties busProperties;

  protected void publishEvent(String destination, String key) {
    log.debug("Publishing test event with destination {} and key {}", destination, key);
    TestEvent testEvent = new TestEvent(this, busProperties.getId(), String.format("%s:**", destination), key);
    applicationEventPublisher.publishEvent(testEvent);
  }
}

Error logs

2025-12-02T08:34:15.636+03:00 ERROR 64774 --- [test-service] [uCnbIRZGKBk_Q-1] o.s.c.b.j.BusJacksonMessageConverter     : Cannot construct instance of `org.test.model.event.TestEvent`, problem: null source
 at [Source: REDACTED (`StreamReadFeature.INCLUDE_SOURCE_IN_LOCATION` disabled); byte offset: spring-cloud/spring-cloud-bus#234]

tools.jackson.databind.exc.ValueInstantiationException: Cannot construct instance of `org.test.model.event.TestEvent`, problem: null source
 at [Source: REDACTED (`StreamReadFeature.INCLUDE_SOURCE_IN_LOCATION` disabled); byte offset: spring-cloud/spring-cloud-bus#234]
	at tools.jackson.databind.exc.ValueInstantiationException.from(ValueInstantiationException.java:44) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.DeserializationContext.instantiationException(DeserializationContext.java:2080) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.std.StdValueInstantiator.wrapAsDatabindException(StdValueInstantiator.java:581) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.std.StdValueInstantiator.rewrapCtorProblem(StdValueInstantiator.java:602) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.std.StdValueInstantiator.createFromObjectWith(StdValueInstantiator.java:289) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.ValueInstantiator.createFromObjectWith(ValueInstantiator.java:270) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.PropertyBasedCreator.build(PropertyBasedCreator.java:252) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.BeanDeserializer._deserializeUsingPropertyBased(BeanDeserializer.java:697) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.BeanDeserializerBase.deserializeFromObjectUsingNonDefault(BeanDeserializerBase.java:1417) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.BeanDeserializer.deserializeFromObject(BeanDeserializer.java:480) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.BeanDeserializer._deserializeOther(BeanDeserializer.java:235) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.BeanDeserializer.deserialize(BeanDeserializer.java:202) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId(AsPropertyTypeDeserializer.java:138) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject(AsPropertyTypeDeserializer.java:103) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.AbstractDeserializer.deserializeWithType(AbstractDeserializer.java:243) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.impl.TypeWrappedDeserializer.deserialize(TypeWrappedDeserializer.java:72) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.DeserializationContextExt.readRootValue(DeserializationContextExt.java:265) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:2610) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:1627) ~[jackson-databind-3.0.2.jar:3.0.2]
	at org.springframework.cloud.bus.jackson.BusJacksonMessageConverter.convertFromInternal(BusJacksonAutoConfiguration.java:180) ~[spring-cloud-bus-5.0.0.jar:5.0.0]
	at org.springframework.messaging.converter.AbstractMessageConverter.fromMessage(AbstractMessageConverter.java:179) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.converter.AbstractMessageConverter.fromMessage(AbstractMessageConverter.java:171) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.cloud.function.context.config.SmartCompositeMessageConverter.fromMessage(SmartCompositeMessageConverter.java:75) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.convertInputMessageIfNecessary(SimpleFunctionRegistry.java:1428) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.convertInputIfNecessary(SimpleFunctionRegistry.java:1180) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.doApply(SimpleFunctionRegistry.java:787) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.apply(SimpleFunctionRegistry.java:627) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.observability.ObservationFunctionAroundWrapper.lambda$nonReactorStream$0(ObservationFunctionAroundWrapper.java:50) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at io.micrometer.observation.Observation.observe(Observation.java:564) ~[micrometer-observation-1.16.0.jar:1.16.0]
	at org.springframework.cloud.function.observability.ObservationFunctionAroundWrapper.nonReactorStream(ObservationFunctionAroundWrapper.java:50) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.observability.ObservationFunctionAroundWrapper.doApply(ObservationFunctionAroundWrapper.java:45) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.FunctionAroundWrapper.apply(FunctionAroundWrapper.java:44) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.apply(SimpleFunctionRegistry.java:624) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.PartitionAwareFunctionWrapper.apply(PartitionAwareFunctionWrapper.java:92) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.FunctionConfiguration$FunctionWrapper.apply(FunctionConfiguration.java:830) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.FunctionConfiguration$FunctionToDestinationBinder$1.handleMessageInternal(FunctionConfiguration.java:668) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.integration.handler.AbstractMessageHandler.doHandleMessage(AbstractMessageHandler.java:102) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:70) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:133) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:150) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:123) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.sendInternal(AbstractMessageChannel.java:438) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.sendWithMetrics(AbstractMessageChannel.java:409) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:338) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:310) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:108) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.integration.endpoint.MessageProducerSupport.sendMessageWithTracking(MessageProducerSupport.java:278) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:267) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.access$000(AmqpInboundChannelAdapter.java:71) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$Listener.lambda$onMessage$0(AmqpInboundChannelAdapter.java:392) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.core.retry.RetryTemplate.execute(RetryTemplate.java:142) ~[spring-core-7.0.1.jar:7.0.1]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$Listener.onMessage(AmqpInboundChannelAdapter.java:385) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1683) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1612) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1599) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1590) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListenerAndHandleException(AbstractMessageListenerContainer.java:1539) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.lambda$executeListener$1(AbstractMessageListenerContainer.java:1517) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at io.micrometer.observation.Observation.observe(Observation.java:499) ~[micrometer-observation-1.16.0.jar:1.16.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1517) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:1116) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:1061) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.mainLoop(SimpleMessageListenerContainer.java:1465) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1359) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at java.base/java.lang.Thread.run(Thread.java:1583) ~[na:na]
Caused by: java.lang.IllegalArgumentException: null source
	at java.base/java.util.EventObject.<init>(EventObject.java:57) ~[na:na]
	at org.springframework.context.ApplicationEvent.<init>(ApplicationEvent.java:48) ~[spring-context-7.0.1.jar:7.0.1]
	at org.springframework.cloud.bus.event.RemoteApplicationEvent.<init>(RemoteApplicationEvent.java:61) ~[spring-cloud-bus-5.0.0.jar:5.0.0]
	at org.test.model.event.TestEvent.<init>(TestEvent.java:16) ~[classes/:na]
	at java.base/java.lang.invoke.MethodHandle.invokeWithArguments(MethodHandle.java:733) ~[na:na]
	at tools.jackson.databind.introspect.AnnotatedConstructor.call(AnnotatedConstructor.java:113) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.std.StdValueInstantiator.createFromObjectWith(StdValueInstantiator.java:287) ~[jackson-databind-3.0.2.jar:3.0.2]
	... 64 common frames omitted

[olegz]

@EmirBoyaci Can you please try with the latest snapshot of s-c-stream? As it uses Jackson 3 there may be few loose ends and in fact I fixed one yesterday - 83b78fb
Thte error looks similar to what I have observed with your issue

[EmirBoyaci]

Hey @olegz, thanks for the feedback. I was not able to locate from which maven repository and which artifact/version should I look for? I thought it is located under https://repo.spring.io/ui/native/snapshot/org/springframework/cloud/ but not able to see it. Can you please advise?

[olegz]

@EmirBoyaci
Try

 <repositories>
        <repository>
            <id>spring-snapshots</id>
            <name>Spring Snapshots</name>
            <url>https://repo.spring.io/snapshot</url>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
            <releases>
                <enabled>false</enabled>
            </releases>
        </repository>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </repository>
        <repository>
            <id>spring-releases</id>
            <name>Spring Releases</name>
            <url>https://repo.spring.io/release</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </repository>
    </repositories>

<spring-cloud.version>2025.1.1-SNAPSHOT</spring-cloud.version>

[olegz]

Actually the fix i did, while related is not going to address it. Let me transfer this issue to s-c-stream and I'll work on it

[olegz]

@EmirBoyaci
I need a little more info to reproduce

1. I need RemoteApplicationEvent
2. I need the object you are passing to public TestEvent(Object source,. . .

[EmirBoyaci]

Hi @olegz,

1. RemoteApplicationEvent is coming from org.springframework.cloud.bus.event.RemoteApplicationEvent
2. The object itself is passed via this from the event publisher's class (ref doc Baeldung and Spring Cloud Bus)

[olegz]

Ok, i see the issue. The event TestEvent that is being created is null hence the

Caused by: java.lang.IllegalArgumentException: null source
	at java.base/java.util.EventObject.<init>(EventObject.java:57) ~[na:na]
	at org.springframework.context.ApplicationEvent.<init>(ApplicationEvent.java:48) ~[spring-context-7.0.1.jar:7.0.1]
	at org.springframework.cloud.bus.event.RemoteApplicationEvent.<init>(RemoteApplicationEvent.java:61) ~[spring-cloud-bus-5.0.0.jar:5.0.0]
	at org.test.model.event.TestEvent.<init>(TestEvent.java:16) ~[classes/:na]

This appears to be happening during deserialisation of a Message into TestEvent.
Could you please send me the JSON payload of a message?

[EmirBoyaci]

@olegz, I made level of the root logger as debug to see exactly what's going on including the payload, you can see below:

2025-12-03T19:55:41.858+03:00 ERROR 2555 --- [test-service] [wWp6Ks6xYCujQ-1] o.s.c.b.j.BusJacksonMessageConverter     : Cannot construct instance of `org.test.model.event.TestEvent`, problem: null source
 at [Source: REDACTED (`StreamReadFeature.INCLUDE_SOURCE_IN_LOCATION` disabled); byte offset: #234]

tools.jackson.databind.exc.ValueInstantiationException: Cannot construct instance of `org.test.model.event.TestEvent`, problem: null source
 at [Source: REDACTED (`StreamReadFeature.INCLUDE_SOURCE_IN_LOCATION` disabled); byte offset: #234]
	at tools.jackson.databind.exc.ValueInstantiationException.from(ValueInstantiationException.java:44) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.DeserializationContext.instantiationException(DeserializationContext.java:2080) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.std.StdValueInstantiator.wrapAsDatabindException(StdValueInstantiator.java:581) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.std.StdValueInstantiator.rewrapCtorProblem(StdValueInstantiator.java:602) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.std.StdValueInstantiator.createFromObjectWith(StdValueInstantiator.java:289) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.ValueInstantiator.createFromObjectWith(ValueInstantiator.java:270) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.PropertyBasedCreator.build(PropertyBasedCreator.java:252) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.BeanDeserializer._deserializeUsingPropertyBased(BeanDeserializer.java:697) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.BeanDeserializerBase.deserializeFromObjectUsingNonDefault(BeanDeserializerBase.java:1417) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.BeanDeserializer.deserializeFromObject(BeanDeserializer.java:480) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.BeanDeserializer._deserializeOther(BeanDeserializer.java:235) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.bean.BeanDeserializer.deserialize(BeanDeserializer.java:202) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId(AsPropertyTypeDeserializer.java:138) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject(AsPropertyTypeDeserializer.java:103) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.AbstractDeserializer.deserializeWithType(AbstractDeserializer.java:243) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.impl.TypeWrappedDeserializer.deserialize(TypeWrappedDeserializer.java:72) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.DeserializationContextExt.readRootValue(DeserializationContextExt.java:265) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:2610) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:1627) ~[jackson-databind-3.0.2.jar:3.0.2]
	at org.springframework.cloud.bus.jackson.BusJacksonMessageConverter.convertFromInternal(BusJacksonAutoConfiguration.java:180) ~[spring-cloud-bus-5.0.0.jar:5.0.0]
	at org.springframework.messaging.converter.AbstractMessageConverter.fromMessage(AbstractMessageConverter.java:179) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.converter.AbstractMessageConverter.fromMessage(AbstractMessageConverter.java:171) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.cloud.function.context.config.SmartCompositeMessageConverter.fromMessage(SmartCompositeMessageConverter.java:75) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.convertInputMessageIfNecessary(SimpleFunctionRegistry.java:1428) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.convertInputIfNecessary(SimpleFunctionRegistry.java:1180) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.doApply(SimpleFunctionRegistry.java:787) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.apply(SimpleFunctionRegistry.java:627) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.PartitionAwareFunctionWrapper.apply(PartitionAwareFunctionWrapper.java:92) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.FunctionConfiguration$FunctionWrapper.apply(FunctionConfiguration.java:830) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.FunctionConfiguration$FunctionToDestinationBinder$1.handleMessageInternal(FunctionConfiguration.java:668) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.integration.handler.AbstractMessageHandler.doHandleMessage(AbstractMessageHandler.java:102) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:70) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:133) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:150) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:123) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.sendInternal(AbstractMessageChannel.java:438) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.sendWithMetrics(AbstractMessageChannel.java:409) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:338) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:310) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:108) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.integration.endpoint.MessageProducerSupport.sendMessageWithTracking(MessageProducerSupport.java:278) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:267) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.access$000(AmqpInboundChannelAdapter.java:71) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$Listener.lambda$onMessage$0(AmqpInboundChannelAdapter.java:392) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.core.retry.RetryTemplate.execute(RetryTemplate.java:178) ~[spring-core-7.0.1.jar:7.0.1]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$Listener.onMessage(AmqpInboundChannelAdapter.java:385) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1683) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1612) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1599) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1590) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListenerAndHandleException(AbstractMessageListenerContainer.java:1539) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.lambda$executeListener$1(AbstractMessageListenerContainer.java:1517) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at io.micrometer.observation.Observation.observe(Observation.java:499) ~[micrometer-observation-1.16.0.jar:1.16.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1517) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:1116) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:1061) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.mainLoop(SimpleMessageListenerContainer.java:1465) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1359) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at java.base/java.lang.Thread.run(Thread.java:1583) ~[na:na]
Caused by: java.lang.IllegalArgumentException: null source
	at java.base/java.util.EventObject.<init>(EventObject.java:57) ~[na:na]
	at org.springframework.context.ApplicationEvent.<init>(ApplicationEvent.java:48) ~[spring-context-7.0.1.jar:7.0.1]
	at org.springframework.cloud.bus.event.RemoteApplicationEvent.<init>(RemoteApplicationEvent.java:61) ~[spring-cloud-bus-5.0.0.jar:5.0.0]
	at org.test.model.event.TestEvent.<init>(TestEvent.java:16) ~[classes/:na]
	at java.base/java.lang.invoke.MethodHandle.invokeWithArguments(MethodHandle.java:733) ~[na:na]
	at tools.jackson.databind.introspect.AnnotatedConstructor.call(AnnotatedConstructor.java:113) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.std.StdValueInstantiator.createFromObjectWith(StdValueInstantiator.java:287) ~[jackson-databind-3.0.2.jar:3.0.2]
	... 58 common frames omitted

2025-12-03T19:55:41.859+03:00 DEBUG 2555 --- [test-service] [wWp6Ks6xYCujQ-1] c.s.c.CompositeMessageConverterFactory$2 : Failed to convert value: {"type":"TestEvent","originService":"publisher-service:dev:9001:4c6b4e19f6c5bb02658c43ba4b1043ec","key":"test-key","destinationService":"test-service:**","id":"eeb09fa5-d833-460d-a132-abfec9079283","timestamp":1764780936829} to: class org.springframework.cloud.bus.event.RemoteApplicationEvent

java.lang.IllegalStateException: Failed to convert. Possible bug as the conversion probably shouldn't have been attempted here
	at org.springframework.cloud.function.json.JacksonMapper.doFromJson(JacksonMapper.java:73) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.json.JsonMapper.fromJson(JsonMapper.java:81) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.config.JsonMessageConverter.convertFromInternal(JsonMessageConverter.java:109) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.messaging.converter.AbstractMessageConverter.fromMessage(AbstractMessageConverter.java:179) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.converter.AbstractMessageConverter.fromMessage(AbstractMessageConverter.java:171) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.cloud.function.context.config.SmartCompositeMessageConverter.fromMessage(SmartCompositeMessageConverter.java:75) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.convertInputMessageIfNecessary(SimpleFunctionRegistry.java:1428) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.convertInputIfNecessary(SimpleFunctionRegistry.java:1180) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.doApply(SimpleFunctionRegistry.java:787) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.apply(SimpleFunctionRegistry.java:627) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.PartitionAwareFunctionWrapper.apply(PartitionAwareFunctionWrapper.java:92) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.FunctionConfiguration$FunctionWrapper.apply(FunctionConfiguration.java:830) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.FunctionConfiguration$FunctionToDestinationBinder$1.handleMessageInternal(FunctionConfiguration.java:668) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.integration.handler.AbstractMessageHandler.doHandleMessage(AbstractMessageHandler.java:102) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:70) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:133) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:150) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:123) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.sendInternal(AbstractMessageChannel.java:438) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.sendWithMetrics(AbstractMessageChannel.java:409) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:338) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:310) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:108) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.integration.endpoint.MessageProducerSupport.sendMessageWithTracking(MessageProducerSupport.java:278) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:267) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.access$000(AmqpInboundChannelAdapter.java:71) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$Listener.lambda$onMessage$0(AmqpInboundChannelAdapter.java:392) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.core.retry.RetryTemplate.execute(RetryTemplate.java:178) ~[spring-core-7.0.1.jar:7.0.1]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$Listener.onMessage(AmqpInboundChannelAdapter.java:385) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1683) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1612) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1599) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1590) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListenerAndHandleException(AbstractMessageListenerContainer.java:1539) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.lambda$executeListener$1(AbstractMessageListenerContainer.java:1517) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at io.micrometer.observation.Observation.observe(Observation.java:499) ~[micrometer-observation-1.16.0.jar:1.16.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1517) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:1116) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:1061) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.mainLoop(SimpleMessageListenerContainer.java:1465) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1359) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at java.base/java.lang.Thread.run(Thread.java:1583) ~[na:na]
Caused by: tools.jackson.databind.exc.InvalidTypeIdException: Could not resolve type id 'TestEvent' as a subtype of `org.springframework.cloud.bus.event.RemoteApplicationEvent`: known type ids = []
 at [Source: REDACTED (`StreamReadFeature.INCLUDE_SOURCE_IN_LOCATION` disabled); byte offset: #8]
	at tools.jackson.databind.exc.InvalidTypeIdException.from(InvalidTypeIdException.java:41) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.DeserializationContext.invalidTypeIdException(DeserializationContext.java:2106) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.DeserializationContext.handleUnknownTypeId(DeserializationContext.java:1669) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.TypeDeserializerBase._handleUnknownTypeId(TypeDeserializerBase.java:279) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.TypeDeserializerBase._findDeserializer(TypeDeserializerBase.java:160) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId(AsPropertyTypeDeserializer.java:119) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject(AsPropertyTypeDeserializer.java:103) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.AbstractDeserializer.deserializeWithType(AbstractDeserializer.java:243) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.impl.TypeWrappedDeserializer.deserialize(TypeWrappedDeserializer.java:72) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.DeserializationContextExt.readRootValue(DeserializationContextExt.java:265) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:2610) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:1666) ~[jackson-databind-3.0.2.jar:3.0.2]
	at org.springframework.cloud.function.json.JacksonMapper.doFromJson(JacksonMapper.java:63) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	... 45 common frames omitted

2025-12-03T19:55:41.860+03:00 DEBUG 2555 --- [test-service] [wWp6Ks6xYCujQ-1] o.s.c.f.c.config.JsonMessageConverter    : Failed to convert value: {"type":"TestEvent","originService":"publisher-service:dev:9001:4c6b4e19f6c5bb02658c43ba4b1043ec","key":"test-key","destinationService":"test-service:**","id":"eeb09fa5-d833-460d-a132-abfec9079283","timestamp":1764780936829} to: class org.springframework.cloud.bus.event.RemoteApplicationEvent

java.lang.IllegalStateException: Failed to convert. Possible bug as the conversion probably shouldn't have been attempted here
	at org.springframework.cloud.function.json.JacksonMapper.doFromJson(JacksonMapper.java:73) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.json.JsonMapper.fromJson(JsonMapper.java:81) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.config.JsonMessageConverter.convertFromInternal(JsonMessageConverter.java:109) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.messaging.converter.AbstractMessageConverter.fromMessage(AbstractMessageConverter.java:179) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.converter.AbstractMessageConverter.fromMessage(AbstractMessageConverter.java:171) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.cloud.function.context.config.SmartCompositeMessageConverter.fromMessage(SmartCompositeMessageConverter.java:75) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.convertInputMessageIfNecessary(SimpleFunctionRegistry.java:1428) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.convertInputIfNecessary(SimpleFunctionRegistry.java:1180) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.doApply(SimpleFunctionRegistry.java:787) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.apply(SimpleFunctionRegistry.java:627) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.PartitionAwareFunctionWrapper.apply(PartitionAwareFunctionWrapper.java:92) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.FunctionConfiguration$FunctionWrapper.apply(FunctionConfiguration.java:830) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.cloud.stream.function.FunctionConfiguration$FunctionToDestinationBinder$1.handleMessageInternal(FunctionConfiguration.java:668) ~[spring-cloud-stream-5.0.0.jar:5.0.0]
	at org.springframework.integration.handler.AbstractMessageHandler.doHandleMessage(AbstractMessageHandler.java:102) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:70) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:133) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:150) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:123) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.sendInternal(AbstractMessageChannel.java:438) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.sendWithMetrics(AbstractMessageChannel.java:409) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:338) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:310) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:108) ~[spring-messaging-7.0.1.jar:7.0.1]
	at org.springframework.integration.endpoint.MessageProducerSupport.sendMessageWithTracking(MessageProducerSupport.java:278) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:267) ~[spring-integration-core-7.0.0.jar:7.0.0]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.access$000(AmqpInboundChannelAdapter.java:71) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$Listener.lambda$onMessage$0(AmqpInboundChannelAdapter.java:392) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.core.retry.RetryTemplate.execute(RetryTemplate.java:178) ~[spring-core-7.0.1.jar:7.0.1]
	at org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter$Listener.onMessage(AmqpInboundChannelAdapter.java:385) ~[spring-integration-amqp-7.0.0.jar:7.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1683) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1612) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1599) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1590) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListenerAndHandleException(AbstractMessageListenerContainer.java:1539) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.lambda$executeListener$1(AbstractMessageListenerContainer.java:1517) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at io.micrometer.observation.Observation.observe(Observation.java:499) ~[micrometer-observation-1.16.0.jar:1.16.0]
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1517) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:1116) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:1061) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.mainLoop(SimpleMessageListenerContainer.java:1465) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1359) ~[spring-rabbit-4.0.0.jar:4.0.0]
	at java.base/java.lang.Thread.run(Thread.java:1583) ~[na:na]
Caused by: tools.jackson.databind.exc.InvalidTypeIdException: Could not resolve type id 'TestEvent' as a subtype of `org.springframework.cloud.bus.event.RemoteApplicationEvent`: known type ids = []
 at [Source: REDACTED (`StreamReadFeature.INCLUDE_SOURCE_IN_LOCATION` disabled); byte offset: #8]
	at tools.jackson.databind.exc.InvalidTypeIdException.from(InvalidTypeIdException.java:41) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.DeserializationContext.invalidTypeIdException(DeserializationContext.java:2106) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.DeserializationContext.handleUnknownTypeId(DeserializationContext.java:1669) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.TypeDeserializerBase._handleUnknownTypeId(TypeDeserializerBase.java:279) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.TypeDeserializerBase._findDeserializer(TypeDeserializerBase.java:160) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId(AsPropertyTypeDeserializer.java:119) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject(AsPropertyTypeDeserializer.java:103) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.AbstractDeserializer.deserializeWithType(AbstractDeserializer.java:243) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.impl.TypeWrappedDeserializer.deserialize(TypeWrappedDeserializer.java:72) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.deser.DeserializationContextExt.readRootValue(DeserializationContextExt.java:265) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:2610) ~[jackson-databind-3.0.2.jar:3.0.2]
	at tools.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:1666) ~[jackson-databind-3.0.2.jar:3.0.2]
	at org.springframework.cloud.function.json.JacksonMapper.doFromJson(JacksonMapper.java:63) ~[spring-cloud-function-context-5.0.0.jar:5.0.0]
	... 45 common frames omitted

[EmirBoyaci]

I just tested again by downgrading spring-boot to 3.5.7 and spring-cloud to 2025.0.0, and here are the debug logs as well. At the end of the logs you will see that remote event from bus actually mapped to TestEvent which is the expected case.

2025-12-03T20:08:48.593+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] o.s.a.r.listener.BlockingQueueConsumer   : Received message: (Body:'[B@435e16d8(byte[235])' MessageProperties [headers={}, timestamp=Wed Dec 03 20:08:48 TRT 2025, messageId=be719313-27dc-d029-d05d-aa3b4e6ac0d9, contentType=application/json, contentLength=0, receivedDeliveryMode=PERSISTENT, priority=0, redelivered=false, receivedExchange=springCloudBus, receivedRoutingKey=springCloudBus, deliveryTag=1, consumerTag=amq.ctag-2-0KqfXQzCNqqLB_frvUqg, consumerQueue=springCloudBus.anonymous.8edHO2jmTvG7G4misG8oaQ])
2025-12-03T20:08:48.602+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] s.i.m.AbstractHeaderMapper$HeaderMatcher : headerName=[amqp_receivedDeliveryMode] WILL be mapped, matched pattern=*
2025-12-03T20:08:48.602+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] s.i.m.AbstractHeaderMapper$HeaderMatcher : headerName=[amqp_receivedRoutingKey] WILL be mapped, matched pattern=*
2025-12-03T20:08:48.602+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] s.i.m.AbstractHeaderMapper$HeaderMatcher : headerName=[amqp_receivedExchange] WILL be mapped, matched pattern=*
2025-12-03T20:08:48.602+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] s.i.m.AbstractHeaderMapper$HeaderMatcher : headerName=[amqp_deliveryTag] WILL be mapped, matched pattern=*
2025-12-03T20:08:48.602+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] s.i.m.AbstractHeaderMapper$HeaderMatcher : headerName=[amqp_timestamp] WILL be mapped, matched pattern=*
2025-12-03T20:08:48.602+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] s.i.m.AbstractHeaderMapper$HeaderMatcher : headerName=[amqp_messageId] WILL be mapped, matched pattern=*
2025-12-03T20:08:48.602+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] s.i.m.AbstractHeaderMapper$HeaderMatcher : headerName=[amqp_redelivered] WILL be mapped, matched pattern=*
2025-12-03T20:08:48.602+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] s.i.m.AbstractHeaderMapper$HeaderMatcher : headerName=[amqp_retryCount] WILL be mapped, matched pattern=*
2025-12-03T20:08:48.602+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] s.i.m.AbstractHeaderMapper$HeaderMatcher : headerName=[contentType] WILL be mapped, matched pattern=*
2025-12-03T20:08:48.604+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] o.s.retry.support.RetryTemplate          : Retry: count=0
2025-12-03T20:08:48.604+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] o.s.c.s.m.DirectWithAttributesChannel    : preSend on channel 'bean 'springCloudBusInput'', message: GenericMessage [payload=byte[235], headers={amqp_receivedDeliveryMode=PERSISTENT, amqp_receivedExchange=springCloudBus, amqp_deliveryTag=1, deliveryAttempt=1, amqp_consumerQueue=springCloudBus.anonymous.8edHO2jmTvG7G4misG8oaQ, amqp_redelivered=false, amqp_receivedRoutingKey=springCloudBus, amqp_timestamp=Wed Dec 03 20:08:48 TRT 2025, amqp_messageId=be719313-27dc-d029-d05d-aa3b4e6ac0d9, amqp_retryCount=0, id=4f24c146-8f3f-2c3b-5011-c2aed16fd6ac, amqp_consumerTag=amq.ctag-2-0KqfXQzCNqqLB_frvUqg, sourceData=(Body:'[B@435e16d8(byte[235])' MessageProperties [headers={}, timestamp=Wed Dec 03 20:08:48 TRT 2025, messageId=be719313-27dc-d029-d05d-aa3b4e6ac0d9, contentType=application/json, contentLength=0, receivedDeliveryMode=PERSISTENT, priority=0, redelivered=false, receivedExchange=springCloudBus, receivedRoutingKey=springCloudBus, deliveryTag=1, consumerTag=amq.ctag-2-0KqfXQzCNqqLB_frvUqg, consumerQueue=springCloudBus.anonymous.8edHO2jmTvG7G4misG8oaQ]), contentType=application/json, timestamp=1764781728603}]
2025-12-03T20:08:48.605+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] figuration$FunctionToDestinationBinder$1 : org.springframework.cloud.stream.function.FunctionConfiguration$FunctionToDestinationBinder$1@70446d5b received message: GenericMessage [payload=byte[235], headers={amqp_receivedDeliveryMode=PERSISTENT, amqp_receivedExchange=springCloudBus, amqp_deliveryTag=1, deliveryAttempt=1, amqp_consumerQueue=springCloudBus.anonymous.8edHO2jmTvG7G4misG8oaQ, amqp_redelivered=false, amqp_receivedRoutingKey=springCloudBus, amqp_timestamp=Wed Dec 03 20:08:48 TRT 2025, amqp_messageId=be719313-27dc-d029-d05d-aa3b4e6ac0d9, amqp_retryCount=0, id=4f24c146-8f3f-2c3b-5011-c2aed16fd6ac, amqp_consumerTag=amq.ctag-2-0KqfXQzCNqqLB_frvUqg, sourceData=(Body:'[B@435e16d8(byte[235])' MessageProperties [headers={}, timestamp=Wed Dec 03 20:08:48 TRT 2025, messageId=be719313-27dc-d029-d05d-aa3b4e6ac0d9, contentType=application/json, contentLength=0, receivedDeliveryMode=PERSISTENT, priority=0, redelivered=false, receivedExchange=springCloudBus, receivedRoutingKey=springCloudBus, deliveryTag=1, consumerTag=amq.ctag-2-0KqfXQzCNqqLB_frvUqg, consumerQueue=springCloudBus.anonymous.8edHO2jmTvG7G4misG8oaQ]), contentType=application/json, timestamp=1764781728603}]
2025-12-03T20:08:48.605+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] c.f.c.c.BeanFactoryAwareFunctionRegistry : Invoking function busConsumer<class org.springframework.cloud.bus.event.RemoteApplicationEvent, null>
2025-12-03T20:08:48.606+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] c.f.c.c.BeanFactoryAwareFunctionRegistry : Invoking function busConsumer<class org.springframework.cloud.bus.event.RemoteApplicationEvent, null>
2025-12-03T20:08:48.624+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] c.f.c.c.BeanFactoryAwareFunctionRegistry : Converted Message: GenericMessage [payload=byte[235], headers={amqp_receivedDeliveryMode=PERSISTENT, amqp_receivedExchange=springCloudBus, amqp_deliveryTag=1, deliveryAttempt=1, amqp_consumerQueue=springCloudBus.anonymous.8edHO2jmTvG7G4misG8oaQ, amqp_redelivered=false, amqp_receivedRoutingKey=springCloudBus, amqp_timestamp=Wed Dec 03 20:08:48 TRT 2025, amqp_messageId=be719313-27dc-d029-d05d-aa3b4e6ac0d9, amqp_retryCount=0, id=4f24c146-8f3f-2c3b-5011-c2aed16fd6ac, amqp_consumerTag=amq.ctag-2-0KqfXQzCNqqLB_frvUqg, sourceData=(Body:'[B@435e16d8(byte[235])' MessageProperties [headers={}, timestamp=Wed Dec 03 20:08:48 TRT 2025, messageId=be719313-27dc-d029-d05d-aa3b4e6ac0d9, contentType=application/json, contentLength=0, receivedDeliveryMode=PERSISTENT, priority=0, redelivered=false, receivedExchange=springCloudBus, receivedRoutingKey=springCloudBus, deliveryTag=1, consumerTag=amq.ctag-2-0KqfXQzCNqqLB_frvUqg, consumerQueue=springCloudBus.anonymous.8edHO2jmTvG7G4misG8oaQ]), contentType=application/json, timestamp=1764781728603}] to: class org.test.model.event.TestEvent
2025-12-03T20:08:48.624+03:00 DEBUG 3438 --- [test-service] [vG7G4misG8oaQ-1] o.springframework.cloud.bus.BusConsumer  : Received remote event from bus: TestEvent(key=test-key)

[olegz]

@EmirBoyaci Unfortunately your log does not include any messages where payload can be clearly seen.
The issue is definitely related to migration from Jackson 2 to Jackson 3. It is also clear that the JSON payload is at the root of an issue, but i can't do much nor can I create a test without such json. So please let me know when you can supply one

[EmirBoyaci]

@olegz if you were asking JSON payload of the message received and tried to covert, it was available in the 1st log. Please see below isolated log line which includes JSON payload of the message received:

2025-12-03T19:55:41.860+03:00 DEBUG 2555 --- [test-service] [wWp6Ks6xYCujQ-1] o.s.c.f.c.config.JsonMessageConverter    : Failed to convert value: {"type":"TestEvent","originService":"publisher-service:dev:9001:4c6b4e19f6c5bb02658c43ba4b1043ec","key":"test-key","destinationService":"test-service:**","id":"eeb09fa5-d833-460d-a132-abfec9079283","timestamp":1764780936829} to: class org.springframework.cloud.bus.event.RemoteApplicationEvent

[olegz]

This is beautiful and exactly what I was looking for as I was able to reproduce the error

java.lang.IllegalStateException: Failed to convert. Possible bug as the conversion probably shouldn't have been attempted here

	at org.springframework.cloud.function.json.JacksonMapper.doFromJson(JacksonMapper.java:73)
	at org.springframework.cloud.function.json.JsonMapper.fromJson(JsonMapper.java:81)
	at org.springframework.cloud.function.context.catalog.BeanFactoryAwareFunctionRegistryTests.testEmptyPojoConversion(BeanFactoryAwareFunctionRegistryTests.java:124)
Caused by: tools.jackson.databind.exc.InvalidTypeIdException: Could not resolve type id 'TestEvent' as a subtype of `org.springframework.cloud.function.context.catalog.BeanFactoryAwareFunctionRegistryTests$TestEvent`: known type ids = [BeanFactoryAwareFunctionRegistryTests$TestEvent]
 at [Source: REDACTED (`StreamReadFeature.INCLUDE_SOURCE_IN_LOCATION` disabled); byte offset: #UNKNOWN]
	at tools.jackson.databind.exc.InvalidTypeIdException.from(InvalidTypeIdException.java:41)
	at tools.jackson.databind.DeserializationContext.invalidTypeIdException(DeserializationContext.java:2106)
	at tools.jackson.databind.DeserializationContext.handleUnknownTypeId(DeserializationContext.java:1669)
	at tools.jackson.databind.jsontype.impl.TypeDeserializerBase._handleUnknownTypeId(TypeDeserializerBase.java:279)
	at tools.jackson.databind.jsontype.impl.TypeDeserializerBase._findDeserializer(TypeDeserializerBase.java:160)
	at tools.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId(AsPropertyTypeDeserializer.java:119)
	at tools.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject(AsPropertyTypeDeserializer.java:103)
	at tools.jackson.databind.deser.bean.BeanDeserializerBase.deserializeWithType(BeanDeserializerBase.java:1307)
	at tools.jackson.databind.deser.impl.TypeWrappedDeserializer.deserialize(TypeWrappedDeserializer.java:72)
	at tools.jackson.databind.deser.DeserializationContextExt.readRootValue(DeserializationContextExt.java:265)
	at tools.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:2610)
	at tools.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:1564)
	at org.springframework.cloud.function.json.JacksonMapper.doFromJson(JacksonMapper.java:60)
	... 2 more

Let me work on fixing it