Class FenceProducersResult

    • Method Detail

      • fencedProducers

        public Map<String,​KafkaFuture<Void>> fencedProducers()
        Return a map from transactional ID to futures which can be used to check the status of individual fencings.
      • producerId

        public KafkaFuture<Long> producerId​(String transactionalId)
        Returns a future that provides the producer ID generated while initializing the given transaction when the request completes.
      • epochId

        public KafkaFuture<Short> epochId​(String transactionalId)
        Returns a future that provides the epoch ID generated while initializing the given transaction when the request completes.
      • all

        public KafkaFuture<Void> all()
        Return a future which succeeds only if all the producer fencings succeed.