| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Kafka.Transaction
Description
Module to work wih Kafkas transactional producers.
Synopsis
- initTransactions :: MonadIO m => KafkaProducer -> Timeout -> m (Maybe KafkaError)
- beginTransaction :: MonadIO m => KafkaProducer -> m (Maybe KafkaError)
- commitTransaction :: MonadIO m => KafkaProducer -> Timeout -> m (Maybe TxError)
- abortTransaction :: MonadIO m => KafkaProducer -> Timeout -> m (Maybe KafkaError)
- commitOffsetMessageTransaction :: MonadIO m => KafkaProducer -> KafkaConsumer -> ConsumerRecord k v -> Timeout -> m (Maybe TxError)
- data TxError
- getKafkaError :: TxError -> KafkaError
- kafkaErrorIsFatal :: TxError -> Bool
- kafkaErrorIsRetriable :: TxError -> Bool
- kafkaErrorTxnRequiresAbort :: TxError -> Bool
Documentation
initTransactions :: MonadIO m => KafkaProducer -> Timeout -> m (Maybe KafkaError) Source #
Initialises Kafka for transactions
beginTransaction :: MonadIO m => KafkaProducer -> m (Maybe KafkaError) Source #
Begins a new transaction
commitTransaction :: MonadIO m => KafkaProducer -> Timeout -> m (Maybe TxError) Source #
Commits an existing transaction Pre-condition: there exists an open transaction, created with beginTransaction
abortTransaction :: MonadIO m => KafkaProducer -> Timeout -> m (Maybe KafkaError) Source #
Aborts an existing transaction Pre-condition: there exists an open transaction, created with beginTransaction
commitOffsetMessageTransaction :: MonadIO m => KafkaProducer -> KafkaConsumer -> ConsumerRecord k v -> Timeout -> m (Maybe TxError) Source #
Commits the message's offset in the current transaction Similar to Kafka.Consumer.commitOffsetMessage but within a transactional context Pre-condition: there exists an open transaction, created with beginTransaction
getKafkaError :: TxError -> KafkaError Source #
kafkaErrorIsFatal :: TxError -> Bool Source #
kafkaErrorIsRetriable :: TxError -> Bool Source #