Skip to content

Consistent Region Support for Messaging Toolkit

Jump to bottom Edit New page
Samantha Chan edited this page Jan 7, 2015 · 14 revisions

This documents describes the design of consistent region for each of the operators in the Messaging Toolkit.

Kafka

  • KafkaProducer will not be allowed at the beginning of a consistent region

[Samantha:] Is the operator doing anything special on drain, checkpoint, reset and resetToInitialState? What can the user expect from message delivery perspective ?

  • KafkaConsumer will not be allowed in a consistent region. It is technically possible to use a low level Kafka API and support some sort of replaying of data for consistent regions, however Kafka documentation mentions that replay support will be added in the recommended high-level API sometime in the near future. Consistent region support can then be re-evaluated at that point

JMS

MQTT

Add a custom footer
Add a custom sidebar

Clone this wiki locally