streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java (6 lines):
	- line 308: // TODO: we should lift this requirement in the future
	- line 619: // TODO: this method is only used by DSL and we might want to refactor this part
	- line 628: // TODO: this method is only used by DSL and we might want to refactor this part
	- line 644: // TODO: this method is only used by DSL and we might want to refactor this part
	- line 650: // TODO: this method is only used by DSL and we might want to refactor this part
	- line 1163: // TODO: we should check regex overlap at topology construction time and then throw TopologyException


connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java (4 lines):
	- line 324: } catch (WakeupException e) { // FIXME should not be WakeupException
	- line 1099: // TODO: As an optimization, some task config updates could avoid a rebalance. In particular, single-task
	- line 1222: // TODO: Technically we don't have to stop connectors at all until we know they've really been removed from
	- line 1231: // TODO: We need to at least commit task offsets, but if we could commit offsets & pause them instead of


release.py (4 lines):
	- line 229: # TODO promotion
	- line 403: # TODO: Many of these suggested validation steps could be automated and would help pre-validate a lot of the stuff voters test
	- line 415: * Build a sample against jars in the staging repo: (TODO: Can we get a temporary URL before "closing" the staged artifacts?)
	- line 436: # TODO: Can we get this closed via a REST API since we already need to collect credentials for this repo?


core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala (3 lines):
	- line 771: // TODO: add metrics for restabilize timeouts
	- line 779: // TODO: cut the socket connection to the client
	- line 842: // TODO: add metrics for complete heartbeats


core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala (2 lines):
	- line 555: // TODO: This need to be implemented when we support delete topic
	- line 1026: * TODO: Deleted topics are interesting (and will not be a concern until


clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java (2 lines):
	- line 147: // TODO write uncompressed content size, update flg.validate()
	- line 206: // TODO implement content checksum, update flg.validate()


core/src/main/scala/kafka/server/DynamicBrokerConfig.scala (2 lines):
	- line 192: // TODO (KAFKA-6246): encrypt passwords
	- line 222: // TODO (KAFKA-6246): encrypt passwords


connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java (2 lines):
	- line 303: // TODO: To get any real benefit from the backing store abstraction, we should move some of
	- line 316: // TODO: move connector configuration update handling here to be consistent with


clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java (2 lines):
	- line 231: // TODO this part of the logic should be removed once we allow regex on leader assign
	- line 370: // TODO: this is a hack and not something we want to support long-term unless we push regex into the protocol


core/src/main/scala/kafka/server/ReplicaManager.scala (2 lines):
	- line 1141: *  TODO: the above may need to be fixed later
	- line 1240: // TODO: Delete leaders from LeaderAndIsrRequest


connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java (1 line):
	- line 64: // TODO: This should not be so long. However, due to potentially long rebalances that may have to wait a full


core/src/main/scala/kafka/tools/SimpleConsumerPerformance.scala (1 line):
	- line 68: // TODO: add in the maxWait and minBytes for performance


connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java (1 line):
	- line 150: // FIXME Kafka needs to add a timeout parameter here for us to properly obey the timeout


streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java (1 line):
	- line 145: // TODO: currently we cannot get the full topic configurations and hence cannot allow topic configs without the prefix,


core/src/main/scala/kafka/security/auth/Acl.scala (1 line):
	- line 92: * TODO: Ideally we would have a symmetric toJson method but our current json library can not jsonify/dejsonify complex objects.


core/src/main/scala/kafka/server/KafkaApis.scala (1 line):
	- line 1603: // TODO: The current append API makes doing separate writes per producerId a little easier, but it would


streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java (1 line):
	- line 50: // TODO: when we have serde associated with class types, we can


clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java (1 line):
	- line 163: in.getInt(); // TODO: verify this content checksum


streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (1 line):
	- line 56: // TODO: change to package-private after removing KStreamBuilder


core/src/main/scala/kafka/coordinator/transaction/DelayedTxnMarker.scala (1 line):
	- line 46: // TODO: if we will always return NONE upon completion, we can remove the error code in the param


core/src/main/scala/kafka/tools/StreamsResetter.java (1 line):
	- line 212: // TODO: deprecated in 1.0; can be removed eventually


clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java (1 line):
	- line 367: // TODO: introspect about e: look for GSS information.


connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java (1 line):
	- line 90: // TODO: improve once plugins are allowed to be added/removed during runtime.


streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java (1 line):
	- line 54: // TODO: this map does not work with customized grouper where multiple partitions


streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java (1 line):
	- line 60: private boolean restoring = false;      // TODO: this is a sub-optimal solution to avoid logging during restoration.


clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java (1 line):
	- line 208: //TODO Find a way to avoid using these proprietary classes as access to Java 9 will block access by default


tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java (1 line):
	- line 188: // TODO: eventually think about putting tasks into a bad state as a result of


streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java (1 line):
	- line 200: // TODO: support TTL with change log?


connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java (1 line):
	- line 47: // TODO: Currently we only support top-level field casting. Ideally we could use a dotted notation in the spec to


core/src/main/scala/kafka/consumer/SimpleConsumer.scala (1 line):
	- line 161: // TODO: With KAFKA-1012, we have to first issue a ConsumerMetadataRequest and connect to the coordinator before


clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java (1 line):
	- line 153: // TODO: we can also serializes objects of type T using generic Java serialization by default


connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java (1 line):
	- line 134: // TODO: once versioning is enabled this line should be moved outside this if branch


streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java (1 line):
	- line 786: // TODO: In the future if we lift this restriction this code path could then be triggered and be updated


core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala (1 line):
	- line 846: // TODO: clear the caches


streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractStateManager.java (1 line):
	- line 82: // TODO remove this eventually


streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java (1 line):
	- line 174: final OffsetAndMetadata metadata = consumer.committed(partition); // TODO: batch API?


core/src/main/scala/kafka/controller/PartitionStateMachine.scala (1 line):
	- line 107: // TODO: If handleStateChanges catches an exception, it is not enough to bail out and log an error.


core/src/main/scala/kafka/controller/KafkaController.scala (1 line):
	- line 739: // TODO: Eventually partition reassignment could use a callback that does retries if deletion failed


streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (1 line):
	- line 57: // TODO: these two fields can be package-private after KStreamBuilder is removed


clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java (1 line):
	- line 84: // TODO: Rebalance callbacks


streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java (1 line):
	- line 673: * // TODO: this is a duplicate of the InternalTopologyBuilder#SubscriptionUpdates


core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala (1 line):
	- line 235: // TODO: decide if ids should be predictable or random


core/src/main/scala/kafka/tools/MirrorMaker.scala (1 line):
	- line 601: // TODO: we need to manually maintain the consumed offsets for new consumer