Path	Lines of Code
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java	965
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java	1203
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchRequestManager.java	108
clients/src/main/java/org/apache/kafka/common/compress/Lz4BlockInputStream.java	209
clients/src/main/java/org/apache/kafka/common/compress/Lz4BlockOutputStream.java	249
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java	195
clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java	194
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java	214
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncWriter.java	147
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java	1718
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java	754
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java	2304
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java	729
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java	403
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java	137
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java	503
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java	556
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java	413
core/src/main/java/kafka/server/share/SharePartition.java	2060
core/src/main/scala/kafka/cluster/Partition.scala	1320
core/src/main/scala/kafka/server/AbstractFetcherThread.scala	680
core/src/main/scala/kafka/server/BrokerServer.scala	642
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala	851
core/src/main/scala/kafka/server/KafkaApis.scala	3343
core/src/main/scala/kafka/server/ReplicaManager.scala	2203
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala	246
generator/src/main/java/org/apache/kafka/message/checker/Unifier.java	149
metadata/src/main/java/org/apache/kafka/image/ClientQuotasImage.java	152
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java	3122
release/release.py	237
release/templates.py	18
shell/src/main/java/org/apache/kafka/shell/glob/GlobComponent.java	135
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCache.java	184
storage/src/main/java/org/apache/kafka/storage/internals/log/LogOffsetMetadata.java	60
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java	1371
streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java	284
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java	242
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java	536
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java	206
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java	312
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java	205
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java	192
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java	125
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java	236
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java	955
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java	444
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java	1852
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java	592
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java	37
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java	131
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java	25
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java	92
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java	789
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java	1027
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java	1511
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java	1257
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java	103
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadata.java	103
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java	218
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java	1727
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java	262
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java	829
streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java	244
streams/src/main/java/org/apache/kafka/streams/state/internals/CachedStateStore.java	7
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingListValueBytesStore.java	25
streams/src/main/java/org/apache/kafka/streams/state/internals/ListValueStore.java	111
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java	164
trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java	237