fr33m0nk.alpakka-kafka.transactional
Akka Stream connector to support transactions between Kafka topics.
Akka Stream connector to support transactions between Kafka topics.
->transactional-sinkclj
(->transactional-sink producer-settings transactional-id)Sink that is aware of the ConsumerMessage.TransactionalMessage.partitionOffset from a Transactional.source. It will initialize, begin, produce, and commit the consumer offset as part of a transaction. https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Transactional$.html#sinkK,V,IN%3C:akka.kafka.ProducerMessage.Envelope[K,V,akka.kafka.ConsumerMessage.PartitionOffset]:akka.stream.javadsl.Sink[IN,java.util.concurrent.CompletionStage[akka.Done]]
Sink that is aware of the ConsumerMessage.TransactionalMessage.partitionOffset from a Transactional.source. It will initialize, begin, produce, and commit the consumer offset as part of a transaction. https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Transactional$.html#sink[K,V,IN%3C:akka.kafka.ProducerMessage.Envelope[K,V,akka.kafka.ConsumerMessage.PartitionOffset]](settings:akka.kafka.ProducerSettings[K,V],transactionalId:String):akka.stream.javadsl.Sink[IN,java.util.concurrent.CompletionStage[akka.Done]]
->transactional-sourceclj
(->transactional-source consumer-settings topics)Transactional source to setup a stream for Exactly Only Once (EoS) kafka message semantics. To enable EoS it's necessary to use the Transactional.sink or Transactional.flow (for passthrough). https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Transactional$.html#sourceK,V:akka.stream.javadsl.Source[akka.kafka.ConsumerMessage.TransactionalMessage[K,V],akka.kafka.javadsl.Consumer.Control]
Transactional source to setup a stream for Exactly Only Once (EoS) kafka message semantics. To enable EoS it's necessary to use the Transactional.sink or Transactional.flow (for passthrough). https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Transactional$.html#source[K,V](consumerSettings:akka.kafka.ConsumerSettings[K,V],subscription:akka.kafka.Subscription):akka.stream.javadsl.Source[akka.kafka.ConsumerMessage.TransactionalMessage[K,V],akka.kafka.javadsl.Consumer.Control]
transactional-flowclj
(transactional-flow producer-settings transactional-id)Publish records to Kafka topics and then continue the flow. The flow can only be used with a Transactional.source that emits a ConsumerMessage.TransactionalMessage. The flow requires a unique transactional.id across all app instances. The flow will override producer properties to enable Kafka exactly-once transactional support. https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Transactional$.html#flowK,V,IN%3C:akka.kafka.ProducerMessage.Envelope[K,V,akka.kafka.ConsumerMessage.PartitionOffset]:akka.stream.javadsl.Flow[IN,akka.kafka.ProducerMessage.Results[K,V,akka.kafka.ConsumerMessage.PartitionOffset],akka.NotUsed]
Publish records to Kafka topics and then continue the flow. The flow can only be used with a Transactional.source that emits a ConsumerMessage.TransactionalMessage. The flow requires a unique transactional.id across all app instances. The flow will override producer properties to enable Kafka exactly-once transactional support. https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Transactional$.html#flow[K,V,IN%3C:akka.kafka.ProducerMessage.Envelope[K,V,akka.kafka.ConsumerMessage.PartitionOffset]](settings:akka.kafka.ProducerSettings[K,V],transactionalId:String):akka.stream.javadsl.Flow[IN,akka.kafka.ProducerMessage.Results[K,V,akka.kafka.ConsumerMessage.PartitionOffset],akka.NotUsed]
transactional-flow-with-offset-contextclj
(transactional-flow-with-offset-context producer-settings transactional-id)https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Transactional$.html#flowWithOffsetContextK,V:akka.stream.javadsl.FlowWithContext[akka.kafka.ProducerMessage.Envelope[K,V,akka.NotUsed],akka.kafka.ConsumerMessage.PartitionOffset,akka.kafka.ProducerMessage.Results[K,V,akka.kafka.ConsumerMessage.PartitionOffset],akka.kafka.ConsumerMessage.PartitionOffset,akka.NotUsed]
https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Transactional$.html#flowWithOffsetContext[K,V](settings:akka.kafka.ProducerSettings[K,V],transactionalId:String):akka.stream.javadsl.FlowWithContext[akka.kafka.ProducerMessage.Envelope[K,V,akka.NotUsed],akka.kafka.ConsumerMessage.PartitionOffset,akka.kafka.ProducerMessage.Results[K,V,akka.kafka.ConsumerMessage.PartitionOffset],akka.kafka.ConsumerMessage.PartitionOffset,akka.NotUsed]
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close