Skip to main content

All Questions

Filter by
Sorted by
Tagged with
2 votes
1 answer
6k views

org.springframework.messaging.MessagingException: nested Exception in java.lang.IllegalArgumentException

I'm facing a problem with arguments that are defined in sendGet Method, it receives stream as xml file from ftp server. For listening the coming stream I'm using Spring cloud stream by binding the ...
Mohamed Aoutir's user avatar
0 votes
1 answer
771 views

Spring Cloud Netflix & Spring Cloud Data Flow microservice arheticture

I'm developing an application that must both handle events coming from other systems and provide a REST API. I want to split the applications into micro services and I'm trying to figure out which ...
user avatar
0 votes
1 answer
1k views

AmqpConnectException: ConnectException: Connection refused: connect

Trying out Spring Cloud to send messages to RabbitMQ following a tutorial by Josh Long on Youtube. OS: Windows GIT URL: https://github.com/joshlong/bootiful-microservices/tree/master/bootiful-...
Anoop Hallimala's user avatar
1 vote
1 answer
1k views

Communication between microservices for large data

I am building a spring cloud-based microservice ML pipeline. I have a data ingestion service that (currently) takes in data from SQL, this data needs to be used by the prediction service. The general ...
Chintan Shah's user avatar
2 votes
1 answer
1k views

Spring Cloud Stream Kafka - Eventual consistency - Does Kafka auto retry unacknowledged messages (when using autocommitoffset=false)

Implementing an eventually consistent distributed architecture has turned out to be a pain. There are tons of blog posts telling stories about how to do it, but not showing (code) how to actually do ...
codependent's user avatar
  • 24.6k
2 votes
2 answers
3k views

Spring Cloud Stream Kafka - How to implement idempotency to support distributed transaction management (eventual consistency)

I have the following typical scenario: An order service used to purchase products. Acts as the commander of the distributed transaction. A product service with the list of products and its stock. A ...
codependent's user avatar
  • 24.6k
0 votes
1 answer
962 views

How to query the event repository in a microservice Event Sourcing architecture with Spring Cloud Stream Kafka

CLARIFICATION: Notice that this question is different form this one: How to implement a microservice Event Driven architecture with Spring Cloud Stream Kafka and Database per service This one is ...
codependent's user avatar
  • 24.6k
6 votes
2 answers
4k views

How to implement a microservice Event Driven architecture with Spring Cloud Stream Kafka and Database per service

I am trying to implement an event driven architecture to handle distributed transactions. Each service has its own database and uses Kafka to send messages to inform other microservices about the ...
codependent's user avatar
  • 24.6k