search

spring-cloud / spring-cloud-stream

Framework for building Event-Driven Microservices
http://cloud.spring.io/spring-cloud-stream
Apache License 2.0
987 stars 602 forks source link

Acknowledgement for Sending Message #151

Closed VikasJindal84 closed 8 years ago

VikasJindal84 commented 8 years ago

Hi,

Currently there is no way to find out if Kafka message is successfully delivered . I tried to use MessageChannel.send , it always returns true ,even if zookeeper and kakfa server is down.

So, my requirement is to have a way to get a confirmation about delivery of message to kafka server.

mbogoevici commented 8 years ago

Hi Vikas,

Thanks for reporting this. Noted. This needs to be an enhancement to Spring Integration Kafka, as well as properly handling this inside Spring Cloud Stream.

Cheers, Marius

artembilan commented 8 years ago

Looks like this should be fixed together with the https://github.com/spring-projects/spring-integration-kafka/issues/62

mbogoevici commented 8 years ago

It would depend on it, but there is more to it than just that.

VikasJindal84 commented 8 years ago

Hi,

Now spring-integration-kafka has support for ProducerListener : https://github.com/spring-projects/spring-integration-kafka/commit/325d0b294c825252f5313bd9696229d198b0d38e

Any plan for providing support for ProducerListener in spring-cloud-stream-binder-kafka ?

mbogoevici commented 8 years ago

This is currently addressed by https://github.com/spring-cloud/spring-cloud-stream/issues/316

sabbyanandan commented 8 years ago

This is already addressed by spring-cloud/spring-cloud-stream#253, so closing this issue.