I didn't realize there was a commitOffset() method on the high level consumer
(the code is abstracted by the Spring Integration classes).
Yes, this actually suits my needs and I was able to get it to work for my use
case.
Thank you very much - that was extremely helpful.
In case it's of any use
Hi Jun,
Thanks for taking a look at my issue and also for updating the future release
plan Wiki page.
My use case is to use Kafka as if it were a JMS provider (messaging use case).
I'm currently using Kafka 0.8.1.1 with Java and specifically the Spring
Integration Kafka Inbound Channel Adapter
Hi Jun,
Thanks for taking a look at my issue and also for updating the future release
plan Wiki page.
My use case is to use Kafka as if it were a JMS provider (messaging use case).
I'm currently using Kafka 0.8.1.1 with Java and specifically the Spring
Integration Kafka Inbound Channel Adapter
I've tried to search a bit for what the current status is for Kafka supporting
consumer transactions.
These links look to be the best indication of where things stand with that:
http://search-hadoop.com/m/4TaT4xeqNq1
https://cwiki.apache.org/confluence/display/KAFKA/Transactional+Messaging+in+Ka
