Summary: 62 instances, 58 unique

Text	Count
// TODO: we need to manually maintain the consumed offsets for new consumer	1
// TODO: when we have serde associated with class types, we can	1
// TODO: move connector configuration update handling here to be consistent with	1
* TODO: Ideally we would have a symmetric toJson method but our current json library can not jsonify/dejsonify complex objects.	1
// TODO: improve once plugins are allowed to be added/removed during runtime.	1
// TODO: once versioning is enabled this line should be moved outside this if branch	1
// TODO: Rebalance callbacks	1
# TODO promotion	1
// TODO: this is a hack and not something we want to support long-term unless we push regex into the protocol	1
// TODO: Currently we only support top-level field casting. Ideally we could use a dotted notation in the spec to	1
// TODO: add in the maxWait and minBytes for performance	1
// TODO: This need to be implemented when we support delete topic	1
# TODO: Can we get this closed via a REST API since we already need to collect credentials for this repo?	1
// TODO: As an optimization, some task config updates could avoid a rebalance. In particular, single-task	1
// TODO implement content checksum, update flg.validate()	1
// TODO: deprecated in 1.0; can be removed eventually	1
// FIXME Kafka needs to add a timeout parameter here for us to properly obey the timeout	1
// TODO remove this eventually	1
// TODO: this map does not work with customized grouper where multiple partitions	1
* Build a sample against jars in the staging repo: (TODO: Can we get a temporary URL before "closing" the staged artifacts?)	1
*  TODO: the above may need to be fixed later	1
// TODO: this method is only used by DSL and we might want to refactor this part	4
//TODO Find a way to avoid using these proprietary classes as access to Java 9 will block access by default	1
} catch (WakeupException e) { // FIXME should not be WakeupException	1
// TODO: In the future if we lift this restriction this code path could then be triggered and be updated	1
// TODO this part of the logic should be removed once we allow regex on leader assign	1
// TODO: clear the caches	1
// TODO: add metrics for complete heartbeats	1
// TODO: Eventually partition reassignment could use a callback that does retries if deletion failed	1
// TODO: we can also serializes objects of type T using generic Java serialization by default	1
// TODO: To get any real benefit from the backing store abstraction, we should move some of	1
// TODO: currently we cannot get the full topic configurations and hence cannot allow topic configs without the prefix,	1
// TODO: introspect about e: look for GSS information.	1
// TODO: add metrics for restabilize timeouts	1
// TODO: With KAFKA-1012, we have to first issue a ConsumerMetadataRequest and connect to the coordinator before	1
// TODO: if we will always return NONE upon completion, we can remove the error code in the param	1
// TODO: This should not be so long. However, due to potentially long rebalances that may have to wait a full	1
// TODO: support TTL with change log?	1
* TODO: Deleted topics are interesting (and will not be a concern until	1
// TODO (KAFKA-6246): encrypt passwords	2
private boolean restoring = false;      // TODO: this is a sub-optimal solution to avoid logging during restoration.	1
// TODO: these two fields can be package-private after KStreamBuilder is removed	1
// TODO: We need to at least commit task offsets, but if we could commit offsets & pause them instead of	1
# TODO: Many of these suggested validation steps could be automated and would help pre-validate a lot of the stuff voters test	1
// TODO: eventually think about putting tasks into a bad state as a result of	1
// TODO: change to package-private after removing KStreamBuilder	1
* // TODO: this is a duplicate of the InternalTopologyBuilder#SubscriptionUpdates	1
final OffsetAndMetadata metadata = consumer.committed(partition); // TODO: batch API?	1
// TODO write uncompressed content size, update flg.validate()	1
// TODO: The current append API makes doing separate writes per producerId a little easier, but it would	1
// TODO: Delete leaders from LeaderAndIsrRequest	1
// TODO: we should lift this requirement in the future	1
// TODO: we should check regex overlap at topology construction time and then throw TopologyException	1
// TODO: decide if ids should be predictable or random	1
// TODO: cut the socket connection to the client	1
// TODO: Technically we don't have to stop connectors at all until we know they've really been removed from	1
// TODO: If handleStateChanges catches an exception, it is not enough to bail out and log an error.	1
in.getInt(); // TODO: verify this content checksum	1