public void onPartitionsRevoked()

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

• 6 lines of code
• 2 McCabe index (conditional complexity)

  public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
    for (TopicPartition partition : partitions) {
      log.info("topic {} - partition {} revoked.", partition.topic(), partition.partition());
      rebalanceFlag.set(true);
    }
  }