protected void doRollback()

in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java [515:527]

• 13 lines of code
• 3 McCabe index (conditional complexity)

    protected void doRollback() throws InterruptedException {
      if (type.equals(TransactionType.NONE)) {
        return;
      }
      if (type.equals(TransactionType.PUT)) {
        producerRecords.get().clear();
        kafkaFutures.get().clear();
      } else {
        counter.addToRollbackCounter(events.get().size());
        consumerAndRecords.get().failedEvents.addAll(events.get());
        events.get().clear();
      }
    }