Hi,
Thanks! It should work now

I have already fixed that. Did you still get that error?

It should work fine now

I have already fixed some problems with the code. Did you still receive that error?

org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method could not be invoked with the incoming message
Endpoint handler details:
Method [public void pl.piomin.payment.PaymentApp.onEvent(pl.piomin.base.domain.Order)]
Bean [pl.piomin.payment.PaymentApp$$EnhancerBySpringCGLIB$$2e99b107@1c618295]; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [pl.piomin.base.domain.Order] for GenericMessage [payload={“id”:4,”customerId”:23,”productId”:10,”productCount”:5,”price”:100,”status”:”NEW”,”source”:null}, headers={kafka_offset=12, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@1354a24d, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedMessageKey=

I am trying to execute it with the following command:
java -jar payment-service-1.0-SNAPSHOT.jar

If you use Kafka Streams? It is fast and simple, and the results are stored in Kafka without the necessity of using an external db

I’m not sure if you are asking about this article or my other one about it. In fact here you have example with JPA https://piotrminkowski.com/2022/01/24/distributed-transactions-in-microservices-with-kafka-streams-and-spring-boot/, while here is KTable https://piotrminkowski.com/2022/02/07/deep-dive-into-saga-transactions-with-kafka-streams-and-spring-boot/