pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java (1 line):
	- line 109: // TODO:- Figure out the metrics story for connectors


pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecord.java (1 line):
	- line 66: // TODO: support decoding KMS data here... should be fairly simple


pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data/TwitterRecord.java (1 line):
	- line 42: // TODO: Could use user or tweet ID as key here


pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java (1 line):
	- line 229: // TODO: should flush for each batch. not wait for a time for acked all.