Dynamic destinations don't work with a transactional binder #626
Assignees
Labels
Comments
sobychacko
added a commit
to sobychacko/spring-cloud-stream-binder-kafka
that referenced
this issue
Apr 8, 2019
With a transactional binder, the producer factory should not be destroyed. Resolves spring-cloud#626
garyrussell
pushed a commit
that referenced
this issue
Apr 8, 2019
With a transactional binder, the producer factory should not be destroyed. Resolves #626
garyrussell
pushed a commit
that referenced
this issue
Apr 8, 2019
With a transactional binder, the producer factory should not be destroyed. Resolves #626
garyrussell
pushed a commit
that referenced
this issue
Apr 8, 2019
With a transactional binder, the producer factory should not be destroyed. Resolves #626
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
In
createProducerMessageHandler()when creating a producer message handler, the binder creates a temporary producer to get information about the topic.It then destroys the producer factory to close the (normally) single-shared producer object
However, it should not destroy the factory when the binder is transactional since the producer factory is shared.
See https://stackoverflow.com/questions/55498015/spring-cloud-stream-kafka-consumer-producer-api-exactly-once-semantics-transact
The text was updated successfully, but these errors were encountered: