Incremental Co-operative Rebalancing Support for HDFS Connector

[ghost]

kafka-connect-hdfs/src/main/java/io/confluent/connect/hdfs/DataWriter.java

Line 486 in bad81d6

topicPartitionWriters.clear();

Hi Team,
@ConfluentJenkins
Just wanted to know if the HDFS connector has the support for the "Incremental Rebalance". As I can see that "TopicPartitionWriters" Map is being cleared on every close call, which is correct if we consider the stop the world scenario. But in Incremental mode there can be case that only few of the partitions have been revoked and task has some partitions with it to read from, In that scenario it will be throwing NullPointerException at the following part of the code.

kafka-connect-hdfs/src/main/java/io/confluent/connect/hdfs/DataWriter.java

Line 364 in bad81d6

topicPartitionWriters.get(tp).buffer(record);