src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkTask.java (3 lines):
	- line 71: // TODO we should check ingestor role differently
	- line 236: // TODO check this for managed identity
	- line 390: // TODO: if we still get duplicates from rebalance - consider keeping writers


src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java (1 line):
	- line 27: // TODO: this might need to be per kusto cluster...


src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/TopicPartitionWriter.java (1 line):
	- line 124: // TODO : improve handling of specific transient exceptions once the client supports them.