path	# lines of code	number of updates	days since first update	days since last update	first updated	last updated	
clients/src/main/java/org/apache/kafka/clients/RequestCompletionHandler.java	4	2	2071	1292	2015-01-11	2017-02-28
clients/src/main/java/org/apache/kafka/clients/producer/UniformStickyPartitioner.java	15	1	393	393	2019-08-16	2019-08-16
clients/src/main/java/org/apache/kafka/clients/producer/BufferExhaustedException.java	8	5	2410	154	2014-02-06	2020-04-11
clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java	57	13	2410	826	2014-02-06	2018-06-09
clients/src/main/java/org/apache/kafka/clients/producer/ProducerInterceptor.java	7	4	1677	1292	2016-02-09	2017-02-28
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java	374	40	2410	55	2014-02-06	2020-07-19
clients/src/main/java/org/apache/kafka/clients/producer/RoundRobinPartitioner.java	33	2	431	403	2019-07-09	2019-08-06
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java	1333	58	1234	31	2017-04-27	2020-08-12
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java	50	8	2410	670	2014-02-06	2018-11-12
clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java	23	8	1934	173	2015-05-28	2020-03-23
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java	319	27	1285	149	2017-03-07	2020-04-16
clients/src/main/java/org/apache/kafka/clients/producer/internals/SenderMetricsRegistry.java	171	6	1103	95	2017-09-05	2020-06-09
clients/src/main/java/org/apache/kafka/clients/producer/internals/IncompleteBatches.java	32	1	1184	1184	2017-06-16	2017-06-16
clients/src/main/java/org/apache/kafka/clients/producer/internals/StickyPartitionCache.java	47	2	408	397	2019-08-01	2019-08-12
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetrics.java	27	3	1103	949	2017-09-05	2018-02-06
clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java	216	23	2410	154	2014-02-06	2020-04-11
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java	657	121	2410	25	2014-02-06	2020-08-18
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetadata.java	109	6	555	215	2019-03-07	2020-02-10
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java	516	87	2410	70	2014-02-06	2020-07-04
clients/src/main/java/org/apache/kafka/clients/producer/internals/FutureRecordMetadata.java	84	12	2410	670	2014-02-06	2018-11-12
clients/src/main/java/org/apache/kafka/clients/producer/internals/ErrorLoggingCallback.java	33	6	2375	1272	2014-03-13	2017-03-20
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerInterceptors.java	68	5	1677	1206	2016-02-09	2017-05-25
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java	59	6	1234	233	2017-04-27	2020-01-23
clients/src/main/java/org/apache/kafka/clients/producer/Callback.java	4	6	2410	221	2014-02-06	2020-02-04
clients/src/main/java/org/apache/kafka/clients/producer/Producer.java	35	13	2410	234	2014-02-06	2020-01-22
clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java	95	16	2410	492	2014-02-06	2019-05-09
clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java	10	4	1934	408	2015-05-28	2019-08-01
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java	692	170	2410	44	2014-02-06	2020-07-30
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java	418	100	2410	19	2014-02-06	2020-08-24
clients/src/main/java/org/apache/kafka/clients/GroupRebalanceConfig.java	64	1	453	453	2019-06-17	2019-06-17
clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java	97	17	2286	734	2014-06-10	2018-09-09
clients/src/main/java/org/apache/kafka/clients/ClientUtils.java	97	28	2049	100	2015-02-02	2020-06-04
clients/src/main/java/org/apache/kafka/clients/ApiVersion.java	29	1	344	344	2019-10-04	2019-10-04
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java	137	37	2071	53	2015-01-11	2020-07-21
clients/src/main/java/org/apache/kafka/clients/ClientRequest.java	85	17	2286	25	2014-06-10	2020-08-18
clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java	138	11	1340	344	2017-01-11	2019-10-04
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsResult.java	18	3	1031	418	2017-11-16	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/PartitionReassignment.java	30	2	395	326	2019-08-14	2019-10-22
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersResult.java	40	3	472	173	2019-05-29	2020-03-23
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClientQuotasOptions.java	5	1	182	182	2020-03-14	2020-03-14
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenOptions.java	13	2	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsResult.java	82	3	1076	418	2017-10-02	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/DescribeDelegationTokenResult.java	15	2	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java	26	8	1229	52	2017-05-02	2020-07-22
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java	3377	128	1230	8	2017-05-01	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java	17	3	885	106	2018-04-11	2020-05-29
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java	92	9	885	443	2018-04-11	2019-06-27
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasResult.java	18	1	182	182	2020-03-14	2020-03-14
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult.java	16	3	885	218	2018-04-11	2020-02-07
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsOptions.java	24	3	1087	52	2017-09-21	2020-07-22
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsResult.java	18	4	1200	418	2017-05-31	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenOptions.java	13	2	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsOptions.java	26	8	1213	106	2017-05-18	2020-05-29
clients/src/main/java/org/apache/kafka/clients/admin/MemberToRemove.java	31	1	323	323	2019-10-25	2019-10-25
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java	222	11	418	8	2019-07-22	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsOptions.java	6	3	1076	418	2017-10-02	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/TopicDescription.java	55	10	1229	345	2017-05-02	2019-10-03
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java	35	5	1200	418	2017-05-31	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsResult.java	13	2	395	326	2019-08-14	2019-10-22
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptions.java	25	2	323	107	2019-10-25	2020-05-28
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult.java	59	1	328	328	2019-10-20	2019-10-20
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsResult.java	64	6	1200	418	2017-05-31	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialAlteration.java	11	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/ScramCredentialInfo.java	35	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsResult.java	16	4	1200	418	2017-05-31	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsOptions.java	18	7	1229	226	2017-05-02	2020-01-30
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java	68	5	1106	44	2017-09-02	2020-07-30
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialUpsertion.java	34	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsOptions.java	6	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java	83	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenResult.java	13	2	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsOptions.java	14	3	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsOptions.java	10	6	1213	226	2017-05-18	2020-01-30
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsOptions.java	10	6	1213	226	2017-05-18	2020-01-30
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsResult.java	18	1	395	395	2019-08-14	2019-08-14
clients/src/main/java/org/apache/kafka/clients/admin/NewTopic.java	102	10	1229	46	2017-05-02	2020-07-28
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsResult.java	17	2	1087	418	2017-09-21	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsOptions.java	6	1	395	395	2019-08-14	2019-08-14
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialDeletion.java	12	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialsDescription.java	38	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/ScramMechanism.java	30	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsOptions.java	10	6	1213	226	2017-05-18	2020-01-30
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersOptions.java	9	4	596	173	2019-01-25	2020-03-23
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsResult.java	18	4	1200	418	2017-05-31	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult.java	59	2	364	323	2019-09-14	2019-10-25
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsResult.java	64	2	328	86	2019-10-20	2020-06-18
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitionReassignment.java	16	4	395	312	2019-08-14	2019-11-05
clients/src/main/java/org/apache/kafka/clients/admin/OffsetSpec.java	24	4	328	86	2019-10-20	2020-06-18
clients/src/main/java/org/apache/kafka/clients/admin/TopicListing.java	19	4	1229	1185	2017-05-02	2017-06-15
clients/src/main/java/org/apache/kafka/clients/admin/MemberAssignment.java	32	4	885	492	2018-04-11	2019-05-09
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java	15	2	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java	151	7	856	283	2018-05-10	2019-12-04
clients/src/main/java/org/apache/kafka/clients/admin/internals/MetadataOperationContext.java	59	2	328	220	2019-10-20	2020-02-05
clients/src/main/java/org/apache/kafka/clients/admin/internals/ConsumerGroupOperationContext.java	50	1	328	328	2019-10-20	2019-10-20
clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java	11	25	1229	418	2017-05-02	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenResult.java	14	2	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/DeletedRecords.java	12	1	1031	1031	2017-11-16	2017-11-16
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsResult.java	22	6	1200	220	2017-05-31	2020-02-05
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersOptions.java	7	3	472	173	2019-05-29	2020-03-23
clients/src/main/java/org/apache/kafka/clients/admin/ReplicaInfo.java	28	1	44	44	2020-07-30	2020-07-30
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenResult.java	13	2	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/RecordsToDelete.java	31	3	1031	418	2017-11-16	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsOptions.java	17	2	328	173	2019-10-20	2020-03-23
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java	18	8	1213	74	2017-05-18	2020-06-30
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsResult.java	20	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java	77	2	323	107	2019-10-25	2020-05-28
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsOptions.java	5	1	395	395	2019-08-14	2019-08-14
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsOptions.java	6	2	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java	67	5	885	429	2018-04-11	2019-07-11
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java	18	7	1229	52	2017-05-02	2020-07-22
clients/src/main/java/org/apache/kafka/clients/admin/Config.java	38	4	1213	418	2017-05-18	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersResult.java	61	5	596	173	2019-01-25	2020-03-23
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitions.java	29	2	1087	418	2017-09-21	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/LogDirDescription.java	26	1	44	44	2020-07-30	2020-07-30
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java	17	8	1229	226	2017-05-02	2020-01-30
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsResult.java	18	3	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenOptions.java	24	2	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java	165	9	1213	106	2017-05-18	2020-05-29
clients/src/main/java/org/apache/kafka/clients/admin/DescribeDelegationTokenOptions.java	15	2	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsOptions.java	6	2	1031	418	2017-11-16	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsResult.java	19	4	1200	418	2017-05-31	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java	48	5	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsResult.java	26	3	1076	328	2017-10-02	2019-10-20
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java	31	7	1200	215	2017-05-31	2020-02-10
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsResult.java	34	4	885	418	2018-04-11	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java	175	20	1229	19	2017-05-02	2020-08-24
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasOptions.java	13	1	182	182	2020-03-14	2020-03-14
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsOptions.java	6	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsOptions.java	6	2	328	173	2019-10-20	2020-03-23
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsOptions.java	6	1	364	364	2019-09-14	2019-09-14
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsOptions.java	6	3	1106	418	2017-09-02	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/AbstractOptions.java	12	4	1106	226	2017-09-02	2020-01-30
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java	61	2	885	106	2018-04-11	2020-05-29
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsResult.java	35	5	1200	418	2017-05-31	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClientQuotasResult.java	15	1	182	182	2020-03-14	2020-03-14
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsOptions.java	17	7	1229	226	2017-05-02	2020-01-30
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsOptions.java	6	2	1076	418	2017-10-02	2019-07-22
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigOp.java	61	3	514	183	2019-04-17	2020-03-13
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsResult.java	65	6	1200	215	2017-05-31	2020-02-10
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java	273	28	2286	67	2014-06-10	2020-07-07
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java	144	6	604	215	2019-01-17	2020-02-10
clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java	45	9	1837	45	2015-09-02	2020-07-29
clients/src/main/java/org/apache/kafka/clients/StaleMetadataException.java	9	1	843	843	2018-05-23	2018-05-23
clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java	18	2	700	100	2018-10-13	2020-06-04
clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java	20	11	1837	283	2015-09-02	2019-12-04
clients/src/main/java/org/apache/kafka/clients/Metadata.java	369	46	2049	99	2015-02-02	2020-06-05
clients/src/main/java/org/apache/kafka/clients/ConnectionState.java	10	7	2286	885	2014-06-10	2018-04-11
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java	310	10	950	73	2018-02-05	2020-07-01
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java	903	110	2286	25	2014-06-10	2020-08-18
clients/src/main/java/org/apache/kafka/clients/ApiVersions.java	32	2	1268	1080	2017-03-24	2017-09-28
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndTimestamp.java	48	5	1445	734	2016-09-28	2018-09-09
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerInterceptor.java	9	6	1677	666	2016-02-09	2018-11-16
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java	50	7	1788	366	2015-10-21	2019-09-12
clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java	49	12	1788	287	2015-10-21	2019-11-30
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java	451	58	2307	103	2014-05-20	2020-06-01
clients/src/main/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignor.java	62	2	382	103	2019-08-27	2020-06-01
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.java	59	4	415	185	2019-07-25	2020-03-11
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java	76	13	2307	840	2014-05-20	2018-05-26
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java	66	29	2307	180	2014-05-20	2020-03-16
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsForLeaderEpochClient.java	98	7	510	57	2019-04-21	2020-07-17
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java	84	9	1788	409	2015-10-21	2019-07-31
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java	212	14	1788	364	2015-10-21	2019-09-14
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java	5	2	1886	1292	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java	1046	128	1788	2	2015-10-21	2020-09-10
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignorAdapter.java	93	2	409	382	2019-07-31	2019-08-27
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoOpConsumerRebalanceListener.java	10	3	1844	1292	2015-08-26	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java	795	65	2071	22	2015-01-11	2020-08-21
clients/src/main/java/org/apache/kafka/clients/consumer/internals/KafkaConsumerMetrics.java	61	3	331	247	2019-10-17	2020-01-09
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureAdapter.java	7	2	1886	1292	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java	691	6	382	39	2019-08-27	2020-08-04
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java	1432	162	2013	22	2015-03-10	2020-08-21
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetrics.java	26	2	1205	949	2017-05-26	2018-02-06
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java	94	14	2071	2	2015-01-11	2020-09-10
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetadata.java	56	3	555	232	2019-03-07	2020-01-24
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java	1047	109	1788	2	2015-10-21	2020-09-10
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java	136	12	1908	173	2015-06-23	2020-03-23
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureListener.java	5	2	1886	1292	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetcherMetricsRegistry.java	143	7	1205	436	2017-05-26	2019-07-04
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java	453	54	1886	25	2015-07-15	2020-08-18
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncClient.java	49	1	510	510	2019-04-21	2019-04-21
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java	63	13	1788	382	2015-10-21	2019-08-27
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptors.java	47	2	1677	1292	2016-02-09	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java	140	16	2307	511	2014-05-20	2019-04-20
clients/src/main/java/org/apache/kafka/clients/consumer/RetriableCommitFailedException.java	15	6	1592	247	2016-05-04	2020-01-09
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetCommitCallback.java	8	9	1828	242	2015-09-11	2020-01-14
clients/src/main/java/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java	25	4	2071	1223	2015-01-11	2017-05-08
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java	4	2	1908	1292	2015-06-23	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java	23	4	1770	86	2015-11-08	2020-06-18
clients/src/main/java/org/apache/kafka/clients/consumer/LogTruncationException.java	16	3	510	86	2019-04-21	2020-06-18
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndMetadata.java	59	7	1816	220	2015-09-23	2020-02-05
clients/src/main/java/org/apache/kafka/clients/consumer/StickyAssignor.java	96	12	1214	382	2017-05-17	2019-08-27
clients/src/main/java/org/apache/kafka/clients/consumer/InvalidOffsetException.java	10	2	1770	1292	2015-11-08	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java	879	228	2307	2	2014-05-20	2020-09-10
clients/src/main/java/org/apache/kafka/clients/consumer/CommitFailedException.java	16	6	1770	247	2015-11-08	2020-01-09
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java	11	14	1844	298	2015-08-26	2019-11-19
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java	119	4	415	213	2019-07-25	2020-02-12
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java	450	82	2307	19	2014-05-20	2020-08-24
clients/src/main/java/org/apache/kafka/clients/KafkaClient.java	37	24	2286	25	2014-06-10	2020-08-18
clients/src/main/java/org/apache/kafka/clients/NetworkClientUtils.java	59	4	1259	666	2017-04-02	2018-11-16
clients/src/main/java/org/apache/kafka/clients/ClientResponse.java	79	7	2286	831	2014-06-10	2018-06-04
clients/src/main/java/org/apache/kafka/server/authorizer/AclCreateResult.java	18	2	376	373	2019-09-02	2019-09-05
clients/src/main/java/org/apache/kafka/server/authorizer/AclDeleteResult.java	45	2	376	373	2019-09-02	2019-09-05
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizationResult.java	7	1	376	376	2019-09-02	2019-09-02
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java	18	3	376	103	2019-09-02	2020-06-01
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizerServerInfo.java	12	1	376	376	2019-09-02	2019-09-02
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizableRequestContext.java	19	3	376	25	2019-09-02	2020-08-18
clients/src/main/java/org/apache/kafka/server/authorizer/Action.java	68	1	376	376	2019-09-02	2019-09-02
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaType.java	7	2	890	52	2018-04-06	2020-07-22
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaCallback.java	14	1	890	890	2018-04-06	2018-04-06
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaEntity.java	15	2	890	734	2018-04-06	2018-09-09
clients/src/main/java/org/apache/kafka/server/policy/AlterConfigPolicy.java	27	2	1197	659	2017-06-03	2018-11-23
clients/src/main/java/org/apache/kafka/server/policy/CreateTopicPolicy.java	47	5	1338	659	2017-01-13	2018-11-23
clients/src/main/java/org/apache/kafka/common/metrics/MeasurableStat.java	3	4	2410	417	2014-02-06	2019-07-23
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java	24	10	2410	108	2014-02-06	2020-05-27
clients/src/main/java/org/apache/kafka/common/metrics/QuotaViolationException.java	36	7	2410	136	2014-02-06	2020-04-29
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetricsContext.java	18	2	108	99	2020-05-27	2020-06-05
clients/src/main/java/org/apache/kafka/common/metrics/MetricConfig.java	64	8	2410	239	2014-02-06	2020-01-17
clients/src/main/java/org/apache/kafka/common/metrics/Gauge.java	4	1	1080	1080	2017-09-28	2017-09-28
clients/src/main/java/org/apache/kafka/common/metrics/MetricsContext.java	8	1	108	108	2020-05-27	2020-05-27
clients/src/main/java/org/apache/kafka/common/metrics/Stat.java	4	6	2410	522	2014-02-06	2019-04-09
clients/src/main/java/org/apache/kafka/common/metrics/internals/IntGaugeSuite.java	184	1	281	281	2019-12-06	2019-12-06
clients/src/main/java/org/apache/kafka/common/metrics/internals/MetricsUtils.java	24	1	37	37	2020-08-06	2020-08-06
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java	64	12	2410	856	2014-02-06	2018-05-10
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java	268	23	2410	98	2014-02-06	2020-06-06
clients/src/main/java/org/apache/kafka/common/metrics/MetricValueProvider.java	2	1	1080	1080	2017-09-28	2017-09-28
clients/src/main/java/org/apache/kafka/common/metrics/Measurable.java	4	6	2410	1080	2014-02-06	2017-09-28
clients/src/main/java/org/apache/kafka/common/metrics/CompoundStat.java	21	5	2410	522	2014-02-06	2019-04-09
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentiles.java	109	13	2410	108	2014-02-06	2020-05-27
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentile.java	17	4	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/Avg.java	22	8	2410	662	2014-02-06	2018-11-20
clients/src/main/java/org/apache/kafka/common/metrics/stats/CumulativeCount.java	8	1	417	417	2019-07-23	2019-07-23
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java	44	1	37	37	2020-08-06	2020-08-06
clients/src/main/java/org/apache/kafka/common/metrics/stats/Count.java	4	7	2410	417	2014-02-06	2019-07-23
clients/src/main/java/org/apache/kafka/common/metrics/stats/WindowedCount.java	8	1	417	417	2019-07-23	2019-07-23
clients/src/main/java/org/apache/kafka/common/metrics/stats/Sum.java	4	2	1198	417	2017-06-02	2019-07-23
clients/src/main/java/org/apache/kafka/common/metrics/stats/SimpleRate.java	10	3	1458	133	2016-09-15	2020-05-02
clients/src/main/java/org/apache/kafka/common/metrics/stats/Max.java	22	7	2410	662	2014-02-06	2018-11-20
clients/src/main/java/org/apache/kafka/common/metrics/stats/Min.java	22	8	2410	662	2014-02-06	2018-11-20
clients/src/main/java/org/apache/kafka/common/metrics/stats/Meter.java	43	3	1093	417	2017-09-15	2019-07-23
clients/src/main/java/org/apache/kafka/common/metrics/stats/WindowedSum.java	19	1	417	417	2019-07-23	2019-07-23
clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java	47	14	2410	37	2014-02-06	2020-08-06
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java	87	9	2410	108	2014-02-06	2020-05-27
clients/src/main/java/org/apache/kafka/common/metrics/stats/Value.java	14	2	1338	1292	2017-01-13	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequencies.java	112	2	1082	1080	2017-09-26	2017-09-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/CumulativeSum.java	20	1	417	417	2019-07-23	2019-07-23
clients/src/main/java/org/apache/kafka/common/metrics/stats/Histogram.java	129	7	2410	133	2014-02-06	2020-05-02
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequency.java	16	1	1082	1082	2017-09-26	2017-09-26
clients/src/main/java/org/apache/kafka/common/metrics/stats/Total.java	4	6	2410	417	2014-02-06	2019-07-23
clients/src/main/java/org/apache/kafka/common/metrics/Quota.java	45	7	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java	222	32	2410	19	2014-02-06	2020-08-24
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java	329	36	2410	39	2014-02-06	2020-08-04
clients/src/main/java/org/apache/kafka/common/PartitionInfo.java	65	12	2410	683	2014-02-06	2018-10-30
clients/src/main/java/org/apache/kafka/common/Node.java	75	12	2410	492	2014-02-06	2019-05-09
clients/src/main/java/org/apache/kafka/common/MetricName.java	56	11	2070	269	2015-01-12	2019-12-18
clients/src/main/java/org/apache/kafka/common/ClusterResource.java	26	3	1456	604	2016-09-17	2019-01-17
clients/src/main/java/org/apache/kafka/common/record/AbstractRecords.java	102	17	1369	449	2016-12-13	2019-06-21
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java	486	40	1369	123	2016-12-13	2020-05-12
clients/src/main/java/org/apache/kafka/common/record/EndTransactionMarker.java	83	2	1225	348	2017-05-06	2019-09-30
clients/src/main/java/org/apache/kafka/common/record/BaseRecords.java	5	1	836	836	2018-05-30	2018-05-30
clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java	185	12	1369	492	2016-12-13	2019-05-09
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java	192	10	2049	284	2015-02-02	2019-12-03
clients/src/main/java/org/apache/kafka/common/record/CompressionRatioEstimator.java	58	2	1210	171	2017-05-21	2020-03-25
clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java	79	4	1268	492	2017-03-24	2019-05-09
clients/src/main/java/org/apache/kafka/common/record/Records.java	23	14	2410	836	2014-02-06	2018-05-30
clients/src/main/java/org/apache/kafka/common/record/LazyDownConversionRecordsSend.java	57	5	836	670	2018-05-30	2018-11-12
clients/src/main/java/org/apache/kafka/common/record/LegacyRecord.java	338	5	1268	348	2017-03-24	2019-09-30
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java	485	16	1268	348	2017-03-24	2019-09-30
clients/src/main/java/org/apache/kafka/common/record/MultiRecordsSend.java	89	3	836	136	2018-05-30	2020-04-29
clients/src/main/java/org/apache/kafka/common/record/RecordBatchIterator.java	21	1	1268	1268	2017-03-24	2017-03-24
clients/src/main/java/org/apache/kafka/common/record/RecordBatch.java	38	9	1268	1199	2017-03-24	2017-06-01
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java	270	10	2049	940	2015-02-02	2018-02-15
clients/src/main/java/org/apache/kafka/common/record/MutableRecordBatch.java	10	5	1268	449	2017-03-24	2019-06-21
clients/src/main/java/org/apache/kafka/common/record/RecordsSend.java	51	1	836	836	2018-05-30	2018-05-30
clients/src/main/java/org/apache/kafka/common/record/ByteBufferLogInputStream.java	47	8	1369	734	2016-12-13	2018-09-09
clients/src/main/java/org/apache/kafka/common/record/LazyDownConversionRecords.java	110	6	836	372	2018-05-30	2019-09-06
clients/src/main/java/org/apache/kafka/common/record/CompressionType.java	159	17	2410	703	2014-02-06	2018-10-10
clients/src/main/java/org/apache/kafka/common/record/PartialDefaultRecord.java	67	1	449	449	2019-06-21	2019-06-21
clients/src/main/java/org/apache/kafka/common/record/RecordConversionStats.java	34	1	836	836	2018-05-30	2018-05-30
clients/src/main/java/org/apache/kafka/common/record/ConvertedRecords.java	15	2	1080	836	2017-09-28	2018-05-30
clients/src/main/java/org/apache/kafka/common/record/TimestampType.java	21	6	1667	1268	2016-02-19	2017-03-24
clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java	5	4	1398	1268	2016-11-14	2017-03-24
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java	327	30	1398	157	2016-11-14	2020-04-08
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java	471	53	2410	372	2014-02-06	2019-09-06
clients/src/main/java/org/apache/kafka/common/record/RecordsUtil.java	87	3	836	449	2018-05-30	2019-06-21
clients/src/main/java/org/apache/kafka/common/record/Record.java	23	22	2410	1205	2014-02-06	2017-05-26
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordsSend.java	15	1	836	836	2018-05-30	2018-05-30
clients/src/main/java/org/apache/kafka/common/record/AbstractRecordBatch.java	15	3	1268	449	2017-03-24	2019-06-21
clients/src/main/java/org/apache/kafka/common/record/RecordVersion.java	20	2	856	582	2018-05-10	2019-02-08
clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java	58	5	1268	348	2017-03-24	2019-09-30
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java	524	28	1268	128	2017-03-24	2020-05-07
clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java	457	16	1268	348	2017-03-24	2019-09-30
clients/src/main/java/org/apache/kafka/common/record/BufferSupplier.java	72	2	1200	816	2017-05-31	2018-06-19
clients/src/main/java/org/apache/kafka/common/memory/MemoryPool.java	34	1	1144	1144	2017-07-26	2017-07-26
clients/src/main/java/org/apache/kafka/common/memory/SimpleMemoryPool.java	92	1	1144	1144	2017-07-26	2017-07-26
clients/src/main/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPool.java	110	2	1144	734	2017-07-26	2018-09-09
clients/src/main/java/org/apache/kafka/common/cache/Cache.java	7	3	1803	1292	2015-10-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/cache/LRUCache.java	30	4	1803	930	2015-10-06	2018-02-25
clients/src/main/java/org/apache/kafka/common/cache/SynchronizedCache.java	23	2	1803	1292	2015-10-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/ConsumerGroupState.java	29	2	845	106	2018-05-21	2020-05-29
clients/src/main/java/org/apache/kafka/common/config/ConfigTransformerResult.java	17	2	836	823	2018-05-30	2018-06-12
clients/src/main/java/org/apache/kafka/common/config/SaslConfigs.java	96	13	1789	840	2015-10-20	2018-05-26
clients/src/main/java/org/apache/kafka/common/config/types/Password.java	26	2	1766	1292	2015-11-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/config/SecurityConfig.java	7	2	383	327	2019-08-26	2019-10-21
clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java	61	7	1200	407	2017-05-31	2019-08-02
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java	984	61	2410	88	2014-02-06	2020-06-16
clients/src/main/java/org/apache/kafka/common/config/ConfigData.java	20	2	836	823	2018-05-30	2018-06-12
clients/src/main/java/org/apache/kafka/common/config/provider/DirectoryConfigProvider.java	59	1	21	21	2020-08-22	2020-08-22
clients/src/main/java/org/apache/kafka/common/config/provider/ConfigProvider.java	19	2	823	174	2018-06-12	2020-03-22
clients/src/main/java/org/apache/kafka/common/config/provider/FileConfigProvider.java	61	2	823	808	2018-06-12	2018-06-27
clients/src/main/java/org/apache/kafka/common/config/ConfigTransformer.java	107	6	836	487	2018-05-30	2019-05-14
clients/src/main/java/org/apache/kafka/common/config/ConfigValue.java	79	5	1640	1292	2016-03-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java	60	7	1094	74	2017-09-14	2020-06-30
clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java	123	18	1785	101	2015-10-24	2020-06-03
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java	133	16	1200	115	2017-05-31	2020-05-20
clients/src/main/java/org/apache/kafka/common/config/ConfigChangeCallback.java	5	2	836	823	2018-05-30	2018-06-12
clients/src/main/java/org/apache/kafka/common/config/LogLevelConfig.java	16	1	407	407	2019-08-02	2019-08-02
clients/src/main/java/org/apache/kafka/common/config/ConfigException.java	14	3	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/config/Config.java	11	3	1640	1292	2016-03-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java	359	48	2410	106	2014-02-06	2020-05-29
clients/src/main/java/org/apache/kafka/common/config/SslClientAuth.java	24	1	486	486	2019-05-15	2019-05-15
clients/src/main/java/org/apache/kafka/common/security/token/delegation/DelegationToken.java	47	4	970	492	2018-01-16	2019-05-09
clients/src/main/java/org/apache/kafka/common/security/token/delegation/internals/DelegationTokenCache.java	81	2	830	632	2018-06-05	2018-12-20
clients/src/main/java/org/apache/kafka/common/security/token/delegation/internals/DelegationTokenCredentialCallback.java	18	2	830	687	2018-06-05	2018-10-26
clients/src/main/java/org/apache/kafka/common/security/token/delegation/TokenInformation.java	93	4	970	492	2018-01-16	2019-05-09
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosError.java	72	2	758	226	2018-08-16	2020-01-30
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosShortNamer.java	63	5	1779	350	2015-10-30	2019-09-28
clients/src/main/java/org/apache/kafka/common/security/kerberos/NoMatchingRule.java	7	2	1789	1292	2015-10-20	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java	289	16	1600	734	2016-04-26	2018-09-09
clients/src/main/java/org/apache/kafka/common/security/kerberos/BadFormatString.java	10	2	1779	1292	2015-10-30	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosClientCallbackHandler.java	51	1	891	891	2018-04-05	2018-04-05
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosName.java	51	4	1789	1292	2015-10-20	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosRule.java	141	6	1789	350	2015-10-20	2019-09-28
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java	347	33	1785	53	2015-10-24	2020-07-21
clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java	265	2	157	56	2020-04-08	2020-07-18
clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java	156	4	688	56	2018-10-25	2020-07-18
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java	83	5	1358	885	2016-12-24	2018-04-11
clients/src/main/java/org/apache/kafka/common/security/JaasContext.java	119	9	1324	56	2017-01-27	2020-07-18
clients/src/main/java/org/apache/kafka/common/security/auth/PlaintextAuthenticationContext.java	22	3	1094	830	2017-09-14	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipal.java	50	8	1852	659	2015-08-18	2018-11-23
clients/src/main/java/org/apache/kafka/common/security/auth/SslEngineFactory.java	15	2	157	52	2020-04-08	2020-07-22
clients/src/main/java/org/apache/kafka/common/security/auth/AuthenticationContext.java	7	3	1094	830	2017-09-14	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipalBuilder.java	4	1	1094	1094	2017-09-14	2017-09-14
clients/src/main/java/org/apache/kafka/common/security/auth/PrincipalBuilder.java	15	5	1852	1094	2015-08-18	2017-09-14
clients/src/main/java/org/apache/kafka/common/security/auth/AuthenticateCallbackHandler.java	9	1	891	891	2018-04-05	2018-04-05
clients/src/main/java/org/apache/kafka/common/security/auth/SaslExtensionsCallback.java	12	2	768	745	2018-08-06	2018-08-29
clients/src/main/java/org/apache/kafka/common/security/auth/Login.java	14	6	1600	891	2016-04-26	2018-04-05
clients/src/main/java/org/apache/kafka/common/security/auth/SecurityProviderCreator.java	11	1	327	327	2019-10-21	2019-10-21
clients/src/main/java/org/apache/kafka/common/security/auth/SecurityProtocol.java	41	1	1074	1074	2017-10-04	2017-10-04
clients/src/main/java/org/apache/kafka/common/security/auth/SaslAuthenticationContext.java	30	3	1094	830	2017-09-14	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/auth/DefaultPrincipalBuilder.java	18	4	1852	1094	2015-08-18	2017-09-14
clients/src/main/java/org/apache/kafka/common/security/auth/SaslExtensions.java	28	2	768	745	2018-08-06	2018-08-29
clients/src/main/java/org/apache/kafka/common/security/auth/SslAuthenticationContext.java	28	3	1094	830	2017-09-14	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/plain/PlainLoginModule.java	38	5	1600	734	2016-04-26	2018-09-09
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainSaslServer.java	122	3	830	578	2018-06-05	2019-02-12
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainSaslServerProvider.java	15	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainServerCallbackHandler.java	49	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/plain/PlainAuthenticateCallback.java	18	1	891	891	2018-04-05	2018-04-05
clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java	48	16	1791	217	2015-10-18	2020-02-08
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerToken.java	11	1	840	840	2018-05-26	2018-05-26
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModule.java	179	6	840	705	2018-05-26	2018-10-08
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenCallback.java	37	2	840	705	2018-05-26	2018-10-08
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredJws.java	204	2	830	734	2018-06-05	2018-09-09
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerValidationUtils.java	97	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredLoginCallbackHandler.java	236	5	830	705	2018-06-05	2018-10-08
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerScopeUtils.java	25	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredValidatorCallbackHandler.java	136	3	830	734	2018-06-05	2018-09-09
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerConfigException.java	11	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerValidationResult.java	44	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerIllegalTokenException.java	16	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServerProvider.java	16	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerRefreshingLogin.java	77	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientProvider.java	16	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServer.java	176	6	830	687	2018-06-05	2018-10-26
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClient.java	146	4	830	734	2018-06-05	2018-09-09
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientCallbackHandler.java	86	4	830	583	2018-06-05	2019-02-07
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshingLogin.java	307	4	830	570	2018-06-05	2019-02-20
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshConfig.java	34	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredential.java	7	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerClientInitialResponse.java	95	3	786	745	2018-07-19	2018-08-29
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerExtensionsValidatorCallback.java	43	2	760	549	2018-08-14	2019-03-13
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallback.java	46	1	840	840	2018-05-26	2018-05-26
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredentialCallback.java	11	5	1341	891	2017-01-10	2018-04-05
clients/src/main/java/org/apache/kafka/common/security/scram/ScramExtensionsCallback.java	13	3	948	768	2018-02-07	2018-08-06
clients/src/main/java/org/apache/kafka/common/security/scram/ScramLoginModule.java	47	7	1341	734	2017-01-10	2018-09-09
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredential.java	25	3	1341	891	2017-01-10	2018-04-05
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramMessages.java	217	2	830	768	2018-06-05	2018-08-06
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServer.java	207	5	830	8	2018-06-05	2020-09-04
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramCredentialUtils.java	53	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramFormatter.java	143	3	830	8	2018-06-05	2020-09-04
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramMechanism.java	47	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramExtensions.java	20	4	830	734	2018-06-05	2018-09-09
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramServerCallbackHandler.java	51	3	830	687	2018-06-05	2018-10-26
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServerProvider.java	16	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClientProvider.java	16	1	830	830	2018-06-05	2018-06-05
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java	192	3	830	8	2018-06-05	2020-09-04
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java	568	47	1789	25	2015-10-20	2020-08-18
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultLogin.java	10	2	1600	1292	2016-04-26	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultKafkaPrincipalBuilder.java	112	5	1094	688	2017-09-14	2018-10-25
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientCallbackHandler.java	74	9	1600	670	2016-04-26	2018-11-12
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java	516	36	1789	56	2015-10-20	2020-07-18
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslInternalConfigs.java	7	1	687	687	2018-10-26	2018-10-26
clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java	156	15	1600	383	2016-04-26	2019-08-26
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerCallbackHandler.java	46	9	1789	891	2015-10-20	2018-04-05
clients/src/main/java/org/apache/kafka/common/security/authenticator/AbstractLogin.java	74	6	1600	891	2016-04-26	2018-04-05
clients/src/main/java/org/apache/kafka/common/security/authenticator/CredentialCache.java	41	5	1341	670	2017-01-10	2018-11-12
clients/src/main/java/org/apache/kafka/common/IsolationLevel.java	21	1	328	328	2019-10-20	2019-10-20
clients/src/main/java/org/apache/kafka/common/serialization/ByteArraySerializer.java	7	3	2076	568	2015-01-06	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/BytesDeserializer.java	9	3	1600	568	2016-04-26	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java	15	11	2076	568	2015-01-06	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/VoidSerializer.java	7	1	329	329	2019-10-19	2019-10-19
clients/src/main/java/org/apache/kafka/common/serialization/UUIDSerializer.java	28	2	734	568	2018-09-09	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/FloatDeserializer.java	18	2	1279	568	2017-03-13	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/Serde.java	12	4	1640	568	2016-03-17	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/DoubleDeserializer.java	18	3	1640	568	2016-03-17	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/ByteBufferSerializer.java	19	3	1663	568	2016-02-23	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/ExtendedDeserializer.java	32	4	1233	722	2017-04-28	2018-09-21
clients/src/main/java/org/apache/kafka/common/serialization/VoidDeserializer.java	9	1	329	329	2019-10-19	2019-10-19
clients/src/main/java/org/apache/kafka/common/serialization/FloatSerializer.java	15	2	1279	568	2017-03-13	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/ByteBufferDeserializer.java	9	3	1663	568	2016-02-23	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/LongSerializer.java	17	3	1814	568	2015-09-25	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/UUIDDeserializer.java	30	2	734	568	2018-09-09	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/StringDeserializer.java	27	5	2076	568	2015-01-06	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/IntegerDeserializer.java	17	4	1973	568	2015-04-19	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/StringSerializer.java	27	5	2076	568	2015-01-06	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java	165	11	1640	329	2016-03-17	2019-10-19
clients/src/main/java/org/apache/kafka/common/serialization/LongDeserializer.java	17	4	1814	568	2015-09-25	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/ByteArrayDeserializer.java	7	3	2076	568	2015-01-06	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/IntegerSerializer.java	13	3	1973	568	2015-04-19	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/DoubleSerializer.java	19	3	1640	568	2016-03-17	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/ShortDeserializer.java	17	2	1200	568	2017-05-31	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/BytesSerializer.java	9	3	1600	568	2016-04-26	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/ExtendedSerializer.java	32	4	1233	722	2017-04-28	2018-09-21
clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java	15	10	2076	568	2015-01-06	2019-02-22
clients/src/main/java/org/apache/kafka/common/serialization/ShortSerializer.java	11	2	1200	568	2017-05-31	2019-02-22
clients/src/main/java/org/apache/kafka/common/Metric.java	7	6	2410	1077	2014-02-06	2017-10-01
clients/src/main/java/org/apache/kafka/common/InvalidRecordException.java	11	1	348	348	2019-09-30	2019-09-30
clients/src/main/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java	28	1	274	274	2019-12-13	2019-12-13
clients/src/main/java/org/apache/kafka/common/network/DelayedResponseAuthenticationException.java	8	1	743	743	2018-08-31	2018-08-31
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java	164	20	1837	250	2015-09-02	2020-01-06
clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java	331	38	1789	130	2015-10-20	2020-05-05
clients/src/main/java/org/apache/kafka/common/network/NetworkReceive.java	118	12	2410	325	2014-02-06	2019-10-23
clients/src/main/java/org/apache/kafka/common/network/Mode.java	2	4	1789	1292	2015-10-20	2017-02-28
clients/src/main/java/org/apache/kafka/common/network/ChannelState.java	42	5	1216	702	2017-05-15	2018-10-11
clients/src/main/java/org/apache/kafka/common/network/CipherInformation.java	37	2	281	274	2019-12-06	2019-12-13
clients/src/main/java/org/apache/kafka/common/network/TransportLayers.java	10	2	1348	1292	2017-01-03	2017-02-28
clients/src/main/java/org/apache/kafka/common/network/Selectable.java	24	15	2410	243	2014-02-06	2020-01-13
clients/src/main/java/org/apache/kafka/common/network/Send.java	9	8	2410	1114	2014-02-06	2017-08-25
clients/src/main/java/org/apache/kafka/common/network/ChannelMetadataRegistry.java	9	1	274	274	2019-12-13	2019-12-13
clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java	13	7	2410	449	2014-02-06	2019-06-21
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java	353	30	1852	106	2015-08-18	2020-05-29
clients/src/main/java/org/apache/kafka/common/network/ReauthenticationContext.java	21	1	687	687	2018-10-26	2018-10-26
clients/src/main/java/org/apache/kafka/common/network/TransportLayer.java	25	14	1852	274	2015-08-18	2019-12-13
clients/src/main/java/org/apache/kafka/common/network/ListenerReconfigurable.java	5	1	963	963	2018-01-23	2018-01-23
clients/src/main/java/org/apache/kafka/common/network/Receive.java	11	6	2410	1144	2014-02-06	2017-07-26
clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java	52	13	2410	136	2014-02-06	2020-04-29
clients/src/main/java/org/apache/kafka/common/network/Authenticator.java	30	11	1852	243	2015-08-18	2020-01-13
clients/src/main/java/org/apache/kafka/common/network/Selector.java	1023	88	2410	93	2014-02-06	2020-06-11
clients/src/main/java/org/apache/kafka/common/network/ListenerName.java	45	7	1338	891	2017-01-13	2018-04-05
clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java	129	21	1785	130	2015-10-24	2020-05-05
clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java	76	17	1852	93	2015-08-18	2020-06-11
clients/src/main/java/org/apache/kafka/common/network/InvalidReceiveException.java	10	2	1928	1292	2015-06-03	2017-02-28
clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java	107	13	1852	274	2015-08-18	2019-12-13
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java	660	31	1785	78	2015-10-24	2020-06-26
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilder.java	11	8	1852	274	2015-08-18	2019-12-13
clients/src/main/java/org/apache/kafka/common/network/ClientInformation.java	39	1	274	274	2019-12-13	2019-12-13
clients/src/main/java/org/apache/kafka/common/Configurable.java	5	4	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/TopicPartition.java	45	6	2410	734	2014-02-06	2018-09-09
clients/src/main/java/org/apache/kafka/common/Cluster.java	213	32	2410	220	2014-02-06	2020-02-05
clients/src/main/java/org/apache/kafka/common/annotation/InterfaceStability.java	16	3	1858	1186	2015-08-12	2017-06-14
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferOutputStream.java	65	4	1284	1172	2017-03-08	2017-06-28
clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java	30	10	2410	470	2014-02-06	2019-05-31
clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java	186	5	1284	226	2017-03-08	2020-01-30
clients/src/main/java/org/apache/kafka/common/utils/SystemScheduler.java	18	1	1044	1044	2017-11-03	2017-11-03
clients/src/main/java/org/apache/kafka/common/utils/LoggingSignalHandler.java	64	2	841	509	2018-05-25	2019-04-22
clients/src/main/java/org/apache/kafka/common/utils/KafkaThread.java	24	7	2410	250	2014-02-06	2020-01-06
clients/src/main/java/org/apache/kafka/common/utils/PrimitiveRef.java	12	1	449	449	2019-06-21	2019-06-21
clients/src/main/java/org/apache/kafka/common/utils/OperatingSystem.java	14	2	1239	141	2017-04-22	2020-04-24
clients/src/main/java/org/apache/kafka/common/utils/MappedIterator.java	19	1	350	350	2019-09-28	2019-09-28
clients/src/main/java/org/apache/kafka/common/utils/FixedOrderMap.java	25	2	509	205	2019-04-22	2020-02-20
clients/src/main/java/org/apache/kafka/common/utils/Checksums.java	35	1	1263	1263	2017-03-29	2017-03-29
clients/src/main/java/org/apache/kafka/common/utils/LogContext.java	631	3	1120	982	2017-08-19	2018-01-04
clients/src/main/java/org/apache/kafka/common/utils/ProducerIdAndEpoch.java	32	2	304	233	2019-11-13	2020-01-23
clients/src/main/java/org/apache/kafka/common/utils/Bytes.java	116	9	1600	345	2016-04-26	2019-10-03
clients/src/main/java/org/apache/kafka/common/utils/Scheduler.java	10	1	1044	1044	2017-11-03	2017-11-03
clients/src/main/java/org/apache/kafka/common/utils/CollectionUtils.java	35	7	2249	650	2014-07-17	2018-12-02
clients/src/main/java/org/apache/kafka/common/utils/Shell.java	168	6	1789	845	2015-10-20	2018-05-21
clients/src/main/java/org/apache/kafka/common/utils/Utils.java	723	92	2410	78	2014-02-06	2020-06-26
clients/src/main/java/org/apache/kafka/common/utils/SecurityUtils.java	110	6	1094	164	2017-09-14	2020-04-01
clients/src/main/java/org/apache/kafka/common/utils/Time.java	20	7	2410	555	2014-02-06	2019-03-07
clients/src/main/java/org/apache/kafka/common/utils/AppInfoParser.java	111	12	1850	39	2015-08-20	2020-08-04
clients/src/main/java/org/apache/kafka/common/utils/CloseableIterator.java	24	2	1262	449	2017-03-30	2019-06-21
clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java	24	1	74	74	2020-06-30	2020-06-30
clients/src/main/java/org/apache/kafka/common/utils/Timer.java	51	1	771	771	2018-08-03	2018-08-03
clients/src/main/java/org/apache/kafka/common/utils/Crc32C.java	57	2	1263	1120	2017-03-29	2017-08-19
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferUnmapper.java	83	1	312	312	2019-11-05	2019-11-05
clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java	582	2	1263	670	2017-03-29	2018-11-12
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java	401	6	492	3	2019-05-09	2020-09-09
clients/src/main/java/org/apache/kafka/common/utils/AbstractIterator.java	56	4	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/utils/FlattenedIterator.java	22	1	350	350	2019-09-28	2019-09-28
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiCollection.java	74	3	492	142	2019-05-09	2020-04-23
clients/src/main/java/org/apache/kafka/common/utils/Sanitizer.java	41	3	1067	1041	2017-10-11	2017-11-06
clients/src/main/java/org/apache/kafka/common/utils/Crc32.java	314	9	2410	670	2014-02-06	2018-11-12
clients/src/main/java/org/apache/kafka/common/utils/ThreadUtils.java	23	1	225	225	2020-01-31	2020-01-31
clients/src/main/java/org/apache/kafka/common/utils/Java.java	40	6	1263	268	2017-03-29	2019-12-19
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java	23	1	1284	1284	2017-03-08	2017-03-08
clients/src/main/java/org/apache/kafka/common/utils/Exit.java	66	3	1318	232	2017-02-02	2020-01-24
clients/src/main/java/org/apache/kafka/common/utils/CircularIterator.java	41	3	1786	129	2015-10-23	2020-05-06
clients/src/main/java/org/apache/kafka/common/utils/CopyOnWriteMap.java	105	4	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/protocol/Message.java	15	5	610	17	2019-01-11	2020-08-26
clients/src/main/java/org/apache/kafka/common/protocol/RecordsReadable.java	54	1	44	44	2020-07-30	2020-07-30
clients/src/main/java/org/apache/kafka/common/protocol/types/RawTaggedField.java	31	1	342	342	2019-10-06	2019-10-06
clients/src/main/java/org/apache/kafka/common/protocol/types/TaggedFields.java	141	1	342	342	2019-10-06	2019-10-06
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java	866	19	2410	30	2014-02-06	2020-08-13
clients/src/main/java/org/apache/kafka/common/protocol/types/Schema.java	143	14	2410	115	2014-02-06	2020-05-20
clients/src/main/java/org/apache/kafka/common/protocol/types/SchemaException.java	11	5	2410	242	2014-02-06	2020-01-14
clients/src/main/java/org/apache/kafka/common/protocol/types/BoundField.java	15	1	1089	1089	2017-09-19	2017-09-19
clients/src/main/java/org/apache/kafka/common/protocol/types/RawTaggedFieldWriter.java	48	1	342	342	2019-10-06	2019-10-06
clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java	92	9	2410	353	2014-02-06	2019-09-25
clients/src/main/java/org/apache/kafka/common/protocol/types/Field.java	136	13	2410	226	2014-02-06	2020-01-30
clients/src/main/java/org/apache/kafka/common/protocol/types/CompactArrayOf.java	99	1	342	342	2019-10-06	2019-10-06
clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java	401	37	2410	226	2014-02-06	2020-01-30
clients/src/main/java/org/apache/kafka/common/protocol/ObjectSerializationCache.java	23	1	342	342	2019-10-06	2019-10-06
clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java	151	62	2410	308	2014-02-06	2019-11-09
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java	346	82	2410	8	2014-02-06	2020-09-04
clients/src/main/java/org/apache/kafka/common/protocol/ByteBufferAccessor.java	76	4	610	226	2019-01-11	2020-01-30
clients/src/main/java/org/apache/kafka/common/protocol/Writable.java	17	5	610	226	2019-01-11	2020-01-30
clients/src/main/java/org/apache/kafka/common/protocol/RecordsWritable.java	71	1	44	44	2020-07-30	2020-07-30
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java	400	93	2410	8	2014-02-06	2020-09-04
clients/src/main/java/org/apache/kafka/common/protocol/Readable.java	34	5	610	226	2019-01-11	2020-01-30
clients/src/main/java/org/apache/kafka/common/protocol/ApiMessage.java	4	1	610	610	2019-01-11	2019-01-11
clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java	143	7	610	96	2019-01-11	2020-06-08
clients/src/main/java/org/apache/kafka/common/protocol/CommonFields.java	23	11	1089	222	2017-09-19	2020-02-03
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java	44	4	970	142	2018-01-16	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java	82	14	1254	31	2017-04-07	2020-08-12
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java	73	30	2249	142	2014-07-17	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsRequest.java	53	10	1213	92	2017-05-18	2020-06-12
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownRequest.java	53	19	1837	341	2015-09-02	2019-10-07
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenRequest.java	50	4	970	400	2018-01-16	2019-08-09
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsRequest.java	54	12	1775	561	2015-11-03	2019-03-01
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java	100	28	2249	164	2014-07-17	2020-04-01
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java	130	13	1255	57	2017-04-06	2020-07-17
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java	39	12	1254	31	2017-04-07	2020-08-12
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java	73	13	1254	142	2017-04-07	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java	138	27	1837	44	2015-09-02	2020-07-30
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java	83	4	970	393	2018-01-16	2019-08-16
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsRequest.java	57	7	1087	248	2017-09-21	2020-01-08
clients/src/main/java/org/apache/kafka/common/requests/FetchMetadata.java	73	1	950	950	2018-02-05	2018-02-05
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java	44	18	1523	142	2016-07-12	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java	38	18	1775	142	2015-11-03	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnRequest.java	46	11	1254	154	2017-04-07	2020-04-11
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java	274	36	2384	57	2014-03-04	2020-07-17
clients/src/main/java/org/apache/kafka/common/requests/RequestHeader.java	105	18	2410	25	2014-02-06	2020-08-18
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java	81	17	1523	465	2016-07-12	2019-06-05
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaResponse.java	42	16	1844	142	2015-08-26	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupRequest.java	67	16	1788	225	2015-10-21	2020-01-31
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsResponse.java	43	14	1492	142	2016-08-12	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java	87	9	1106	44	2017-09-02	2020-07-30
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenRequest.java	53	4	970	402	2018-01-16	2019-08-07
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasRequest.java	88	2	182	180	2020-03-14	2020-03-16
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java	140	26	2249	184	2014-07-17	2020-03-12
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java	44	4	970	142	2018-01-16	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateRequest.java	55	7	1093	57	2017-09-15	2020-07-17
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsResponse.java	41	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java	67	3	514	142	2019-04-17	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java	91	3	182	57	2020-03-14	2020-07-17
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java	52	28	2249	142	2014-07-17	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsRequest.java	96	15	1213	214	2017-05-18	2020-02-11
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java	202	14	1254	163	2017-04-07	2020-04-02
clients/src/main/java/org/apache/kafka/common/requests/RequestAndSize.java	9	2	1303	1292	2017-02-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsRequest.java	78	1	411	411	2019-07-29	2019-07-29
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java	111	12	1213	222	2017-05-18	2020-02-03
clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java	111	9	1114	25	2017-08-25	2020-08-18
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java	105	11	1213	222	2017-05-18	2020-02-03
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java	172	70	1398	8	2016-11-14	2020-09-04
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java	42	10	1219	31	2017-05-12	2020-08-12
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java	61	11	1250	142	2017-04-11	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsRequest.java	69	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/common/requests/EpochEndOffset.java	56	5	1255	99	2017-04-06	2020-06-05
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java	99	30	2249	225	2014-07-17	2020-01-31
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteResponse.java	47	2	364	142	2019-09-14	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java	109	12	1213	142	2017-05-18	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java	260	31	2249	164	2014-07-17	2020-04-01
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeResponse.java	34	11	1600	142	2016-04-26	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java	46	5	1076	100	2017-10-02	2020-06-04
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java	211	28	2249	57	2014-07-17	2020-07-17
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenRequest.java	47	4	970	445	2018-01-16	2019-06-25
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java	94	3	182	57	2020-03-14	2020-07-17
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsRequest.java	82	14	1599	344	2016-04-27	2019-10-04
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsRequest.java	60	13	1492	421	2016-08-12	2019-07-19
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java	76	11	1254	57	2017-04-07	2020-07-17
clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java	45	11	1254	31	2017-04-07	2020-08-12
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownResponse.java	48	15	1837	142	2015-09-02	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteRequest.java	52	1	364	364	2019-09-14	2019-09-14
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsRequest.java	74	2	411	395	2019-07-29	2019-08-14
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java	120	13	1213	214	2017-05-18	2020-02-11
clients/src/main/java/org/apache/kafka/common/requests/ApiError.java	63	6	1213	52	2017-05-18	2020-07-22
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsRequest.java	101	8	1213	156	2017-05-18	2020-04-09
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRequest.java	54	6	1219	520	2017-05-12	2019-04-11
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersRequest.java	163	7	1254	177	2017-04-07	2020-03-19
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java	90	18	1793	323	2015-10-16	2019-10-25
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java	387	47	2409	99	2014-02-07	2020-06-05
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsRequest.java	60	2	514	428	2019-04-17	2019-07-12
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersRequest.java	95	1	472	472	2019-05-29	2019-05-29
clients/src/main/java/org/apache/kafka/common/requests/AbstractControlRequest.java	22	2	650	350	2018-12-02	2019-09-28
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java	216	12	1213	92	2017-05-18	2020-06-12
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java	54	21	2249	353	2014-07-17	2019-09-25
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsRequest.java	59	15	1775	106	2015-11-03	2020-05-29
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsResponse.java	41	3	411	142	2019-07-29	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java	174	14	1255	477	2017-04-06	2019-05-24
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateResponse.java	39	8	1093	142	2017-09-15	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java	279	45	2249	32	2014-07-17	2020-08-11
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java	88	2	472	142	2019-05-29	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java	45	7	1213	156	2017-05-18	2020-04-09
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java	39	9	1213	142	2017-05-18	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataResponse.java	30	12	1837	350	2015-09-02	2019-09-28
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java	59	5	955	142	2018-01-31	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java	46	11	1264	57	2017-03-28	2020-07-17
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java	153	31	2249	243	2014-07-17	2020-01-13
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsResponse.java	43	5	1087	142	2017-09-21	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java	46	19	1788	142	2015-10-21	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java	43	15	1837	142	2015-09-02	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java	160	20	1599	93	2016-04-27	2020-06-11
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsResponse.java	48	3	411	142	2019-07-29	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/ResponseHeader.java	39	10	2410	331	2014-02-06	2019-10-17
clients/src/main/java/org/apache/kafka/common/requests/RequestUtils.java	27	13	1213	220	2017-05-18	2020-02-05
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequest.java	67	5	1076	100	2017-10-02	2020-06-04
clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsResponse.java	41	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java	290	42	2249	44	2014-07-17	2020-07-30
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java	188	49	1995	8	2015-03-28	2020-09-04
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeRequest.java	51	13	1600	242	2016-04-26	2020-01-14
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsRequest.java	49	6	1106	177	2017-09-02	2020-03-19
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java	3	6	2249	44	2014-07-17	2020-07-30
clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsRequest.java	54	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java	99	11	1254	142	2017-04-07	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorRequest.java	81	8	1250	495	2017-04-11	2019-05-06
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupResponse.java	106	19	1793	142	2015-10-16	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java	116	20	1775	68	2015-11-03	2020-07-06
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataRequest.java	165	28	1837	44	2015-09-02	2020-07-30
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasRequest.java	96	1	182	182	2020-03-14	2020-03-14
clients/src/main/java/org/apache/kafka/common/requests/EndTxnRequest.java	53	11	1254	247	2017-04-07	2020-01-09
clients/src/main/java/org/apache/kafka/common/requests/TransactionResult.java	14	1	1254	1254	2017-04-07	2017-04-07
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsRequest.java	57	5	955	353	2018-01-31	2019-09-25
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java	305	40	2286	57	2014-06-10	2020-07-17
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java	38	21	2249	142	2014-07-17	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaRequest.java	175	21	1844	44	2015-08-26	2020-07-30
clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java	127	28	2409	299	2014-02-07	2019-11-18
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java	68	4	970	142	2018-01-16	2020-04-23
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java	62	9	1264	183	2017-03-28	2020-03-13
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenRequest.java	54	4	970	393	2018-01-16	2019-08-16
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java	213	9	1229	631	2017-05-02	2018-12-21
clients/src/main/java/org/apache/kafka/common/internals/ClusterResourceListeners.java	26	2	1456	1292	2016-09-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/internals/FatalExitError.java	17	3	1318	1183	2017-02-02	2017-06-17
clients/src/main/java/org/apache/kafka/common/internals/Topic.java	44	5	1275	431	2017-03-17	2019-07-09
clients/src/main/java/org/apache/kafka/common/internals/InvalidProducerEpochException.java	8	1	31	31	2020-08-12	2020-08-12
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java	113	12	1455	22	2016-09-18	2020-08-21
clients/src/main/java/org/apache/kafka/common/TopicPartitionInfo.java	51	5	1200	492	2017-05-31	2019-05-09
clients/src/main/java/org/apache/kafka/common/TopicPartitionReplica.java	51	3	1106	398	2017-09-02	2019-08-11
clients/src/main/java/org/apache/kafka/common/KafkaException.java	16	3	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/Endpoint.java	57	2	376	352	2019-09-02	2019-09-26
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java	55	5	1205	398	2017-05-26	2019-08-11
clients/src/main/java/org/apache/kafka/common/KafkaFuture.java	74	7	1229	881	2017-05-02	2018-04-15
clients/src/main/java/org/apache/kafka/common/ElectionType.java	22	3	472	173	2019-05-29	2020-03-23
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java	14	1	93	93	2020-06-11	2020-06-11
clients/src/main/java/org/apache/kafka/common/feature/BaseVersionRange.java	66	1	93	93	2020-06-11	2020-06-11
clients/src/main/java/org/apache/kafka/common/feature/FinalizedVersionRange.java	17	1	93	93	2020-06-11	2020-06-11
clients/src/main/java/org/apache/kafka/common/feature/Features.java	83	1	93	93	2020-06-11	2020-06-11
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaAlteration.java	50	1	182	182	2020-03-14	2020-03-14
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaFilterComponent.java	41	2	182	180	2020-03-14	2020-03-16
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaFilter.java	42	1	182	182	2020-03-14	2020-03-14
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaEntity.java	29	1	182	182	2020-03-14	2020-03-14
clients/src/main/java/org/apache/kafka/common/replica/RackAwareReplicaSelector.java	28	1	436	436	2019-07-04	2019-07-04
clients/src/main/java/org/apache/kafka/common/replica/ClientMetadata.java	71	1	436	436	2019-07-04	2019-07-04
clients/src/main/java/org/apache/kafka/common/replica/ReplicaView.java	57	1	436	436	2019-07-04	2019-07-04
clients/src/main/java/org/apache/kafka/common/replica/ReplicaSelector.java	18	1	436	436	2019-07-04	2019-07-04
clients/src/main/java/org/apache/kafka/common/replica/PartitionView.java	43	1	436	436	2019-07-04	2019-07-04
clients/src/main/java/org/apache/kafka/common/errors/GroupMaxSizeReachedException.java	7	2	589	423	2019-02-01	2019-07-17
clients/src/main/java/org/apache/kafka/common/errors/IllegalGenerationException.java	16	3	1886	1292	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/ApiException.java	21	4	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/SaslAuthenticationException.java	11	2	1087	1074	2017-09-21	2017-10-04
clients/src/main/java/org/apache/kafka/common/errors/InvalidMetadataException.java	16	2	2403	1292	2014-02-13	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/GroupNotEmptyException.java	6	2	955	845	2018-01-31	2018-05-21
clients/src/main/java/org/apache/kafka/common/errors/NotControllerException.java	10	2	1523	1292	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenOwnerMismatchException.java	10	1	970	970	2018-01-16	2018-01-16
clients/src/main/java/org/apache/kafka/common/errors/DisconnectException.java	17	3	1886	1292	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/ResourceNotFoundException.java	22	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedCompressionTypeException.java	10	1	703	703	2018-10-10	2018-10-10
clients/src/main/java/org/apache/kafka/common/errors/InvalidCommitOffsetSizeException.java	10	2	1699	1292	2016-01-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/UnknownLeaderEpochException.java	10	1	708	708	2018-10-05	2018-10-05
clients/src/main/java/org/apache/kafka/common/errors/LeaderNotAvailableException.java	10	5	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/FetchSessionIdNotFoundException.java	9	1	950	950	2018-02-05	2018-02-05
clients/src/main/java/org/apache/kafka/common/errors/LogDirNotFoundException.java	13	1	1106	1106	2017-09-02	2017-09-02
clients/src/main/java/org/apache/kafka/common/errors/ElectionNotNeededException.java	9	1	472	472	2019-05-29	2019-05-29
clients/src/main/java/org/apache/kafka/common/errors/InvalidConfigurationException.java	10	2	1523	1292	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/CoordinatorLoadInProgressException.java	10	1	1250	1250	2017-04-11	2017-04-11
clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnStateException.java	6	1	1254	1254	2017-04-07	2017-04-07
clients/src/main/java/org/apache/kafka/common/errors/TopicAuthorizationException.java	19	3	1774	423	2015-11-04	2019-07-17
clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java	15	6	2410	1074	2014-02-06	2017-10-04
clients/src/main/java/org/apache/kafka/common/errors/RecordTooLargeException.java	26	5	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/DuplicateResourceException.java	22	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/common/errors/UnknownServerException.java	15	4	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/ReassignmentInProgressException.java	9	1	1087	1087	2017-09-21	2017-09-21
clients/src/main/java/org/apache/kafka/common/errors/GroupIdNotFoundException.java	6	2	955	845	2018-01-31	2018-05-21
clients/src/main/java/org/apache/kafka/common/errors/OffsetNotAvailableException.java	7	1	638	638	2018-12-14	2018-12-14
clients/src/main/java/org/apache/kafka/common/errors/ClusterAuthorizationException.java	10	2	1711	1292	2016-01-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/OutOfOrderSequenceException.java	6	2	1259	1115	2017-04-02	2017-08-24
clients/src/main/java/org/apache/kafka/common/errors/KafkaStorageException.java	16	2	1148	1106	2017-07-22	2017-09-02
clients/src/main/java/org/apache/kafka/common/errors/InterruptException.java	17	3	2044	1292	2015-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/CoordinatorNotAvailableException.java	14	1	1250	1250	2017-04-11	2017-04-11
clients/src/main/java/org/apache/kafka/common/errors/GroupAuthorizationException.java	17	3	1774	423	2015-11-04	2019-07-17
clients/src/main/java/org/apache/kafka/common/errors/InvalidReplicaAssignmentException.java	10	2	1523	1292	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/ThrottlingQuotaExceededException.java	14	1	52	52	2020-07-22	2020-07-22
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderForPartitionException.java	17	6	2410	52	2014-02-06	2020-07-22
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderOrFollowerException.java	17	1	57	57	2020-07-17	2020-07-17
clients/src/main/java/org/apache/kafka/common/errors/UnknownProducerIdException.java	6	1	1088	1088	2017-09-20	2017-09-20
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenDisabledException.java	10	1	970	970	2018-01-16	2018-01-16
clients/src/main/java/org/apache/kafka/common/errors/ConcurrentTransactionsException.java	7	1	1235	1235	2017-04-26	2017-04-26
clients/src/main/java/org/apache/kafka/common/errors/PolicyViolationException.java	9	3	1338	1292	2017-01-13	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/BrokerNotAvailableException.java	10	2	1837	1292	2015-09-02	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/IllegalSaslStateException.java	10	3	1600	1087	2016-04-26	2017-09-21
clients/src/main/java/org/apache/kafka/common/errors/UnacceptableCredentialException.java	10	1	8	8	2020-09-04	2020-09-04
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedByAuthenticationException.java	10	1	970	970	2018-01-16	2018-01-16
clients/src/main/java/org/apache/kafka/common/errors/GroupSubscribedToTopicException.java	6	1	364	364	2019-09-14	2019-09-14
clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java	16	7	2410	1152	2014-02-06	2017-07-18
clients/src/main/java/org/apache/kafka/common/errors/InvalidPartitionsException.java	10	2	1523	1292	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidSessionTimeoutException.java	10	2	1699	1292	2016-01-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/NotCoordinatorException.java	10	1	1250	1250	2017-04-11	2017-04-11
clients/src/main/java/org/apache/kafka/common/errors/UnknownMemberIdException.java	16	2	1788	1292	2015-10-21	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/MemberIdRequiredException.java	10	1	606	606	2019-01-15	2019-01-15
clients/src/main/java/org/apache/kafka/common/errors/ProducerFencedException.java	6	2	1259	1115	2017-04-02	2017-08-24
clients/src/main/java/org/apache/kafka/common/errors/StaleBrokerEpochException.java	10	1	650	650	2018-12-02	2018-12-02
clients/src/main/java/org/apache/kafka/common/errors/FencedLeaderEpochException.java	10	1	708	708	2018-10-05	2018-10-05
clients/src/main/java/org/apache/kafka/common/errors/InvalidFetchSessionEpochException.java	9	1	950	950	2018-02-05	2018-02-05
clients/src/main/java/org/apache/kafka/common/errors/AuthorizationException.java	9	4	1780	1292	2015-10-29	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/SerializationException.java	21	2	2096	1292	2014-12-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidTimestampException.java	10	2	1667	1292	2016-02-19	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidFetchSizeException.java	10	2	1711	1292	2016-01-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidPrincipalTypeException.java	10	1	970	970	2018-01-16	2018-01-16
clients/src/main/java/org/apache/kafka/common/errors/ReplicaNotAvailableException.java	13	3	1711	57	2016-01-06	2020-07-17
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequiredAcksException.java	7	2	2038	1292	2015-02-13	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnTimeoutException.java	10	4	1250	919	2017-04-11	2018-03-08
clients/src/main/java/org/apache/kafka/common/errors/InvalidTopicException.java	30	4	2220	788	2014-08-15	2018-07-17
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenAuthorizationException.java	10	1	970	970	2018-01-16	2018-01-16
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedSaslMechanismException.java	10	3	1600	1087	2016-04-26	2017-09-21
clients/src/main/java/org/apache/kafka/common/errors/ControllerMovedException.java	10	2	1837	1292	2015-09-02	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/OffsetOutOfRangeException.java	10	7	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/TimeoutException.java	16	4	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenNotFoundException.java	10	1	970	970	2018-01-16	2018-01-16
clients/src/main/java/org/apache/kafka/common/errors/PreferredLeaderNotAvailableException.java	9	1	596	596	2019-01-25	2019-01-25
clients/src/main/java/org/apache/kafka/common/errors/TopicExistsException.java	10	2	1523	1292	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequestException.java	10	2	1523	1292	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/WakeupException.java	5	3	1782	840	2015-10-27	2018-05-26
clients/src/main/java/org/apache/kafka/common/errors/AuthenticationException.java	14	5	1600	743	2016-04-26	2018-08-31
clients/src/main/java/org/apache/kafka/common/errors/TransactionalIdAuthorizationException.java	6	2	1215	1207	2017-05-16	2017-05-24
clients/src/main/java/org/apache/kafka/common/errors/OffsetMetadataTooLarge.java	15	5	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenExpiredException.java	10	1	970	970	2018-01-16	2018-01-16
clients/src/main/java/org/apache/kafka/common/errors/InvalidOffsetException.java	10	2	1711	1292	2016-01-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/OperationNotAttemptedException.java	6	1	1198	1198	2017-06-02	2017-06-02
clients/src/main/java/org/apache/kafka/common/errors/InvalidPidMappingException.java	6	1	1254	1254	2017-04-07	2017-04-07
clients/src/main/java/org/apache/kafka/common/errors/RecordBatchTooLargeException.java	16	2	2165	1292	2014-10-09	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidGroupIdException.java	10	2	1699	1292	2016-01-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/EligibleLeadersNotAvailableException.java	9	1	472	472	2019-05-29	2019-05-29
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedVersionException.java	11	3	1599	1115	2016-04-27	2017-08-24
clients/src/main/java/org/apache/kafka/common/errors/FencedInstanceIdException.java	10	1	505	505	2019-04-26	2019-04-26
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedForMessageFormatException.java	10	3	1445	1115	2016-09-28	2017-08-24
clients/src/main/java/org/apache/kafka/common/errors/InvalidReplicationFactorException.java	10	2	1523	1292	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/NoReassignmentInProgressException.java	9	1	411	411	2019-07-29	2019-07-29
clients/src/main/java/org/apache/kafka/common/errors/NetworkException.java	16	4	2410	1292	2014-02-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/NotEnoughReplicasException.java	16	3	2165	1292	2014-10-09	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/RebalanceInProgressException.java	16	2	1782	1292	2015-10-27	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/TopicDeletionDisabledException.java	9	1	750	750	2018-08-24	2018-08-24
clients/src/main/java/org/apache/kafka/common/errors/DuplicateSequenceException.java	6	1	1094	1094	2017-09-14	2017-09-14
clients/src/main/java/org/apache/kafka/common/errors/SslAuthenticationException.java	11	1	1086	1086	2017-09-22	2017-09-22
clients/src/main/java/org/apache/kafka/common/errors/UnstableOffsetCommitException.java	7	1	243	243	2020-01-13	2020-01-13
clients/src/main/java/org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.java	7	4	2165	1292	2014-10-09	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/RetriableException.java	15	3	2403	31	2014-02-13	2020-08-12
clients/src/main/java/org/apache/kafka/common/errors/SecurityDisabledException.java	10	1	1213	1213	2017-05-18	2017-05-18
clients/src/main/java/org/apache/kafka/common/errors/ListenerNotFoundException.java	10	1	815	815	2018-06-20	2018-06-20
clients/src/main/java/org/apache/kafka/common/errors/TransactionCoordinatorFencedException.java	10	1	1225	1225	2017-05-06	2017-05-06
clients/src/main/java/org/apache/kafka/common/errors/InconsistentGroupProtocolException.java	10	2	1699	1292	2016-01-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/resource/Resource.java	43	6	1200	827	2017-05-31	2018-06-08
clients/src/main/java/org/apache/kafka/common/resource/PatternType.java	44	2	821	753	2018-06-14	2018-08-21
clients/src/main/java/org/apache/kafka/common/resource/ResourceFilter.java	55	7	1200	734	2017-05-31	2018-09-09
clients/src/main/java/org/apache/kafka/common/resource/ResourceType.java	44	5	1200	970	2017-05-31	2018-01-16
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java	55	2	827	821	2018-06-08	2018-06-14
clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java	85	3	827	739	2018-06-08	2018-09-04
clients/src/main/java/org/apache/kafka/common/ClusterResourceListener.java	4	4	1456	173	2016-09-17	2020-03-23
clients/src/main/java/org/apache/kafka/common/Reconfigurable.java	9	2	963	951	2018-01-23	2018-02-04
clients/src/main/java/org/apache/kafka/common/acl/AclBinding.java	47	6	1200	821	2017-05-31	2018-06-14
clients/src/main/java/org/apache/kafka/common/acl/AclOperation.java	50	6	1200	473	2017-05-31	2019-05-28
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntry.java	51	3	1200	1185	2017-05-31	2017-06-15
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryData.java	65	2	1200	1185	2017-05-31	2017-06-15
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryFilter.java	62	4	1200	734	2017-05-31	2018-09-09
clients/src/main/java/org/apache/kafka/common/acl/AclPermissionType.java	41	3	1200	1185	2017-05-31	2017-06-15
clients/src/main/java/org/apache/kafka/common/acl/AclBindingFilter.java	57	7	1200	821	2017-05-31	2018-06-14
clients/src/main/java/org/apache/kafka/common/header/Headers.java	9	2	1233	928	2017-04-28	2018-02-27
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java	51	2	1233	492	2017-04-28	2019-05-09
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java	152	6	1233	492	2017-04-28	2019-05-09
clients/src/main/java/org/apache/kafka/common/header/Header.java	5	1	1233	1233	2017-04-28	2017-04-28
clients/src/main/java/org/apache/kafka/common/MessageFormatter.java	17	1	71	71	2020-07-03	2020-07-03
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java	30	3	1242	631	2017-04-19	2018-12-21
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java	343	20	1782	583	2015-10-27	2019-02-07
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java	312	14	1199	38	2017-06-01	2020-08-05
tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java	400	25	1782	53	2015-10-27	2020-07-21
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java	532	20	1769	194	2015-11-09	2020-03-02
tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java	67	8	1782	1292	2015-10-27	2017-02-28
tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java	459	17	1327	53	2017-01-24	2020-07-21
tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java	183	12	1782	232	2015-10-27	2020-01-24
tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java	256	4	1038	675	2017-11-09	2018-11-07
tools/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java	484	10	1044	225	2017-11-03	2020-01-31
tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java	124	16	1114	232	2017-08-25	2020-01-24
tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java	237	9	1114	225	2017-08-25	2020-01-31
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorRestResource.java	109	8	1114	606	2017-08-25	2019-01-15
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java	460	10	1114	537	2017-08-25	2019-03-25
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicTopology.java	34	1	1114	1114	2017-08-25	2017-08-25
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicPlatform.java	82	3	1114	1044	2017-08-25	2017-11-03
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicNode.java	83	1	1114	1114	2017-08-25	2017-08-25
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java	271	6	1114	597	2017-08-25	2019-01-24
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentRestResource.java	71	4	1114	606	2017-08-25	2019-01-15
tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java	186	13	1114	232	2017-08-25	2020-01-24
tools/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java	498	9	1044	225	2017-11-03	2020-01-31
tools/src/main/java/org/apache/kafka/trogdor/common/JsonUtil.java	50	4	1114	597	2017-08-25	2019-01-24
tools/src/main/java/org/apache/kafka/trogdor/common/Node.java	26	2	1114	914	2017-08-25	2018-03-13
tools/src/main/java/org/apache/kafka/trogdor/common/Topology.java	20	3	1114	911	2017-08-25	2018-03-16
tools/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java	219	10	997	39	2017-12-20	2020-08-04
tools/src/main/java/org/apache/kafka/trogdor/common/StringFormatter.java	68	1	597	597	2019-01-24	2019-01-24
tools/src/main/java/org/apache/kafka/trogdor/common/Platform.java	33	2	1114	1044	2017-08-25	2017-11-03
tools/src/main/java/org/apache/kafka/trogdor/common/StringExpander.java	30	2	880	606	2018-04-16	2019-01-15
tools/src/main/java/org/apache/kafka/trogdor/task/AgentWorkerStatusTracker.java	16	1	888	888	2018-04-08	2018-04-08
tools/src/main/java/org/apache/kafka/trogdor/task/TaskController.java	6	1	1044	1044	2017-11-03	2017-11-03
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskController.java	14	1	1044	1044	2017-11-03	2017-11-03
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskSpec.java	18	1	1044	1044	2017-11-03	2017-11-03
tools/src/main/java/org/apache/kafka/trogdor/task/TaskSpec.java	50	3	1044	610	2017-11-03	2019-01-11
tools/src/main/java/org/apache/kafka/trogdor/task/TaskWorker.java	8	2	1044	888	2017-11-03	2018-04-08
tools/src/main/java/org/apache/kafka/trogdor/task/WorkerStatusTracker.java	5	1	888	888	2018-04-08	2018-04-08
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskWorker.java	26	2	1044	888	2017-11-03	2018-04-08
tools/src/main/java/org/apache/kafka/trogdor/workload/PayloadKeyType.java	12	1	918	918	2018-03-09	2018-03-09
tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionSpec.java	121	1	370	370	2019-09-08	2019-09-08
tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandSpec.java	56	1	584	584	2019-02-06	2019-02-06
tools/src/main/java/org/apache/kafka/trogdor/workload/PartitionsSpec.java	90	3	880	708	2018-04-16	2018-10-05
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java	263	14	768	64	2018-08-06	2020-07-10
tools/src/main/java/org/apache/kafka/trogdor/workload/TransactionGenerator.java	16	2	655	537	2018-11-27	2019-03-25
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java	440	8	886	128	2018-04-10	2020-05-07
tools/src/main/java/org/apache/kafka/trogdor/workload/PayloadGenerator.java	16	4	918	409	2018-03-09	2019-07-31
tools/src/main/java/org/apache/kafka/trogdor/workload/RandomComponentPayloadGenerator.java	56	1	409	409	2019-07-31	2019-07-31
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpec.java	137	5	886	654	2018-04-10	2018-11-28
tools/src/main/java/org/apache/kafka/trogdor/workload/TopicsSpec.java	43	2	880	684	2018-04-16	2018-10-29
tools/src/main/java/org/apache/kafka/trogdor/workload/TimeIntervalTransactionsGenerator.java	38	1	537	537	2019-03-25	2019-03-25
tools/src/main/java/org/apache/kafka/trogdor/workload/Throttle.java	46	2	1019	768	2017-11-28	2018-08-06
tools/src/main/java/org/apache/kafka/trogdor/workload/RandomComponent.java	21	1	409	409	2019-07-31	2019-07-31
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java	388	13	997	39	2017-12-20	2020-08-04
tools/src/main/java/org/apache/kafka/trogdor/workload/UniformTransactionsGenerator.java	30	1	655	655	2018-11-27	2018-11-27
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java	95	7	997	541	2017-12-20	2019-03-21
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressSpec.java	72	3	768	631	2018-08-06	2018-12-21
tools/src/main/java/org/apache/kafka/trogdor/workload/SequentialPayloadGenerator.java	34	1	911	911	2018-03-16	2018-03-16
tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionWorker.java	396	3	370	225	2019-09-08	2020-01-31
tools/src/main/java/org/apache/kafka/trogdor/workload/ConstantPayloadGenerator.java	29	1	911	911	2018-03-16	2018-03-16
tools/src/main/java/org/apache/kafka/trogdor/workload/PayloadIterator.java	27	1	911	911	2018-03-16	2018-03-16
tools/src/main/java/org/apache/kafka/trogdor/workload/NullPayloadGenerator.java	11	1	886	886	2018-04-10	2018-04-10
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java	341	14	1019	128	2017-11-28	2020-05-07
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java	126	12	1019	437	2017-11-28	2019-07-03
tools/src/main/java/org/apache/kafka/trogdor/workload/Histogram.java	127	1	1019	1019	2017-11-28	2017-11-28
tools/src/main/java/org/apache/kafka/trogdor/workload/UniformRandomPayloadGenerator.java	54	1	911	911	2018-03-16	2018-03-16
tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java	282	3	584	225	2019-02-06	2020-01-31
tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultController.java	14	1	1031	1031	2017-11-16	2017-11-16
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultController.java	14	1	997	997	2017-12-20	2017-12-20
tools/src/main/java/org/apache/kafka/trogdor/fault/FilesUnreadableFaultSpec.java	53	2	1031	912	2017-11-16	2018-03-15
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultSpec.java	47	3	1114	912	2017-08-25	2018-03-15
tools/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultWorker.java	113	2	449	299	2019-06-21	2019-11-18
tools/src/main/java/org/apache/kafka/trogdor/fault/Kibosh.java	144	3	1031	2	2017-11-16	2020-09-10
tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultWorker.java	37	2	1031	888	2017-11-16	2018-04-08
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultController.java	20	1	1044	1044	2017-11-03	2017-11-03
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultWorker.java	60	2	1044	888	2017-11-03	2018-04-08
tools/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultSpec.java	63	2	449	299	2019-06-21	2019-11-18
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultSpec.java	38	2	997	912	2017-12-20	2018-03-15
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultWorker.java	62	2	997	888	2017-12-20	2018-04-08
tools/src/main/java/org/apache/kafka/trogdor/rest/Message.java	19	1	1044	1044	2017-11-03	2017-11-03
tools/src/main/java/org/apache/kafka/trogdor/rest/RequestConflictException.java	10	1	880	880	2018-04-16	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/UptimeResponse.java	21	1	606	606	2019-01-15	2019-01-15
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStateType.java	19	1	656	656	2018-11-26	2018-11-26
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskPending.java	15	3	1044	597	2017-11-03	2019-01-24
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerReceiving.java	17	3	1044	880	2017-11-03	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/RestExceptionMapper.java	56	3	1114	880	2017-08-25	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/DestroyWorkerRequest.java	14	1	880	880	2018-04-16	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerRunning.java	33	4	1044	880	2017-11-03	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskState.java	33	4	1044	597	2017-11-03	2019-01-24
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStopping.java	37	4	1044	880	2017-11-03	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorShutdownRequest.java	14	1	1044	1044	2017-11-03	2017-11-03
tools/src/main/java/org/apache/kafka/trogdor/rest/AgentStatusResponse.java	22	4	1114	880	2017-08-25	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java	190	7	1114	225	2017-08-25	2020-01-31
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerDone.java	47	4	1044	880	2017-11-03	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/StopWorkerRequest.java	14	2	1044	880	2017-11-03	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/TasksRequest.java	76	2	891	656	2018-04-05	2018-11-26
tools/src/main/java/org/apache/kafka/trogdor/rest/DestroyTaskRequest.java	14	1	880	880	2018-04-16	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRequest.java	14	1	673	673	2018-11-09	2018-11-09
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerState.java	46	3	1044	880	2017-11-03	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStopping.java	23	3	1044	597	2017-11-03	2019-01-24
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateTaskRequest.java	22	1	1044	1044	2017-11-03	2017-11-03
tools/src/main/java/org/apache/kafka/trogdor/rest/StopTaskRequest.java	14	2	1044	880	2017-11-03	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRunning.java	23	3	1044	597	2017-11-03	2019-01-24
tools/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorStatusResponse.java	14	2	1114	1044	2017-08-25	2017-11-03
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateWorkerRequest.java	29	2	1044	880	2017-11-03	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStarting.java	17	3	1044	880	2017-11-03	2018-04-16
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskDone.java	44	3	1044	597	2017-11-03	2019-01-24
tools/src/main/java/org/apache/kafka/trogdor/rest/ErrorResponse.java	39	1	1114	1114	2017-08-25	2017-08-25
tools/src/main/java/org/apache/kafka/trogdor/rest/TasksResponse.java	18	2	1044	912	2017-11-03	2018-03-15
tools/src/main/java/org/apache/kafka/trogdor/rest/Empty.java	23	1	1114	1114	2017-08-25	2017-08-25
core/src/main/java/kafka/metrics/KafkaYammerMetrics.java	38	1	212	212	2020-02-13	2020-02-13
core/src/main/java/kafka/metrics/FilteringJmxReporter.java	36	1	212	212	2020-02-13	2020-02-13
core/src/main/scala/org/apache/zookeeper/ZooKeeperMainWithTlsSupportForKafka.scala	62	3	217	78	2020-02-08	2020-06-26
core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala	10	6	2949	225	2012-08-16	2020-01-31
core/src/main/scala/kafka/metrics/LinuxIoMetricsCollector.scala	59	1	117	117	2020-05-18	2020-05-18
core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala	58	24	2949	212	2012-08-16	2020-02-13
core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala	51	12	2949	212	2012-08-16	2020-02-13
core/src/main/scala/kafka/metrics/KafkaTimer.scala	9	3	2949	1207	2012-08-16	2017-05-24
core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala	38	9	2949	393	2012-08-16	2019-08-16
core/src/main/scala/kafka/cluster/Broker.scala	57	36	3330	93	2011-08-01	2020-06-11
core/src/main/scala/kafka/cluster/BrokerEndPoint.scala	40	9	1987	708	2015-04-05	2018-10-05
core/src/main/scala/kafka/cluster/Partition.scala	827	174	3330	2	2011-08-01	2020-09-10
core/src/main/scala/kafka/cluster/Replica.scala	54	43	3097	108	2012-03-21	2020-05-27
core/src/main/scala/kafka/cluster/EndPoint.scala	39	12	1987	352	2015-04-05	2019-09-26
core/src/main/scala/kafka/zk/KafkaZkClient.scala	1170	57	1053	78	2017-10-25	2020-06-26
core/src/main/scala/kafka/zk/ZkSecurityMigratorUtils.scala	5	1	652	652	2018-11-30	2018-11-30
core/src/main/scala/kafka/zk/AdminZkClient.scala	278	15	1025	52	2017-11-22	2020-07-22
core/src/main/scala/kafka/zk/ZkData.scala	656	37	1053	93	2017-10-25	2020-06-11
core/src/main/scala/kafka/tools/DumpLogSegments.scala	351	72	3308	164	2011-08-23	2020-04-01
core/src/main/scala/kafka/tools/MirrorMaker.scala	435	87	3026	124	2012-05-31	2020-05-11
core/src/main/scala/kafka/tools/GetOffsetShell.scala	115	18	3330	164	2011-08-01	2020-04-01
core/src/main/scala/kafka/tools/ConsumerPerformance.scala	251	40	3330	49	2011-08-01	2020-07-25
core/src/main/scala/kafka/tools/StreamsResetter.java	563	43	1503	38	2016-08-01	2020-08-05
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala	408	42	2488	74	2013-11-20	2020-06-30
core/src/main/scala/kafka/tools/JmxTool.scala	221	26	3246	164	2011-10-24	2020-04-01
core/src/main/scala/kafka/tools/ConsoleConsumer.scala	464	75	2292	71	2014-06-04	2020-07-03
core/src/main/scala/kafka/tools/StateChangeLogMerger.scala	129	13	2747	78	2013-03-06	2020-06-26
core/src/main/scala/kafka/tools/ConsoleProducer.scala	256	41	2292	10	2014-06-04	2020-09-02
core/src/main/scala/kafka/tools/EndToEndLatency.scala	117	18	1873	124	2015-07-28	2020-05-11
core/src/main/scala/kafka/tools/PerfConfig.scala	20	8	2292	660	2014-06-04	2018-11-22
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala	469	31	1235	31	2017-04-26	2020-08-12
core/src/main/scala/kafka/coordinator/transaction/ProducerIdManager.scala	104	11	1235	164	2017-04-26	2020-04-01
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala	321	32	1235	74	2017-04-26	2020-06-30
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala	140	18	1235	57	2017-04-26	2020-07-17
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala	309	19	1235	31	2017-04-26	2020-08-12
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala	484	48	1235	57	2017-04-26	2020-07-17
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala	192	12	1235	71	2017-04-26	2020-07-03
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala	1049	59	1235	2	2017-04-26	2020-09-10
core/src/main/scala/kafka/coordinator/group/MemberMetadata.scala	83	11	1235	172	2017-04-26	2020-03-24
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala	514	38	1235	95	2017-04-26	2020-06-09
core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala	39	7	1235	2	2017-04-26	2020-09-10
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala	1157	64	1235	2	2017-04-26	2020-09-10
core/src/main/scala/kafka/coordinator/group/DelayedHeartbeat.scala	12	7	1235	172	2017-04-26	2020-03-24
core/src/main/scala/kafka/coordinator/group/OffsetConfig.scala	24	2	1235	809	2017-04-26	2018-06-26
core/src/main/scala/kafka/serializer/Decoder.scala	29	8	3330	1179	2011-08-01	2017-06-21
core/src/main/scala/kafka/Kafka.scala	55	32	3330	78	2011-08-01	2020-06-26
core/src/main/scala/kafka/security/auth/Acl.scala	42	8	1837	239	2015-09-02	2020-01-17
core/src/main/scala/kafka/security/auth/Resource.scala	42	13	1837	164	2015-09-02	2020-04-01
core/src/main/scala/kafka/security/auth/Authorizer.scala	15	10	1837	376	2015-09-02	2019-09-02
core/src/main/scala/kafka/security/auth/ResourceType.scala	64	17	1837	165	2015-09-02	2020-03-31
core/src/main/scala/kafka/security/auth/PermissionType.scala	26	8	1837	239	2015-09-02	2020-01-17
core/src/main/scala/kafka/security/auth/SimpleAclAuthorizer.scala	121	51	1818	124	2015-09-21	2020-05-11
core/src/main/scala/kafka/security/auth/Operation.scala	87	9	1837	165	2015-09-02	2020-03-31
core/src/main/scala/kafka/security/authorizer/AclEntry.scala	89	2	239	164	2020-01-17	2020-04-01
core/src/main/scala/kafka/security/authorizer/AuthorizerWrapper.scala	137	5	376	164	2019-09-02	2020-04-01
core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala	440	14	376	78	2019-09-02	2020-06-26
core/src/main/scala/kafka/security/authorizer/AuthorizerUtils.scala	38	4	376	142	2019-09-02	2020-04-23
core/src/main/scala/kafka/security/CredentialProvider.scala	30	7	1341	393	2017-01-10	2019-08-16
core/src/main/scala/kafka/network/SocketServer.scala	1055	132	3330	25	2011-08-01	2020-08-18
core/src/main/scala/kafka/network/RequestChannel.scala	396	102	3165	25	2012-01-13	2020-08-18
core/src/main/scala/kafka/admin/DelegationTokenCommand.scala	162	8	970	164	2018-01-16	2020-04-01
core/src/main/scala/kafka/admin/LeaderElectionCommand.scala	232	7	472	164	2019-05-29	2020-04-01
core/src/main/scala/kafka/admin/AclCommand.scala	516	50	1808	65	2015-10-01	2020-07-09
core/src/main/scala/kafka/admin/RackAwareMode.scala	7	1	1642	1642	2016-03-15	2016-03-15
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala	280	16	1333	74	2017-01-18	2020-06-30
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala	1234	62	2894	78	2012-10-10	2020-06-26
core/src/main/scala/kafka/admin/AdminUtils.scala	120	92	3165	250	2012-01-13	2020-01-06
core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala	229	22	1786	78	2015-10-23	2020-06-26
core/src/main/scala/kafka/admin/AdminOperationException.scala	5	1	2745	2745	2013-03-08	2013-03-08
core/src/main/scala/kafka/admin/ConfigCommand.scala	706	61	1866	8	2015-08-04	2020-09-04
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala	1008	75	2041	78	2015-02-10	2020-06-26
core/src/main/scala/kafka/admin/TopicCommand.scala	649	98	2745	22	2013-03-08	2020-08-21
core/src/main/scala/kafka/admin/BrokerMetadata.scala	2	1	1642	1642	2016-03-15	2016-03-15
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala	244	37	2891	78	2012-10-13	2020-06-26
core/src/main/scala/kafka/admin/DeleteRecordsCommand.scala	97	12	1264	124	2017-03-28	2020-05-11
core/src/main/scala/kafka/admin/LogDirsCommand.scala	88	10	1106	44	2017-09-02	2020-07-30
core/src/main/scala/kafka/message/CompressionCodec.scala	74	13	3330	225	2011-08-01	2020-01-31
core/src/main/scala/kafka/server/ReplicaFetcherManager.scala	26	20	3003	393	2012-06-23	2019-08-16
core/src/main/scala/kafka/server/DelayedOperationKey.scala	25	9	2109	472	2014-12-04	2019-05-29
core/src/main/scala/kafka/server/ClientQuotaManager.scala	418	41	1856	26	2015-08-14	2020-08-17
core/src/main/scala/kafka/server/LogDirFailureChannel.scala	14	3	1148	705	2017-07-22	2018-10-08
core/src/main/scala/kafka/server/ReplicaManager.scala	1383	250	3095	2	2012-03-23	2020-09-10
core/src/main/scala/kafka/server/ActionQueue.scala	22	1	2	2	2020-09-10	2020-09-10
core/src/main/scala/kafka/server/DelayedElectLeader.scala	38	4	472	164	2019-05-29	2020-04-01
core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala	65	10	2070	164	2015-01-12	2020-04-01
core/src/main/scala/kafka/server/DelayedProduce.scala	81	23	2230	57	2014-08-05	2020-07-17
core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala	141	19	1255	78	2017-04-06	2020-06-26
core/src/main/scala/kafka/server/FetchDataInfo.scala	11	6	2230	708	2014-08-05	2018-10-05
core/src/main/scala/kafka/server/DelayedOperation.scala	208	26	2109	2	2014-12-04	2020-09-10
core/src/main/scala/kafka/server/SensorAccess.scala	24	3	1458	37	2016-09-15	2020-08-06
core/src/main/scala/kafka/server/checkpoints/OffsetCheckpointFile.scala	52	8	1255	393	2017-04-06	2019-08-16
core/src/main/scala/kafka/server/checkpoints/CheckpointFile.scala	110	10	1255	217	2017-04-06	2020-02-08
core/src/main/scala/kafka/server/checkpoints/LeaderEpochCheckpointFile.scala	32	5	1255	393	2017-04-06	2019-08-16
core/src/main/scala/kafka/server/FinalizedFeatureCache.scala	45	1	93	93	2020-06-11	2020-06-11
core/src/main/scala/kafka/server/KafkaRequestHandler.scala	273	50	3165	39	2012-01-13	2020-08-04
core/src/main/scala/kafka/server/ControllerMutationQuotaManager.scala	150	3	52	37	2020-07-22	2020-08-06
core/src/main/scala/kafka/server/MetadataCache.scala	282	54	2335	19	2014-04-22	2020-08-24
core/src/main/scala/kafka/server/KafkaServer.scala	587	234	3330	45	2011-08-01	2020-07-29
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala	249	132	3025	109	2012-06-01	2020-05-26
core/src/main/scala/kafka/server/KafkaConfig.scala	1508	234	3330	26	2011-08-01	2020-08-17
core/src/main/scala/kafka/server/DelayedDeleteTopics.scala	40	3	1492	52	2016-08-12	2020-07-22
core/src/main/scala/kafka/server/DelegationTokenManager.scala	346	9	970	78	2018-01-16	2020-06-26
core/src/main/scala/kafka/server/LogOffsetMetadata.scala	40	9	2230	453	2014-08-05	2019-06-17
core/src/main/scala/kafka/server/AbstractFetcherManager.scala	159	38	3003	52	2012-06-23	2020-07-22
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala	201	29	1061	57	2017-10-17	2020-07-17
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala	715	35	963	26	2018-01-23	2020-08-17
core/src/main/scala/kafka/server/ReplicationQuotaManager.scala	99	13	1458	37	2016-09-15	2020-08-06
core/src/main/scala/kafka/server/BrokerStates.scala	17	3	2321	393	2014-05-06	2019-08-16
core/src/main/scala/kafka/server/AbstractFetcherThread.scala	550	108	3003	57	2012-06-23	2020-07-17
core/src/main/scala/kafka/server/DelayedFuture.scala	57	3	347	222	2019-10-01	2020-02-03
core/src/main/scala/kafka/server/SupportedFeatures.scala	36	1	93	93	2020-06-11	2020-06-11
core/src/main/scala/kafka/server/DynamicConfig.scala	85	14	1446	40	2016-09-27	2020-08-03
core/src/main/scala/kafka/server/DelayedCreatePartitions.scala	56	6	1087	52	2017-09-21	2020-07-22
core/src/main/scala/kafka/server/ConfigHandler.scala	162	34	1866	40	2015-08-04	2020-08-03
core/src/main/scala/kafka/server/ReplicaAlterLogDirsManager.scala	34	5	1061	162	2017-10-17	2020-04-03
core/src/main/scala/kafka/server/FetchSession.scala	507	13	950	124	2018-02-05	2020-05-11
core/src/main/scala/kafka/server/ThrottledChannel.scala	24	4	885	136	2018-04-11	2020-04-29
core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala	54	13	1230	26	2017-05-01	2020-08-17
core/src/main/scala/kafka/server/DelayedFetch.scala	117	32	2230	57	2014-08-05	2020-07-17
core/src/main/scala/kafka/server/QuotaFactory.scala	107	12	1458	52	2016-09-15	2020-07-22
core/src/main/scala/kafka/server/DelayedDeleteRecords.scala	76	11	1264	57	2017-03-28	2020-07-17
core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala	99	14	1255	74	2017-04-06	2020-06-30
core/src/main/scala/kafka/server/DynamicConfigManager.scala	100	22	1866	164	2015-08-04	2020-04-01
core/src/main/scala/kafka/server/AdminManager.scala	1039	55	1523	8	2016-07-12	2020-09-04
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala	143	1	45	45	2020-07-29	2020-07-29
core/src/main/scala/kafka/server/KafkaApis.scala	2720	388	3165	2	2012-01-13	2020-09-10
core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala	128	2	93	92	2020-06-11	2020-06-12
core/src/main/scala/kafka/server/KafkaServerStartable.scala	38	29	3330	382	2011-08-01	2019-08-27
core/src/main/scala/kafka/utils/DelayedItem.scala	15	9	3330	708	2011-08-01	2018-10-05
core/src/main/scala/kafka/utils/Annotations.scala	5	5	3330	1262	2011-08-01	2017-03-30
core/src/main/scala/kafka/utils/CommandDefaultOptions.scala	8	2	660	494	2018-11-22	2019-05-07
core/src/main/scala/kafka/utils/Throttler.scala	65	11	3330	393	2011-08-01	2019-08-16
core/src/main/scala/kafka/utils/KafkaScheduler.scala	80	28	3330	250	2011-08-01	2020-01-06
core/src/main/scala/kafka/utils/Logging.scala	41	13	3216	935	2011-11-23	2018-02-20
core/src/main/scala/kafka/utils/ToolsUtils.scala	41	7	2178	162	2014-09-26	2020-04-03
core/src/main/scala/kafka/utils/Implicits.scala	12	2	1120	164	2017-08-19	2020-04-01
core/src/main/scala/kafka/utils/FileLock.scala	39	9	2871	393	2012-11-02	2019-08-16
core/src/main/scala/kafka/utils/timer/TimerTaskList.scala	99	7	1984	78	2015-04-08	2020-06-26
core/src/main/scala/kafka/utils/timer/Timer.scala	69	9	1984	78	2015-04-08	2020-06-26
core/src/main/scala/kafka/utils/timer/TimingWheel.scala	49	4	1984	1613	2015-04-08	2016-04-13
core/src/main/scala/kafka/utils/timer/TimerTask.scala	19	4	1984	78	2015-04-08	2020-06-26
core/src/main/scala/kafka/utils/CommandLineUtils.scala	71	23	2891	22	2012-10-13	2020-08-21
core/src/main/scala/kafka/utils/Mx4jLoader.scala	37	11	3264	670	2011-10-06	2018-11-12
core/src/main/scala/kafka/utils/TopicFilter.scala	25	1	816	816	2018-06-19	2018-06-19
core/src/main/scala/kafka/utils/Json.scala	27	13	2891	108	2012-10-13	2020-05-27
core/src/main/scala/kafka/utils/VersionInfo.scala	17	3	841	393	2018-05-25	2019-08-16
core/src/main/scala/kafka/utils/json/JsonValue.scala	40	3	1143	670	2017-07-27	2018-11-12
core/src/main/scala/kafka/utils/json/DecodeJson.scala	61	7	1143	78	2017-07-27	2020-06-26
core/src/main/scala/kafka/utils/json/JsonArray.scala	7	2	1143	164	2017-07-27	2020-04-01
core/src/main/scala/kafka/utils/json/JsonObject.scala	13	3	1143	164	2017-07-27	2020-04-01
core/src/main/scala/kafka/utils/VerifiableProperties.scala	118	17	2940	164	2012-08-25	2020-04-01
core/src/main/scala/kafka/utils/QuotaUtils.scala	22	1	26	26	2020-08-17	2020-08-17
core/src/main/scala/kafka/utils/Pool.scala	38	20	3330	50	2011-08-01	2020-07-24
core/src/main/scala/kafka/utils/CoreUtils.scala	180	34	2199	124	2014-09-05	2020-05-11
core/src/main/scala/kafka/utils/PasswordEncoder.scala	128	2	951	844	2018-02-04	2018-05-22
core/src/main/scala/kafka/utils/Exit.scala	31	4	1318	232	2017-02-02	2020-01-24
core/src/main/scala/kafka/utils/ReplicationUtils.scala	33	17	2286	478	2014-06-10	2019-05-23
core/src/main/scala/kafka/utils/Log4jController.scala	68	7	2940	3	2012-08-25	2020-09-09
core/src/main/scala/kafka/utils/ShutdownableThread.scala	65	12	2944	337	2012-08-21	2019-10-11
core/src/main/scala/kafka/utils/NotNothing.scala	8	1	1296	1296	2017-02-24	2017-02-24
core/src/main/scala/kafka/zookeeper/ZooKeeperClient.scala	414	24	1053	142	2017-10-25	2020-04-23
core/src/main/scala/kafka/controller/StateChangeLogger.scala	19	2	1090	1025	2017-09-18	2017-11-22
core/src/main/scala/kafka/controller/PartitionStateMachine.scala	405	74	2916	99	2012-09-18	2020-06-05
core/src/main/scala/kafka/controller/ControllerState.scala	69	9	1207	296	2017-05-24	2019-11-21
core/src/main/scala/kafka/controller/ControllerChannelManager.scala	569	132	2916	74	2012-09-18	2020-06-30
core/src/main/scala/kafka/controller/Election.scala	90	5	507	324	2019-04-24	2019-10-24
core/src/main/scala/kafka/controller/ControllerContext.scala	363	19	1056	78	2017-10-22	2020-06-26
core/src/main/scala/kafka/controller/ControllerEventManager.scala	114	17	1207	36	2017-05-24	2020-08-07
core/src/main/scala/kafka/controller/TopicDeletionManager.scala	191	37	2410	99	2014-02-06	2020-06-05
core/src/main/scala/kafka/controller/KafkaController.scala	1519	196	2916	8	2012-09-18	2020-09-04
core/src/main/scala/kafka/controller/ReplicaStateMachine.scala	334	78	2916	99	2012-09-18	2020-06-05
core/src/main/scala/kafka/common/InterBrokerSendThread.scala	152	13	1235	25	2017-04-26	2020-08-18
core/src/main/scala/kafka/common/OffsetsOutOfOrderException.scala	3	1	821	821	2018-06-14	2018-06-14
core/src/main/scala/kafka/common/BaseEnum.scala	4	1	1808	1808	2015-10-01	2015-10-01
core/src/main/scala/kafka/common/TopicAlreadyMarkedForDeletionException.scala	3	1	1884	1884	2015-07-17	2015-07-17
core/src/main/scala/kafka/common/OffsetAndMetadata.scala	27	1	717	717	2018-09-26	2018-09-26
core/src/main/scala/kafka/common/LogCleaningAbortedException.scala	3	1	2440	2440	2014-01-07	2014-01-07
core/src/main/scala/kafka/common/ThreadShutdownException.scala	3	1	2440	2440	2014-01-07	2014-01-07
core/src/main/scala/kafka/common/IndexOffsetOverflowException.scala	4	2	827	815	2018-06-08	2018-06-20
core/src/main/scala/kafka/common/UnknownCodecException.scala	4	2	3330	3321	2011-08-01	2011-08-10
core/src/main/scala/kafka/common/StateChangeFailedException.scala	5	2	2916	2894	2012-09-18	2012-10-10
core/src/main/scala/kafka/common/MessageFormatter.scala	4	3	1657	71	2016-02-29	2020-07-03
core/src/main/scala/kafka/common/Config.scala	16	4	2826	393	2012-12-17	2019-08-16
core/src/main/scala/kafka/common/MessageReader.scala	9	2	1657	393	2016-02-29	2019-08-16
core/src/main/scala/kafka/common/GenerateBrokerIdException.scala	6	1	2070	2070	2015-01-12	2015-01-12
core/src/main/scala/kafka/common/RecordValidationException.scala	7	2	338	284	2019-10-10	2019-12-03
core/src/main/scala/kafka/common/UnexpectedAppendOffsetException.scala	5	1	821	821	2018-06-14	2018-06-14
core/src/main/scala/kafka/common/InconsistentBrokerIdException.scala	6	1	2070	2070	2015-01-12	2015-01-12
core/src/main/scala/kafka/common/InconsistentBrokerMetadataException.scala	6	1	395	395	2019-08-14	2019-08-14
core/src/main/scala/kafka/common/LongRef.scala	30	1	1662	1662	2016-02-24	2016-02-24
core/src/main/scala/kafka/common/KafkaException.scala	5	3	2972	448	2012-07-24	2019-06-22
core/src/main/scala/kafka/common/BrokerEndPointNotAvailableException.scala	4	1	1987	1987	2015-04-05	2015-04-05
core/src/main/scala/kafka/common/ClientIdAndTopic.scala	9	2	2826	2124	2012-12-17	2014-11-19
core/src/main/scala/kafka/common/ZkNodeChangeNotificationListener.scala	99	21	1818	78	2015-09-21	2020-06-26
core/src/main/scala/kafka/common/AdminCommandFailedException.scala	5	1	2894	2894	2012-10-10	2012-10-10
core/src/main/scala/kafka/common/ClientIdAndBroker.scala	9	2	2826	2124	2012-12-17	2014-11-19
core/src/main/scala/kafka/common/InconsistentClusterIdException.scala	6	1	395	395	2019-08-14	2019-08-14
core/src/main/scala/kafka/common/NoEpochForPartitionException.scala	4	1	3064	3064	2012-04-23	2012-04-23
core/src/main/scala/kafka/common/LogSegmentOffsetOverflowException.scala	5	3	827	815	2018-06-08	2018-06-20
core/src/main/scala/kafka/api/LeaderAndIsr.scala	26	12	1733	151	2015-12-15	2020-04-14
core/src/main/scala/kafka/api/ApiVersion.scala	252	41	1987	93	2015-04-05	2020-06-11
core/src/main/scala/kafka/api/Request.scala	16	2	816	635	2018-06-19	2018-12-17
core/src/main/scala/kafka/api/package.scala	27	3	472	164	2019-05-29	2020-04-01
core/src/main/scala/kafka/api/ApiUtils.scala	39	10	2891	226	2012-10-13	2020-01-30
core/src/main/scala/kafka/log/LogConfig.scala	301	61	2784	124	2013-01-28	2020-05-11
core/src/main/scala/kafka/log/TransactionIndex.scala	168	8	1225	170	2017-05-06	2020-03-26
core/src/main/scala/kafka/log/LogCleaner.scala	717	98	2784	60	2013-01-28	2020-07-14
core/src/main/scala/kafka/log/LogCleanerManager.scala	392	49	2440	60	2014-01-07	2020-07-14
core/src/main/scala/kafka/log/Log.scala	1638	234	3330	2	2011-08-01	2020-09-10
core/src/main/scala/kafka/log/IndexEntry.scala	17	2	1485	1170	2016-08-19	2017-06-30
core/src/main/scala/kafka/log/AbstractIndex.scala	200	32	1485	68	2016-08-19	2020-07-06
core/src/main/scala/kafka/log/LogValidator.scala	412	37	1369	123	2016-12-13	2020-05-12
core/src/main/scala/kafka/log/CleanerConfig.scala	11	4	2784	1966	2013-01-28	2015-04-26
core/src/main/scala/kafka/log/ProducerStateManager.scala	516	32	1225	164	2017-05-06	2020-04-01
core/src/main/scala/kafka/log/CorruptIndexException.scala	2	1	1005	1005	2017-12-12	2017-12-12
core/src/main/scala/kafka/log/OffsetIndex.scala	107	52	2896	164	2012-10-08	2020-04-01
core/src/main/scala/kafka/log/LazyIndex.scala	89	3	285	170	2019-12-02	2020-03-26
core/src/main/scala/kafka/log/TimeIndex.scala	117	19	1485	164	2016-08-19	2020-04-01
core/src/main/scala/kafka/log/LogSegment.scala	400	89	2896	4	2012-10-08	2020-09-08
core/src/main/scala/kafka/log/OffsetMap.scala	99	10	2784	393	2013-01-28	2019-08-16
core/src/main/scala/kafka/log/LogManager.scala	840	127	3330	44	2011-08-01	2020-07-30
core/src/main/scala/kafka/consumer/BaseConsumerRecord.scala	14	1	816	816	2018-06-19	2018-06-19
streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java	115	3	341	330	2019-10-07	2019-10-18
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java	335	25	900	30	2018-03-27	2020-08-13
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals/TestDriverProducer.java	23	4	177	162	2020-03-19	2020-04-03
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java	762	71	957	25	2018-01-29	2020-08-18
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/KeyValueStoreFacade.java	61	2	556	483	2019-03-06	2019-05-18
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/WindowStoreFacade.java	71	3	556	10	2019-03-06	2020-09-02
streams/test-utils/src/main/java/org/apache/kafka/streams/TestOutputTopic.java	91	3	341	333	2019-10-07	2019-10-15
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala	132	25	873	113	2018-04-23	2020-05-22
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Materialized.scala	23	1	732	732	2018-09-11	2018-09-11
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/CogroupedKStream.scala	16	1	248	248	2020-01-08	2020-01-08
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedCogroupedKStream.scala	10	1	248	248	2020-01-08	2020-01-08
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedKStream.scala	35	9	873	10	2018-04-23	2020-09-02
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Repartitioned.scala	15	1	113	113	2020-05-22	2020-05-22
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedTable.scala	24	10	873	250	2018-04-23	2020-01-06
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Suppressed.scala	28	3	516	250	2019-04-15	2020-01-06
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala	76	14	873	267	2018-04-23	2019-12-20
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Produced.scala	11	1	732	732	2018-09-11	2018-09-11
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/StreamJoined.scala	23	2	346	267	2019-10-02	2019-12-20
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedKStream.scala	32	11	873	10	2018-04-23	2020-09-02
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Consumed.scala	20	1	732	732	2018-09-11	2018-09-11
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/package.scala	11	4	732	113	2018-09-11	2020-05-22
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedCogroupedKStream.scala	10	1	248	248	2020-01-08	2020-01-08
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Grouped.scala	9	2	697	267	2018-10-16	2019-12-20
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedStream.scala	42	14	873	10	2018-04-23	2020-09-02
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Joined.scala	14	2	732	697	2018-09-11	2018-10-16
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/serialization/Serdes.scala	63	1	10	10	2020-09-02	2020-09-02
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/ImplicitConversions.scala	60	11	873	113	2018-04-23	2020-05-22
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/package.scala	8	1	746	746	2018-08-28	2018-08-28
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionConversions.scala	52	7	873	164	2018-04-23	2020-04-01
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala	52	6	858	10	2018-05-08	2020-09-02
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionsCompatConversions.scala	89	8	724	134	2018-09-19	2020-05-01
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala	48	13	873	23	2018-04-23	2020-08-20
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java	40	3	1128	546	2017-08-11	2019-03-16
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java	36	1	1128	1128	2017-08-11	2017-08-11
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java	49	3	1128	814	2017-08-11	2018-06-21
streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java	36	11	1640	436	2016-03-17	2019-07-04
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java	66	22	1640	668	2016-03-17	2018-11-14
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonTimestampExtractor.java	19	5	1656	422	2016-03-01	2019-07-18
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java	158	24	1640	38	2016-03-17	2020-08-05
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java	103	25	1640	21	2016-03-17	2020-08-22
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java	110	2	108	21	2020-05-27	2020-08-22
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java	66	20	1640	21	2016-03-17	2020-08-22
streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java	61	10	1138	586	2017-08-01	2019-02-04
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java	840	127	1695	19	2016-01-22	2020-08-24
streams/src/main/java/org/apache/kafka/streams/Topology.java	309	14	1142	3	2017-07-28	2020-09-09
streams/src/main/java/org/apache/kafka/streams/LagInfo.java	43	1	240	240	2020-01-16	2020-01-16
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java	23	3	272	185	2019-12-15	2020-03-11
streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java	4	5	1345	1200	2017-01-06	2017-05-31
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java	5	10	1800	108	2015-10-09	2020-05-27
streams/src/main/java/org/apache/kafka/streams/kstream/Grouped.java	45	3	711	222	2018-10-02	2020-02-03
streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java	4	10	1684	1075	2016-02-02	2017-10-03
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java	5	2	970	108	2018-01-16	2020-05-27
streams/src/main/java/org/apache/kafka/streams/kstream/Printed.java	52	6	1100	316	2017-09-08	2019-11-01
streams/src/main/java/org/apache/kafka/streams/kstream/Window.java	59	18	1814	641	2015-09-25	2018-12-11
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java	131	29	1710	316	2016-01-07	2019-11-01
streams/src/main/java/org/apache/kafka/streams/kstream/Serialized.java	25	5	1102	641	2017-09-06	2018-12-11
streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java	24	11	287	12	2019-11-30	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java	56	5	918	423	2018-03-09	2019-07-17
streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java	4	12	1710	1075	2016-01-07	2017-10-03
streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java	13	22	1800	134	2015-10-09	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java	39	9	1087	185	2017-09-21	2020-03-11
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java	4	11	1814	970	2015-09-25	2018-01-16
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java	4	11	1814	316	2015-09-25	2019-11-01
streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java	83	5	1101	512	2017-09-07	2019-04-19
streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java	163	3	346	316	2019-10-02	2019-11-01
streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java	38	25	1710	359	2016-01-07	2019-09-19
streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java	35	15	1710	641	2016-01-07	2018-12-11
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java	136	21	1597	359	2016-04-29	2019-09-19
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java	20	7	275	98	2019-12-12	2020-06-06
streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java	5	12	1814	668	2015-09-25	2018-11-14
streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java	5	11	1697	1075	2016-01-20	2017-10-03
streams/src/main/java/org/apache/kafka/streams/kstream/Consumed.java	90	4	849	512	2018-05-17	2019-04-19
streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java	5	11	1814	1200	2015-09-25	2017-05-31
streams/src/main/java/org/apache/kafka/streams/kstream/NamedOperation.java	4	1	542	542	2019-03-20	2019-03-20
streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java	4	9	1618	1118	2016-04-08	2017-08-21
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java	43	20	1800	108	2015-10-09	2020-05-27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapter.java	40	4	594	108	2019-01-27	2020-05-27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java	108	20	1744	134	2015-12-04	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java	119	23	1739	134	2015-12-09	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoin.java	22	5	1423	78	2016-10-20	2020-06-26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionTupleForwarder.java	28	3	488	134	2019-05-13	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java	56	13	1339	134	2017-01-12	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMap.java	23	8	1814	771	2015-09-25	2018-08-03
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValues.java	24	8	1814	771	2015-09-25	2018-08-03
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedKeyValueStoreMaterializer.java	33	1	489	489	2019-05-12	2019-05-12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullChangeSerde.java	52	7	718	78	2018-09-25	2020-06-26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java	157	5	346	3	2019-10-02	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java	128	23	1740	134	2015-12-08	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableSerializer.java	5	2	215	92	2020-02-10	2020-06-12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/Change.java	30	7	1732	451	2015-12-16	2019-06-19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKey.java	31	1	345	345	2019-10-03	2019-10-03
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerde.java	99	4	345	92	2019-10-03	2020-06-12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolverJoinProcessorSupplier.java	70	4	345	136	2019-10-03	2020-04-29
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper.java	67	1	345	345	2019-10-03	2019-10-03
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchema.java	68	4	345	136	2019-10-03	2020-04-29
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplier.java	80	6	345	134	2019-10-03	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionSendProcessorSupplier.java	125	7	345	136	2019-10-03	2020-04-29
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java	77	8	345	134	2019-10-03	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java	37	1	345	345	2019-10-03	2019-10-03
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionJoinForeignProcessorSupplier.java	77	3	345	134	2019-10-03	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java	118	5	345	92	2019-10-03	2020-06-12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedSerializer.java	6	7	1704	918	2016-01-13	2018-03-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedInternal.java	17	2	711	697	2018-10-02	2018-10-16
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableProcessorSupplier.java	6	5	1744	1292	2015-12-04	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java	181	23	1345	298	2017-01-06	2019-11-19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionCacheFlushListener.java	28	3	488	134	2019-05-13	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java	190	1	12	12	2020-08-31	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedDeserializer.java	39	9	1704	92	2016-01-13	2020-06-12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMaterializedValueGetterSupplier.java	31	4	968	483	2018-01-18	2019-05-18
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java	201	35	1549	12	2016-06-16	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java	136	5	275	12	2019-12-12	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImpl.java	117	6	287	12	2019-11-30	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java	947	97	1744	3	2015-12-04	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/StreamJoinedInternal.java	30	1	346	346	2019-10-02	2019-10-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java	67	5	817	232	2018-06-18	2020-01-24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java	132	12	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphNode.java	99	6	817	563	2018-06-18	2019-02-27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java	66	10	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamTableJoinNode.java	35	4	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSinkNode.java	44	5	817	345	2018-06-18	2019-10-03
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java	84	9	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GroupedTableOperationRepartitionNode.java	89	7	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNode.java	50	11	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java	174	10	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseRepartitionNode.java	108	7	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamToTableNode.java	39	3	226	3	2020-01-30	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java	55	5	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StateStoreNode.java	23	4	766	177	2018-08-08	2020-03-19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GlobalStoreNode.java	46	3	766	23	2018-08-08	2020-08-20
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamStreamJoinNode.java	128	4	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java	75	2	155	3	2020-04-10	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorGraphNode.java	27	5	773	3	2018-08-01	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GraphGraceSearchUtil.java	65	4	719	3	2018-09-24	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseJoinProcessorNode.java	54	4	817	3	2018-06-18	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java	211	21	1087	12	2017-09-21	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetterSupplier.java	5	3	1744	1292	2015-12-04	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java	386	37	1139	3	2017-07-31	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java	25	6	1732	771	2015-12-16	2018-08-03
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalNameProvider.java	5	2	1072	512	2017-10-06	2019-04-19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMapValues.java	22	7	1814	970	2015-09-25	2018-01-16
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java	95	11	1732	489	2015-12-16	2019-05-12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedCacheFlushListener.java	32	3	489	134	2019-05-12	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggProcessorSupplier.java	6	2	1657	1292	2016-02-29	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java	50	12	1704	92	2016-01-13	2020-06-12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PassThrough.java	16	1	287	287	2019-11-30	2019-11-30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedTupleForwarder.java	34	4	489	134	2019-05-12	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java	115	4	272	12	2019-12-15	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMap.java	24	8	1814	771	2015-09-25	2018-08-03
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoinValueGetterSupplier.java	22	2	968	957	2018-01-18	2018-01-29
streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinedInternal.java	22	1	542	542	2019-03-20	2019-03-20
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java	79	19	1711	78	2016-01-06	2020-06-26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFilter.java	25	6	1814	771	2015-09-25	2018-08-03
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSourceValueGetterSupplier.java	30	12	1744	345	2015-12-04	2019-10-03
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java	167	33	1657	298	2016-02-29	2019-11-19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ProducedInternal.java	21	4	1097	512	2017-09-11	2019-04-19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintedInternal.java	14	4	1100	512	2017-09-08	2019-04-19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java	220	14	1087	84	2017-09-21	2020-06-20
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/TimeDefinitions.java	45	3	711	67	2018-10-02	2020-07-07
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/StrictBufferConfigImpl.java	94	4	719	199	2018-09-24	2020-02-26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/NamedSuppressed.java	5	1	573	573	2019-02-17	2019-02-17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorSupplier.java	172	4	471	134	2019-05-30	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/EagerBufferConfigImpl.java	78	6	719	199	2018-09-24	2020-02-26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/BufferConfigInternal.java	28	4	711	199	2018-10-02	2020-02-26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/FinalResultsSuppressionBuilder.java	53	6	719	573	2018-09-24	2019-02-17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/BufferFullStrategy.java	6	1	719	719	2018-09-24	2018-09-24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/SuppressedInternal.java	75	8	711	67	2018-10-02	2020-07-07
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindow.java	19	7	1597	396	2016-04-29	2019-08-13
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java	77	16	1697	471	2016-01-20	2019-05-30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java	77	18	1704	134	2016-01-13	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowingDefaults.java	5	1	751	751	2018-08-23	2018-08-23
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedStreamPartitioner.java	16	9	1703	773	2016-01-14	2018-08-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamJoinWindow.java	32	10	1711	770	2016-01-06	2018-08-04
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java	86	19	1704	483	2016-01-13	2019-05-18
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintForeachAction.java	36	3	1100	741	2017-09-08	2018-09-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java	181	34	1605	84	2016-04-21	2020-06-20
streams/src/main/java/org/apache/kafka/streams/kstream/internals/RepartitionedInternal.java	28	2	155	113	2020-04-10	2020-05-22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindow.java	15	6	1340	554	2017-01-11	2019-03-08
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SerializedInternal.java	14	4	1097	670	2017-09-11	2018-11-12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java	116	17	1744	483	2015-12-04	2019-05-18
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoin.java	24	2	1339	1292	2017-01-12	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ConsumedInternal.java	41	5	1100	84	2017-09-08	2020-06-20
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java	107	30	1699	78	2016-01-18	2020-06-26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableDeserializer.java	5	2	215	92	2020-02-10	2020-06-12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetter.java	8	6	1744	134	2015-12-04	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullTimeWindowedSerde.java	14	1	711	711	2018-10-02	2018-10-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java	123	12	957	134	2018-01-29	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GlobalKTableImpl.java	18	4	1339	644	2017-01-12	2018-12-08
streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.java	52	7	1100	644	2017-09-08	2018-12-08
streams/src/main/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindow.java	15	8	1710	396	2016-01-07	2019-08-13
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java	116	6	848	134	2018-05-18	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java	218	7	287	12	2019-11-30	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java	87	20	1090	84	2017-09-18	2020-06-20
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java	113	1	12	12	2020-08-31	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransformValues.java	48	4	515	108	2019-04-16	2020-05-27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPeek.java	26	3	1305	1214	2017-02-15	2017-05-17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java	136	23	1739	134	2015-12-09	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java	1159	109	1814	3	2015-09-25	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamBranch.java	30	5	1814	911	2015-09-25	2018-03-16
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java	101	35	1740	84	2015-12-08	2020-06-20
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java	100	24	1697	323	2016-01-20	2019-10-25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/NamedInternal.java	48	3	512	470	2019-04-19	2019-05-31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPrint.java	27	2	1214	1100	2017-05-17	2017-09-08
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java	115	23	1744	123	2015-12-04	2020-05-12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransform.java	48	4	594	108	2019-01-27	2020-05-27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java	349	2	12	3	2020-08-31	2020-09-09
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java	178	103	1814	85	2015-09-25	2020-06-19
streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java	8	12	1339	127	2017-01-12	2020-05-08
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java	53	3	918	423	2018-03-09	2019-07-17
streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java	62	1	155	155	2020-04-10	2020-04-10
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java	39	27	1605	98	2016-04-21	2020-06-06
streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java	82	22	1710	554	2016-01-07	2019-03-08
streams/src/main/java/org/apache/kafka/streams/kstream/Named.java	47	2	512	484	2019-04-19	2019-05-17
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java	35	38	1549	12	2016-06-16	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java	5	9	1800	108	2015-10-09	2020-05-27
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializer.java	46	2	918	423	2018-03-09	2019-07-17
streams/src/main/java/org/apache/kafka/streams/kstream/Materialized.java	98	10	1100	512	2017-09-08	2019-04-19
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapperWithKey.java	4	1	970	970	2018-01-16	2018-01-16
streams/src/main/java/org/apache/kafka/streams/kstream/Suppressed.java	39	8	719	199	2018-09-24	2020-02-26
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java	140	63	1744	127	2015-12-04	2020-05-08
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java	64	3	918	423	2018-03-09	2019-07-17
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java	84	19	1345	359	2017-01-06	2019-09-19
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java	14	6	970	134	2018-01-16	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java	36	12	1087	98	2017-09-21	2020-06-06
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java	14	20	1800	134	2015-10-09	2020-05-01
streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java	56	3	1710	12	2016-01-07	2020-08-31
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java	52	4	918	177	2018-03-09	2020-03-19
streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java	73	4	1102	316	2017-09-06	2019-11-01
streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java	14	6	1373	278	2016-12-09	2019-12-09
streams/src/main/java/org/apache/kafka/streams/processor/AbstractProcessor.java	16	8	1814	134	2015-09-25	2020-05-01
streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java	6	12	1814	396	2015-09-25	2019-08-13
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java	4	4	1807	396	2015-10-02	2019-08-13
streams/src/main/java/org/apache/kafka/streams/processor/DefaultPartitionGrouper.java	51	19	1783	348	2015-10-26	2019-09-30
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java	44	2	1103	771	2017-09-05	2018-08-03
streams/src/main/java/org/apache/kafka/streams/processor/RecordContext.java	9	1	836	836	2018-05-30	2018-05-30
streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java	10	2	1142	96	2017-07-28	2020-06-08
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java	40	34	1814	3	2015-09-25	2020-09-09
streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java	8	9	1639	278	2016-03-18	2019-12-09
streams/src/main/java/org/apache/kafka/streams/processor/To.java	44	4	911	483	2018-03-16	2019-05-18
streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java	20	7	1373	278	2016-12-09	2019-12-09
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreListener.java	15	3	1142	96	2017-07-28	2020-06-08
streams/src/main/java/org/apache/kafka/streams/processor/Cancellable.java	5	3	1172	709	2017-06-28	2018-10-04
streams/src/main/java/org/apache/kafka/streams/processor/StreamPartitioner.java	6	7	1710	836	2016-01-07	2018-05-30
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRegister.java	7	4	221	86	2020-02-04	2020-06-18
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java	225	3	117	10	2020-05-18	2020-09-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java	420	6	298	19	2019-11-19	2020-08-24
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java	330	13	467	159	2019-06-03	2020-04-06
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java	789	39	873	15	2018-04-23	2020-08-28
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java	282	8	323	15	2019-10-25	2020-08-28
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java	291	22	1494	74	2016-08-10	2020-06-30
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java	33	30	1814	81	2015-09-25	2020-06-23
streams/src/main/java/org/apache/kafka/streams/processor/internals/ToInternal.java	19	1	911	911	2018-03-16	2018-03-16
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java	49	5	998	155	2017-12-19	2020-04-10
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java	11	3	1339	48	2017-01-12	2020-07-26
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java	40	20	1457	34	2016-09-16	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java	248	10	191	80	2020-03-05	2020-06-24
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java	210	75	1762	32	2015-11-16	2020-08-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java	610	59	1296	85	2017-02-24	2020-06-19
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java	229	9	203	155	2020-02-22	2020-04-10
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java	115	7	172	37	2020-03-24	2020-08-06
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java	207	43	1663	37	2016-02-23	2020-08-06
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java	725	232	1814	2	2015-09-25	2020-09-10
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java	65	13	1466	155	2016-09-07	2020-04-10
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java	917	90	1128	31	2017-08-11	2020-08-12
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalApiProcessorContext.java	36	1	34	34	2020-08-09	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java	32	5	1814	641	2015-09-25	2018-12-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java	149	30	1814	34	2015-09-25	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java	19	2	74	65	2020-06-30	2020-07-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java	295	29	1339	38	2017-01-12	2020-08-05
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java	1614	67	1146	3	2017-07-24	2020-09-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/ThreadStateTransitionValidator.java	4	1	1164	1164	2017-07-06	2017-07-06
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java	121	35	1814	34	2015-09-25	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java	168	28	1339	34	2017-01-12	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java	71	10	354	9	2019-09-24	2020-09-03
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java	257	62	1814	34	2015-09-25	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java	1166	58	929	37	2018-02-26	2020-08-06
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java	315	20	370	37	2019-09-08	2020-08-06
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySet.java	55	1	121	121	2020-05-14	2020-05-14
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java	174	8	162	108	2020-04-03	2020-05-27
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/CopartitionedTopicsEnforcer.java	135	2	370	155	2019-09-08	2020-04-10
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.java	265	18	1320	121	2017-01-31	2020-05-14
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignor.java	11	12	1767	121	2015-11-11	2020-05-14
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/FallbackPriorTaskAssignor.java	20	2	137	121	2020-04-28	2020-05-14
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java	407	22	1767	157	2015-11-11	2020-04-08
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java	310	22	1767	57	2015-11-11	2020-07-17
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorError.java	12	3	370	123	2019-09-08	2020-05-12
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java	250	18	1767	175	2015-11-11	2020-03-21
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProtocolVersions.java	7	4	370	190	2019-09-08	2020-03-06
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java	205	10	163	108	2020-04-02	2020-05-27
streams/src/main/java/org/apache/kafka/streams/processor/internals/StaticTopicNameExtractor.java	32	2	836	150	2018-05-30	2020-04-15
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java	93	25	1339	34	2017-01-12	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java	478	92	1814	32	2015-09-25	2020-08-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java	367	38	1339	32	2017-01-12	2020-08-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java	280	23	1516	63	2016-07-19	2020-07-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/QuickUnion.java	39	7	1783	641	2015-10-26	2018-12-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java	68	31	1814	34	2015-09-25	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamPartitioner.java	20	4	1494	173	2016-08-10	2020-03-23
streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.java	66	5	998	155	2017-12-19	2020-04-10
streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java	123	7	848	100	2018-05-18	2020-06-04
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java	6	4	1172	34	2017-06-28	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultKafkaClientSupplier.java	38	8	1590	387	2016-05-06	2019-08-22
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java	22	11	1339	32	2017-01-12	2020-08-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskAction.java	5	2	1117	1041	2017-08-22	2017-11-06
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManager.java	7	4	1339	1006	2017-01-12	2017-12-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java	182	19	1814	34	2015-09-25	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java	90	67	1762	32	2015-11-16	2020-08-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestoreCallbackAdapter.java	31	1	713	713	2018-09-30	2018-09-30
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorAdapter.java	37	3	34	3	2020-08-09	2020-09-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java	227	3	117	10	2020-05-18	2020-09-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/RestoringTasks.java	5	3	1079	659	2017-09-29	2018-11-23
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java	83	30	1128	32	2017-08-11	2020-08-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java	126	5	191	80	2020-03-05	2020-06-24
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java	156	36	1814	23	2015-09-25	2020-08-20
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java	105	12	428	31	2019-07-12	2020-08-12
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordBatchingStateRestoreCallback.java	12	2	713	96	2018-09-30	2020-06-08
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java	174	13	1457	78	2016-09-16	2020-06-26
streams/src/main/java/org/apache/kafka/streams/processor/internals/StampedRecord.java	30	4	1814	771	2015-09-25	2018-08-03
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java	218	46	1376	81	2016-12-06	2020-06-23
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java	105	26	1339	32	2017-01-12	2020-08-11
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java	70	27	1814	34	2015-09-25	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java	75	12	1339	34	2017-01-12	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicProperties.java	20	1	155	155	2020-04-10	2020-04-10
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java	11	12	1296	106	2017-02-24	2020-05-29
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java	57	7	998	155	2017-12-19	2020-04-10
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationQueue.java	38	8	1814	771	2015-09-25	2018-08-03
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java	774	167	1814	19	2015-09-25	2020-08-24
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextAdapter.java	177	3	34	3	2020-08-09	2020-09-09
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationSchedule.java	69	8	1814	771	2015-09-25	2018-08-03
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextReverseAdapter.java	188	1	34	34	2020-08-09	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/Processor.java	7	15	1814	134	2015-09-25	2020-05-01
streams/src/main/java/org/apache/kafka/streams/processor/PartitionGrouper.java	9	12	1783	348	2015-10-26	2019-09-30
streams/src/main/java/org/apache/kafka/streams/processor/TopicNameExtractor.java	4	2	836	396	2018-05-30	2019-08-13
streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java	10	11	1814	710	2015-09-25	2018-10-03
streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java	18	7	1373	278	2016-12-09	2019-12-09
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java	40	3	34	3	2020-08-09	2020-09-09
streams/src/main/java/org/apache/kafka/streams/processor/api/Processor.java	10	1	34	34	2020-08-09	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorSupplier.java	7	1	34	34	2020-08-09	2020-08-09
streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java	66	12	1783	641	2015-10-26	2018-12-11
streams/src/main/java/org/apache/kafka/streams/processor/PunctuationType.java	6	3	1172	709	2017-06-28	2018-10-04
streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java	15	6	1373	278	2016-12-09	2019-12-09
streams/src/main/java/org/apache/kafka/streams/processor/Punctuator.java	5	3	1172	709	2017-06-28	2018-10-04
streams/src/main/java/org/apache/kafka/streams/processor/ConnectedStoreProvider.java	14	2	108	3	2020-05-27	2020-09-09
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorSupplier.java	5	6	1800	108	2015-10-09	2020-05-27
streams/src/main/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestamp.java	16	1	278	278	2019-12-09	2019-12-09
streams/src/main/java/org/apache/kafka/streams/processor/ThreadMetadata.java	99	3	1103	589	2017-09-05	2019-02-01
streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java	43	13	1695	177	2016-01-22	2020-03-19
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java	14	8	1516	21	2016-07-19	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java	80	9	1494	178	2016-08-10	2020-03-18
streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java	11	11	1345	505	2017-01-06	2019-04-26
streams/src/main/java/org/apache/kafka/streams/state/WindowStoreIterator.java	8	10	1713	709	2016-01-04	2018-10-04
streams/src/main/java/org/apache/kafka/streams/state/TimestampedKeyValueStore.java	2	1	561	561	2019-03-01	2019-03-01
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java	9	6	1516	556	2016-07-19	2019-03-06
streams/src/main/java/org/apache/kafka/streams/state/StateSerdes.java	92	11	1640	473	2016-03-17	2019-05-28
streams/src/main/java/org/apache/kafka/streams/state/Stores.java	216	50	1795	124	2015-10-14	2020-05-11
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java	84	25	1713	10	2016-01-04	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/ValueAndTimestamp.java	46	3	561	489	2019-03-01	2019-05-12
streams/src/main/java/org/apache/kafka/streams/state/WindowBytesStoreSupplier.java	10	4	1101	641	2017-09-07	2018-12-11
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java	28	10	1345	10	2017-01-06	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java	123	14	1345	10	2017-01-06	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java	28	8	1317	396	2017-02-03	2019-08-13
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializer.java	85	4	561	123	2019-03-01	2020-05-12
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTrigger.java	39	2	354	134	2019-09-24	2020-05-01
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetrics.java	67	4	355	318	2019-09-23	2019-10-30
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java	532	4	318	15	2019-10-30	2020-08-28
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java	734	7	407	9	2019-08-02	2020-09-03
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java	422	8	382	9	2019-08-27	2020-09-03
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java	151	3	500	10	2019-05-01	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIterator.java	57	8	1457	396	2016-09-16	2019-08-13
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedSegmentedBytesStore.java	10	2	536	382	2019-03-26	2019-08-27
streams/src/main/java/org/apache/kafka/streams/state/internals/BufferValue.java	120	4	471	78	2019-05-30	2020-06-26
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbSessionBytesStoreSupplier.java	39	9	1101	379	2017-09-07	2019-08-30
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java	310	37	1345	21	2017-01-06	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java	358	10	591	10	2019-01-30	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverters.java	37	2	576	469	2019-02-14	2019-06-01
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java	39	4	1101	562	2017-09-07	2019-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerde.java	35	2	561	473	2019-03-01	2019-05-28
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeKeyValueIterator.java	41	3	1121	21	2017-08-18	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/OffsetCheckpoint.java	132	16	1697	44	2016-01-20	2020-07-30
streams/src/main/java/org/apache/kafka/streams/state/internals/CachedStateStore.java	6	6	1457	32	2016-09-16	2020-08-11
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java	86	15	1334	21	2017-01-17	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/ReadOnlyKeyValueStoreFacade.java	37	3	556	21	2019-03-06	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java	7	16	1345	10	2017-01-06	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java	169	6	554	10	2019-03-08	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/Maybe.java	51	2	471	445	2019-05-30	2019-06-25
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java	287	40	1457	21	2016-09-16	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java	239	38	1697	15	2016-01-20	2020-08-28
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java	473	48	1457	10	2016-09-16	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/StateStoreProvider.java	8	3	1516	1292	2016-07-19	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueIteratorFacade.java	28	2	556	483	2019-03-06	2019-05-18
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java	225	22	1113	15	2017-08-26	2020-08-28
streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java	60	10	1457	457	2016-09-16	2019-06-13
streams/src/main/java/org/apache/kafka/streams/state/internals/NextIteratorFunction.java	5	1	1121	1121	2017-08-18	2017-08-18
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java	259	13	536	10	2019-03-26	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java	367	1	359	359	2019-09-19	2019-09-19
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionBytesStoreSupplier.java	33	2	505	379	2019-04-26	2019-08-30
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java	122	25	1685	21	2016-02-01	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java	487	97	1697	15	2016-01-20	2020-08-28
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java	149	17	1317	21	2017-02-03	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java	421	17	710	15	2018-10-03	2020-08-28
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java	119	10	1516	21	2016-07-19	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/FilteredCacheIterator.java	68	4	1278	396	2017-03-14	2019-08-13
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java	89	13	1101	75	2017-09-07	2020-06-29
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.java	27	5	1101	379	2017-09-07	2019-08-30
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java	54	3	1117	278	2017-08-22	2019-12-09
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java	56	16	1345	562	2017-01-06	2019-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/ContextualRecord.java	51	6	711	78	2018-10-02	2020-06-26
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java	106	18	1117	10	2017-08-22	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java	48	3	1117	278	2017-08-22	2019-12-09
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java	181	15	1317	10	2017-02-03	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java	98	17	1516	102	2016-07-19	2020-06-02
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java	31	11	1516	215	2016-07-19	2020-02-10
streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java	15	19	1345	10	2017-01-06	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStore.java	36	5	554	65	2019-03-08	2020-07-09
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegment.java	45	2	536	382	2019-03-26	2019-08-27
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterator.java	135	10	1334	10	2017-01-17	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractStoreBuilder.java	63	4	1101	488	2017-09-07	2019-05-13
streams/src/main/java/org/apache/kafka/streams/state/internals/OrderedBytes.java	32	3	1213	771	2017-05-18	2018-08-03
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java	82	10	1345	10	2017-01-06	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilder.java	41	4	1101	488	2017-09-07	2019-05-13
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegments.java	34	7	536	15	2019-03-26	2020-08-28
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java	483	16	570	10	2019-02-20	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java	51	6	1113	117	2017-08-26	2020-05-18
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java	73	6	1213	396	2017-05-18	2019-08-13
streams/src/main/java/org/apache/kafka/streams/state/internals/ExceptionUtils.java	26	1	168	168	2020-03-28	2020-03-28
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java	51	5	1101	137	2017-09-07	2020-04-28
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIterator.java	36	9	1334	10	2017-01-17	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java	98	40	1697	10	2016-01-20	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreKeyValueIterator.java	47	7	1213	10	2017-05-18	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueByteStoreAdapter.java	94	2	500	21	2019-05-01	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStore.java	51	5	1345	591	2017-01-06	2019-01-30
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java	10	19	1345	382	2017-01-06	2019-08-27
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java	81	11	1685	21	2016-02-01	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/BatchWritingStore.java	9	1	96	96	2020-06-08	2020-06-08
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java	118	1	78	78	2020-06-26	2020-06-26
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegments.java	34	8	596	15	2019-01-25	2020-08-28
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java	68	11	1334	32	2017-01-17	2020-08-11
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegment.java	45	3	596	382	2019-01-25	2019-08-27
streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverter.java	5	2	591	576	2019-01-30	2019-02-14
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreIterator.java	32	3	1125	21	2017-08-14	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java	307	10	505	21	2019-04-26	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueIterators.java	37	2	1213	396	2017-05-18	2019-08-13
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java	76	6	561	65	2019-03-01	2020-07-09
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedCacheFunction.java	56	4	1213	514	2017-05-18	2019-04-17
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowBytesStoreSupplier.java	65	4	570	346	2019-02-20	2019-10-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheSessionStoreIterator.java	39	10	1334	21	2017-01-17	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java	60	3	591	21	2019-01-30	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java	190	17	1516	10	2016-07-19	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractSegments.java	187	5	596	10	2019-01-25	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedWindowStore.java	9	1	500	500	2019-05-01	2019-05-01
streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFunction.java	6	1	1213	1213	2017-05-18	2017-05-18
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBuffer.java	54	3	710	471	2018-10-03	2019-05-30
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBRangeIterator.java	55	2	591	21	2019-01-30	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesStore.java	20	2	554	117	2019-03-08	2020-05-18
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java	1111	4	591	332	2019-01-30	2019-10-16
streams/src/main/java/org/apache/kafka/streams/state/internals/BlockBasedTableConfigWithAccessibleCache.java	14	1	30	30	2020-08-13	2020-08-13
streams/src/main/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProvider.java	33	4	1339	494	2017-01-12	2019-05-07
streams/src/main/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreFacade.java	109	3	556	10	2019-03-06	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/HasNextCondition.java	6	2	1345	1292	2017-01-06	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java	259	29	1457	21	2016-09-16	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java	47	13	1516	102	2016-07-19	2020-06-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java	231	34	1697	10	2016-01-20	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java	297	29	1457	21	2016-09-16	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampDeserializer.java	54	1	561	561	2019-03-01	2019-03-01
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java	139	4	561	21	2019-03-01	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueBytesStore.java	19	3	561	117	2019-03-01	2020-05-18
streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFlushListener.java	4	1	602	602	2019-01-19	2019-01-19
streams/src/main/java/org/apache/kafka/streams/state/internals/BufferKey.java	45	1	471	471	2019-05-30	2019-05-30
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueIteratorAdapter.java	27	1	500	500	2019-05-01	2019-05-01
streams/src/main/java/org/apache/kafka/streams/state/internals/PeekingKeyValueIterator.java	6	3	1457	1292	2016-09-16	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java	25	16	1516	10	2016-07-19	2020-09-02
streams/src/main/java/org/apache/kafka/streams/state/StoreSupplier.java	7	1	1101	1101	2017-09-07	2017-09-07
streams/src/main/java/org/apache/kafka/streams/state/TimestampedWindowStore.java	3	1	556	556	2019-03-06	2019-03-06
streams/src/main/java/org/apache/kafka/streams/state/KeyValueIterator.java	9	9	1814	396	2015-09-25	2019-08-13
streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java	10	14	1814	21	2015-09-25	2020-08-22
streams/src/main/java/org/apache/kafka/streams/state/KeyValueBytesStoreSupplier.java	4	4	1101	641	2017-09-07	2018-12-11
streams/src/main/java/org/apache/kafka/streams/state/HostInfo.java	63	7	1494	178	2016-08-10	2020-03-18
streams/src/main/java/org/apache/kafka/streams/state/StoreBuilder.java	13	3	1101	725	2017-09-07	2018-09-18
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java	6	8	1345	591	2017-01-06	2019-01-30
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java	102	10	1516	185	2016-07-19	2020-03-11
streams/src/main/java/org/apache/kafka/streams/state/TimestampedBytesStore.java	15	2	591	500	2019-01-30	2019-05-01
streams/src/main/java/org/apache/kafka/streams/state/SessionBytesStoreSupplier.java	6	4	1101	725	2017-09-07	2018-09-18
streams/src/main/java/org/apache/kafka/streams/state/RocksDBConfigSetter.java	12	6	1514	432	2016-07-21	2019-07-08
streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java	37	8	1146	3	2017-07-24	2020-09-09
streams/src/main/java/org/apache/kafka/streams/internals/metrics/ClientMetrics.java	97	2	343	159	2019-10-05	2020-04-06
streams/src/main/java/org/apache/kafka/streams/internals/ApiUtils.java	34	4	709	638	2018-10-04	2018-12-14
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java	195	34	1139	23	2017-07-31	2020-08-20
streams/src/main/java/org/apache/kafka/streams/StoreQueryParameters.java	61	2	215	85	2020-02-10	2020-06-19
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java	713	132	1695	30	2016-01-22	2020-08-13
streams/src/main/java/org/apache/kafka/streams/errors/UnknownStateStoreException.java	10	1	51	51	2020-07-23	2020-07-23
streams/src/main/java/org/apache/kafka/streams/errors/TaskCorruptedException.java	21	3	205	85	2020-02-20	2020-06-19
streams/src/main/java/org/apache/kafka/streams/errors/MissingSourceTopicException.java	7	1	9	9	2020-09-03	2020-09-03
streams/src/main/java/org/apache/kafka/streams/errors/TaskMigratedException.java	10	7	1079	81	2017-09-29	2020-06-23
streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java	13	5	1691	1200	2016-01-26	2017-05-31
streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java	22	3	1160	897	2017-07-10	2018-03-30
streams/src/main/java/org/apache/kafka/streams/errors/DeserializationExceptionHandler.java	19	1	1160	1160	2017-07-10	2017-07-10
streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java	13	2	1240	1200	2017-04-21	2017-05-31
streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java	13	5	1691	1200	2016-01-26	2017-05-31
streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java	22	3	1160	897	2017-07-10	2018-03-30
streams/src/main/java/org/apache/kafka/streams/errors/LockException.java	13	4	1369	1200	2016-12-13	2017-05-31
streams/src/main/java/org/apache/kafka/streams/errors/StateStoreNotAvailableException.java	10	1	51	51	2020-07-23	2020-07-23
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java	13	5	1466	51	2016-09-07	2020-07-23
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStorePartitionException.java	11	1	51	51	2020-07-23	2020-07-23
streams/src/main/java/org/apache/kafka/streams/errors/TopologyException.java	14	1	1142	1142	2017-07-28	2017-07-28
streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java	14	4	1691	1200	2016-01-26	2017-05-31
streams/src/main/java/org/apache/kafka/streams/errors/StreamsRebalancingException.java	10	1	51	51	2020-07-23	2020-07-23
streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java	13	1	1002	1002	2017-12-15	2017-12-15
streams/src/main/java/org/apache/kafka/streams/errors/ProductionExceptionHandler.java	18	1	1002	1002	2017-12-15	2017-12-15
streams/src/main/java/org/apache/kafka/streams/errors/TaskAssignmentException.java	13	4	1691	1292	2016-01-26	2017-02-28
streams/src/main/java/org/apache/kafka/streams/errors/StateStoreMigratedException.java	10	1	51	51	2020-07-23	2020-07-23
streams/src/main/java/org/apache/kafka/streams/errors/StreamsNotStartedException.java	12	2	51	17	2020-07-23	2020-08-26
streams/src/main/java/org/apache/kafka/streams/KafkaClientSupplier.java	24	12	1590	387	2016-05-06	2019-08-22
streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java	60	3	297	37	2019-11-20	2020-08-06
streams/src/main/java/org/apache/kafka/streams/KeyValue.java	32	8	1695	492	2016-01-22	2019-05-09
generator/src/main/java/org/apache/kafka/message/MessageSpec.java	83	5	599	17	2019-01-22	2020-08-26
generator/src/main/java/org/apache/kafka/message/MessageClassGenerator.java	6	1	17	17	2020-08-26	2020-08-26
generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java	373	1	17	17	2020-08-26	2020-08-26
generator/src/main/java/org/apache/kafka/message/VersionConditional.java	159	2	353	342	2019-09-25	2019-10-06
generator/src/main/java/org/apache/kafka/message/HeaderGenerator.java	63	3	599	353	2019-01-22	2019-09-25
generator/src/main/java/org/apache/kafka/message/MessageSpecType.java	12	2	599	316	2019-01-22	2019-11-01
generator/src/main/java/org/apache/kafka/message/ApiMessageTypeGenerator.java	295	6	526	59	2019-04-05	2020-07-15
generator/src/main/java/org/apache/kafka/message/EntityType.java	35	1	494	494	2019-05-07	2019-05-07
generator/src/main/java/org/apache/kafka/message/FieldType.java	332	10	599	17	2019-01-22	2020-08-26
generator/src/main/java/org/apache/kafka/message/ClauseGenerator.java	4	1	353	353	2019-09-25	2019-09-25
generator/src/main/java/org/apache/kafka/message/IsNullConditional.java	94	2	353	156	2019-09-25	2020-04-09
generator/src/main/java/org/apache/kafka/message/MessageGenerator.java	257	12	599	17	2019-01-22	2020-08-26
generator/src/main/java/org/apache/kafka/message/StructSpec.java	67	2	599	342	2019-01-22	2019-10-06
generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java	1856	28	599	17	2019-01-22	2020-08-26
generator/src/main/java/org/apache/kafka/message/SchemaGenerator.java	274	10	599	17	2019-01-22	2020-08-26
generator/src/main/java/org/apache/kafka/message/Versions.java	120	3	599	353	2019-01-22	2019-09-25
generator/src/main/java/org/apache/kafka/message/FieldSpec.java	496	11	599	17	2019-01-22	2020-08-26
generator/src/main/java/org/apache/kafka/message/CodeBuffer.java	53	1	599	599	2019-01-22	2019-01-22
generator/src/main/java/org/apache/kafka/message/Target.java	67	1	156	156	2020-04-09	2020-04-09
generator/src/main/java/org/apache/kafka/message/TypeClassGenerator.java	8	1	59	59	2020-07-15	2020-07-15
generator/src/main/java/org/apache/kafka/message/StructRegistry.java	129	4	438	2	2019-07-02	2020-09-10
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRecordBenchmark.java	25	2	1196	670	2017-06-04	2018-11-12
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java	151	5	1200	160	2017-05-31	2020-04-05
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/cache/LRUCacheBenchmark.java	47	3	1286	380	2017-03-06	2019-08-29
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java	262	3	332	171	2019-10-16	2020-03-25
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/CheckpointBench.java	145	2	140	48	2020-04-25	2020-07-26
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/TopicBenchmark.java	31	1	1194	1194	2017-06-06	2017-06-06
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchRequestBenchmark.java	94	1	44	44	2020-07-30	2020-07-30
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchResponseBenchmark.java	75	1	44	44	2020-07-30	2020-07-30
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetchsession/FetchSessionBenchmark.java	87	1	332	332	2019-10-16	2019-10-16
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/consumer/SubscriptionStateBenchmark.java	69	1	22	22	2020-08-21	2020-08-21
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java	147	5	360	108	2019-09-18	2020-05-27
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java	146	2	199	171	2020-02-26	2020-03-25
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/MetadataRequestBenchmark.java	175	3	180	25	2020-03-16	2020-08-18
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/AclAuthorizerBenchmark.java	127	4	193	25	2020-03-03	2020-08-18
examples/src/main/java/kafka/examples/KafkaProperties.java	7	7	3330	205	2011-08-01	2020-02-20
examples/src/main/java/kafka/examples/Consumer.java	70	17	3330	205	2011-08-01	2020-02-20
examples/src/main/java/kafka/examples/Producer.java	94	16	3330	204	2011-08-01	2020-02-21
examples/src/main/java/kafka/examples/KafkaConsumerProducerDemo.java	20	11	3330	205	2011-08-01	2020-02-20
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java	127	3	220	205	2020-02-05	2020-02-20
examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java	107	4	220	205	2020-02-05	2020-02-20
log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java	292	14	1895	23	2015-07-06	2020-08-20
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java	183	10	1770	808	2015-11-08	2018-06-27
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkConnector.java	49	5	1770	939	2015-11-08	2018-02-16
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkTask.java	67	6	1770	785	2015-11-08	2018-07-20
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java	64	6	1770	939	2015-11-08	2018-02-16
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkTask.java	53	3	1543	1292	2016-06-22	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkTask.java	74	2	1766	1292	2015-11-12	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceConnector.java	41	3	1766	1292	2015-11-12	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkConnector.java	51	2	1543	1292	2016-06-22	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceTask.java	45	3	1543	1292	2016-06-22	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceConnector.java	51	2	1543	1292	2016-06-22	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/TransformationDoc.java	63	7	1331	88	2017-01-20	2020-06-16
connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java	135	6	1527	173	2016-07-08	2020-03-23
connect/runtime/src/main/java/org/apache/kafka/connect/tools/PredicateDoc.java	55	1	88	88	2020-06-16	2020-06-16
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkConnector.java	41	3	1766	1292	2015-11-12	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockConnector.java	71	3	1543	1292	2016-06-22	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java	103	5	1766	114	2015-11-12	2020-05-21
connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceConnector.java	41	2	1527	1292	2016-07-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/LoggingContext.java	81	1	485	485	2019-05-16	2019-05-16
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConvertingFutureCallback.java	87	3	1770	298	2015-11-08	2019-11-19
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreationGroup.java	87	1	109	109	2020-05-26	2020-05-26
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java	50	4	1770	492	2015-11-08	2019-05-09
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java	229	14	1770	96	2015-11-08	2020-06-08
connect/runtime/src/main/java/org/apache/kafka/connect/util/Table.java	42	3	1663	211	2016-02-23	2020-02-14
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectUtils.java	66	9	1308	93	2017-02-12	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/util/SafeObjectInputStream.java	43	1	1149	1149	2017-07-21	2017-07-21
connect/runtime/src/main/java/org/apache/kafka/connect/util/ShutdownableThread.java	58	2	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/FutureCallback.java	13	2	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/Callback.java	4	2	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreation.java	63	1	109	109	2020-05-26	2020-05-26
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java	336	10	1213	94	2017-05-18	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/util/SinkUtils.java	7	2	1400	1292	2016-11-12	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java	411	28	1770	100	2015-11-08	2020-06-04
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderRequest.java	4	1	836	836	2018-05-30	2018-05-30
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java	568	49	1770	94	2015-11-08	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicStatus.java	57	1	226	226	2020-01-30	2020-01-30
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java	537	41	1663	93	2016-02-23	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java	352	29	1770	93	2015-11-08	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneConfig.java	19	4	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/RebalanceNeededException.java	7	2	1606	1292	2016-04-20	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java	457	30	1770	95	2015-11-08	2020-06-09
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ExtendedWorkerState.java	19	1	485	485	2019-05-16	2019-05-16
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java	209	5	1770	227	2015-11-08	2020-01-29
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerRebalanceListener.java	7	4	1770	485	2015-11-08	2019-05-16
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/NotAssignedException.java	6	2	1608	1292	2016-04-18	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocolCompatibility.java	70	2	485	346	2019-05-16	2019-10-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java	1446	57	1770	93	2015-11-08	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java	383	23	1770	74	2015-11-08	2020-06-30
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectAssignor.java	10	1	485	485	2019-05-16	2019-05-16
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java	172	10	1770	115	2015-11-08	2020-05-20
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeConnectProtocol.java	124	2	485	346	2019-05-16	2019-10-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ExtendedAssignment.java	189	2	485	95	2019-05-16	2020-06-09
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/RequestTargetException.java	20	2	1608	1292	2016-04-18	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/NotLeaderException.java	6	3	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java	181	39	1770	74	2015-11-08	2020-06-30
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java	545	6	485	93	2019-05-16	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/EagerAssignor.java	127	1	485	485	2019-05-16	2019-05-16
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java	311	23	1770	94	2015-11-08	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskStatus.java	18	4	1663	110	2016-02-23	2020-05-25
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTaskContext.java	25	3	1770	836	2015-11-08	2018-05-30
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java	76	17	1770	93	2015-11-08	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/health/ConnectClusterDetailsImpl.java	12	1	492	492	2019-05-09	2019-05-09
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/health/ConnectClusterStateImpl.java	86	7	837	112	2018-05-29	2020-05-23
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java	130	9	1588	27	2016-05-08	2020-08-16
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java	414	18	1606	93	2016-04-20	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractStatus.java	71	4	1663	731	2016-02-23	2018-09-12
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/StateTracker.java	96	2	1082	1075	2017-09-26	2017-10-03
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java	125	13	1588	94	2016-05-08	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java	355	4	1074	346	2017-10-04	2019-10-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java	843	59	1770	93	2015-11-08	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/PredicatedTransformation.java	50	1	107	107	2020-05-28	2020-05-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/CloseableConnectorContext.java	7	1	93	93	2020-06-11	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java	221	12	1086	108	2017-09-22	2020-05-27
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java	355	13	1213	107	2017-05-18	2020-05-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java	405	20	1213	107	2017-05-18	2020-05-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java	268	16	1213	94	2017-05-18	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginDesc.java	80	2	1213	1187	2017-05-18	2017-06-13
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanResult.java	76	7	1213	107	2017-05-18	2020-05-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginType.java	40	5	1213	484	2017-05-18	2019-05-17
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java	50	3	1213	965	2017-05-18	2018-01-21
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java	44	1	108	108	2020-05-27	2020-05-27
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java	31	1	346	346	2019-10-02	2019-10-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TargetState.java	5	2	1606	1292	2016-04-20	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicCreationConfig.java	112	1	109	109	2020-05-26	2020-05-26
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderConnectorContext.java	38	5	1770	93	2015-11-08	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java	79	7	1770	225	2015-11-08	2020-01-31
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerInfo.java	63	1	1081	1081	2017-09-27	2017-09-27
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java	688	55	1770	61	2015-11-08	2020-07-13
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorStatus.java	17	3	1663	1292	2016-02-23	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfigTransformer.java	77	7	836	135	2018-05-30	2020-04-30
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java	441	31	1770	94	2015-11-08	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/Stage.java	11	1	836	836	2018-05-30	2018-05-30
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ToleranceType.java	9	2	836	830	2018-05-30	2018-06-05
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/Operation.java	4	1	836	836	2018-05-30	2018-05-30
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorReporter.java	8	5	836	108	2018-05-30	2020-05-27
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorHandlingMetrics.java	68	3	836	212	2018-05-30	2020-02-13
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/DeadLetterQueueReporter.java	155	10	836	108	2018-05-30	2020-05-27
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/LogReporter.java	40	4	836	108	2018-05-30	2020-05-27
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporter.java	110	2	108	94	2020-05-27	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java	185	6	836	94	2018-05-30	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ProcessingContext.java	136	3	836	108	2018-05-30	2020-05-27
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java	54	5	1339	109	2017-01-12	2020-05-26
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTaskContext.java	128	9	1770	108	2015-11-08	2020-05-27
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java	23	3	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java	74	10	1770	94	2015-11-08	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/ConnectRestConfigurable.java	96	2	837	670	2018-05-29	2018-11-12
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java	351	25	1770	111	2015-11-08	2020-05-24
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/util/SSLUtils.java	96	9	956	87	2018-01-30	2020-06-17
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java	92	11	1640	93	2016-03-17	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResource.java	128	1	346	346	2019-10-02	2019-10-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java	337	26	1770	93	2015-11-08	2020-06-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/RootResource.java	20	5	1770	494	2015-11-08	2019-05-07
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/ConnectRestExtensionContextImpl.java	23	1	837	837	2018-05-29	2018-05-29
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/errors/ConnectRestException.java	39	2	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/errors/BadRequestException.java	7	2	1400	1292	2016-11-12	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/errors/ConnectExceptionMapper.java	49	3	1770	1027	2015-11-08	2017-11-20
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/TaskInfo.java	33	2	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorType.java	28	1	1220	1220	2017-05-11	2017-05-11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorPluginInfo.java	62	4	1632	1213	2016-03-25	2017-05-18
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ServerInfo.java	32	4	1770	537	2015-11-08	2019-03-25
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigInfo.java	39	2	1640	1292	2016-03-17	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequest.java	34	2	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorInfo.java	53	6	1770	612	2015-11-08	2019-01-09
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigValueInfo.java	76	3	1640	1292	2016-03-17	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorStateInfo.java	101	5	1663	607	2016-02-23	2019-01-14
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ErrorMessage.java	33	3	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ActiveTopicsInfo.java	20	1	226	226	2020-01-30	2020-01-30
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigKeyInfo.java	135	3	1640	1292	2016-03-17	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigInfos.java	69	2	1640	1292	2016-03-17	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java	131	5	956	346	2018-01-30	2019-10-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java	99	1	346	346	2019-10-02	2019-10-02
connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverterConfig.java	13	1	820	820	2018-06-15	2018-06-15
connect/runtime/src/main/java/org/apache/kafka/connect/converters/LongConverter.java	11	1	820	820	2018-06-15	2018-06-15
connect/runtime/src/main/java/org/apache/kafka/connect/converters/ShortConverter.java	11	1	820	820	2018-06-15	2018-06-15
connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverter.java	81	2	820	670	2018-06-15	2018-11-12
connect/runtime/src/main/java/org/apache/kafka/connect/converters/FloatConverter.java	11	1	820	820	2018-06-15	2018-06-15
connect/runtime/src/main/java/org/apache/kafka/connect/converters/IntegerConverter.java	11	1	820	820	2018-06-15	2018-06-15
connect/runtime/src/main/java/org/apache/kafka/connect/converters/DoubleConverter.java	11	1	820	820	2018-06-15	2018-06-15
connect/runtime/src/main/java/org/apache/kafka/connect/converters/ByteArrayConverter.java	45	3	1278	955	2017-03-14	2018-01-31
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java	90	21	1770	484	2015-11-08	2019-05-17
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java	90	18	1770	484	2015-11-08	2019-05-17
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReaderImpl.java	119	5	1770	298	2015-11-08	2019-11-19
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java	192	15	1770	94	2015-11-08	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/storage/FileOffsetBackingStore.java	70	9	1770	808	2015-11-08	2018-06-27
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java	512	21	1606	94	2016-04-20	2020-06-10
connect/runtime/src/main/java/org/apache/kafka/connect/storage/StatusBackingStore.java	26	5	1663	226	2016-02-23	2020-01-30
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetUtils.java	31	4	1770	1292	2015-11-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java	100	4	1663	226	2016-02-23	2020-01-30
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryOffsetBackingStore.java	78	7	1770	225	2015-11-08	2020-01-31
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java	130	6	1606	346	2016-04-20	2019-10-02
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java	102	6	1770	670	2015-11-08	2018-11-12
connect/runtime/src/main/java/org/apache/kafka/connect/storage/CloseableOffsetStorageReader.java	8	1	298	298	2019-11-19	2019-11-19
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetBackingStore.java	14	5	1770	298	2015-11-08	2019-11-19
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConfigBackingStore.java	31	5	1606	346	2016-04-20	2019-10-02
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java	540	18	1663	53	2016-02-23	2020-07-21
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/PrincipalConnectorClientConfigOverridePolicy.java	29	2	484	481	2019-05-17	2019-05-20
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/AllConnectorClientConfigOverridePolicy.java	20	2	484	481	2019-05-17	2019-05-20
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/NoneConnectorClientConfigOverridePolicy.java	20	2	484	481	2019-05-17	2019-05-20
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/AbstractConnectorClientConfigOverridePolicy.java	30	1	484	484	2019-05-17	2019-05-17
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/PropertyFileLoginModule.java	113	3	829	111	2018-06-06	2020-05-24
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/BasicAuthSecurityRestExtension.java	27	2	829	111	2018-06-06	2020-05-24
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java	110	3	829	111	2018-06-06	2020-05-24
connect/json/src/main/java/org/apache/kafka/connect/json/DecimalFormat.java	5	1	347	347	2019-10-01	2019-10-01
connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java	34	5	1770	128	2015-11-08	2020-05-07
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java	32	4	1770	128	2015-11-08	2020-05-07
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java	656	20	1770	128	2015-11-08	2020-05-07
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSchema.java	58	2	1770	1292	2015-11-08	2017-02-28
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java	63	2	955	347	2018-01-31	2019-10-01
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.java	48	2	107	88	2020-05-28	2020-06-16
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKey.java	38	2	107	88	2020-05-28	2020-06-16
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/RecordIsTombstone.java	26	2	107	88	2020-05-28	2020-06-16
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java	69	5	1339	666	2017-01-12	2018-11-16
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/RegexValidator.java	18	2	1331	1292	2017-01-20	2017-02-28
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SimpleConfig.java	9	2	1339	1292	2017-01-12	2017-02-28
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidator.java	16	3	1331	1217	2017-01-20	2017-05-14
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/Requirements.java	48	5	1331	1135	2017-01-20	2017-08-04
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java	19	3	1331	1215	2017-01-20	2017-05-16
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java	218	5	1215	166	2017-05-16	2020-03-30
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java	85	4	1331	244	2017-01-20	2020-01-12
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java	101	5	1331	653	2017-01-20	2018-11-29
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java	173	5	1331	213	2017-01-20	2020-02-12
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java	357	4	1212	244	2017-05-19	2020-01-12
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java	162	4	1331	111	2017-01-20	2020-05-24
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java	211	7	1339	170	2017-01-12	2020-03-26
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java	383	7	1215	244	2017-05-16	2020-01-12
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/RegexRouter.java	46	2	1331	1292	2017-01-20	2017-02-28
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ValueToKey.java	79	4	1331	235	2017-01-20	2020-01-21
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Filter.java	24	1	107	107	2020-05-28	2020-05-28
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java	80	5	1331	214	2017-01-20	2020-02-11
connect/api/src/main/java/org/apache/kafka/connect/util/ConnectorUtils.java	23	3	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectClusterDetails.java	4	1	492	492	2019-05-09	2019-05-09
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorType.java	11	1	837	837	2018-05-29	2018-05-29
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java	61	2	837	333	2018-05-29	2019-10-15
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectClusterState.java	13	2	837	492	2018-05-29	2019-05-09
connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java	42	2	837	333	2018-05-29	2019-10-15
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java	36	2	837	333	2018-05-29	2019-10-15
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorState.java	14	2	837	333	2018-05-29	2019-10-15
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnectorContext.java	6	1	110	110	2020-05-25	2020-05-25
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java	8	4	1770	110	2015-11-08	2020-05-25
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java	25	12	1770	114	2015-11-08	2020-05-21
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java	7	4	1770	836	2015-11-08	2018-05-30
connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java	84	8	1770	492	2015-11-08	2019-05-09
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java	17	7	1770	99	2015-11-08	2020-06-05
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnectorContext.java	4	1	110	110	2020-05-25	2020-05-25
connect/api/src/main/java/org/apache/kafka/connect/sink/ErrantRecordReporter.java	6	1	108	108	2020-05-27	2020-05-27
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java	37	8	1770	887	2015-11-08	2018-04-09
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java	9	4	1770	110	2015-11-08	2020-05-25
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java	64	7	1770	492	2015-11-08	2019-05-09
connect/api/src/main/java/org/apache/kafka/connect/storage/SimpleHeaderConverter.java	54	1	955	955	2018-01-31	2018-01-31
connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverter.java	65	3	1770	955	2015-11-08	2018-01-31
connect/api/src/main/java/org/apache/kafka/connect/storage/HeaderConverter.java	12	2	955	946	2018-01-31	2018-02-09
connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java	16	6	1770	234	2015-11-08	2020-01-22
connect/api/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReader.java	7	3	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/storage/ConverterConfig.java	22	1	955	955	2018-01-31	2018-01-31
connect/api/src/main/java/org/apache/kafka/connect/storage/ConverterType.java	32	1	955	955	2018-01-31	2018-01-31
connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverterConfig.java	27	1	955	955	2018-01-31	2018-01-31
connect/api/src/main/java/org/apache/kafka/connect/components/Versioned.java	4	1	837	837	2018-05-29	2018-05-29
connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/Predicate.java	10	1	107	107	2020-05-28	2020-05-28
connect/api/src/main/java/org/apache/kafka/connect/transforms/Transformation.java	11	2	1339	1292	2017-01-12	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java	106	11	1770	647	2015-11-08	2018-12-05
connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java	39	8	1770	110	2015-11-08	2020-05-25
connect/api/src/main/java/org/apache/kafka/connect/connector/Task.java	7	3	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectorContext.java	5	4	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/connector/policy/ConnectorClientConfigRequest.java	41	1	484	484	2019-05-17	2019-05-17
connect/api/src/main/java/org/apache/kafka/connect/connector/policy/ConnectorClientConfigOverridePolicy.java	7	1	484	484	2019-05-17	2019-05-17
connect/api/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java	12	2	1769	1292	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/DataException.java	12	2	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/ConnectException.java	13	3	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/IllegalWorkerStateException.java	12	2	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/SchemaBuilderException.java	12	2	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/SchemaProjectorException.java	12	2	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java	12	2	1769	1292	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/RetriableException.java	12	2	1769	1292	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/data/Values.java	931	9	955	156	2018-01-31	2020-04-09
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaBuilder.java	228	14	1770	235	2015-11-08	2020-01-21
connect/api/src/main/java/org/apache/kafka/connect/data/Timestamp.java	21	4	1770	1031	2015-11-08	2017-11-16
connect/api/src/main/java/org/apache/kafka/connect/data/Schema.java	72	4	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/data/Decimal.java	35	3	1770	1271	2015-11-08	2017-03-21
connect/api/src/main/java/org/apache/kafka/connect/data/Time.java	33	3	1770	1031	2015-11-08	2017-11-16
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaProjector.java	150	4	1770	709	2015-11-08	2018-10-04
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java	239	15	1770	95	2015-11-08	2020-06-09
connect/api/src/main/java/org/apache/kafka/connect/data/Field.java	42	3	1770	952	2015-11-08	2018-02-03
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaAndValue.java	36	2	1770	1292	2015-11-08	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/data/Date.java	32	3	1770	1031	2015-11-08	2017-11-16
connect/api/src/main/java/org/apache/kafka/connect/data/Struct.java	138	8	1770	943	2015-11-08	2018-02-12
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java	404	4	955	245	2018-01-31	2020-01-11
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeader.java	64	1	955	955	2018-01-31	2018-01-31
connect/api/src/main/java/org/apache/kafka/connect/header/Headers.java	44	2	955	526	2018-01-31	2019-04-05
connect/api/src/main/java/org/apache/kafka/connect/header/Header.java	9	1	955	955	2018-01-31	2018-01-31
connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtensionContext.java	7	1	837	837	2018-05-29	2018-05-29
connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtension.java	9	1	837	837	2018-05-29	2018-05-29
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClient.java	168	1	341	341	2019-10-07	2019-10-07
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java	82	2	341	170	2019-10-07	2020-03-26
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/DefaultReplicationPolicy.java	43	1	341	341	2019-10-07	2019-10-07
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/RemoteClusterUtils.java	41	2	341	170	2019-10-07	2020-03-26
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/SourceAndTarget.java	27	1	341	341	2019-10-07	2019-10-07
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Heartbeat.java	105	1	341	341	2019-10-07	2019-10-07
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Checkpoint.java	140	1	341	341	2019-10-07	2019-10-07
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java	20	1	341	341	2019-10-07	2019-10-07
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorUtils.java	78	1	341	341	2019-10-07	2019-10-07
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceTask.java	241	1	341	341	2019-10-07	2019-10-07
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/Scheduler.java	85	3	341	170	2019-10-07	2020-03-26
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultGroupFilter.java	58	1	341	341	2019-10-07	2019-10-07
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/ConfigPropertyFilter.java	12	1	341	341	2019-10-07	2019-10-07
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java	252	5	341	78	2019-10-07	2020-06-26
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/HeartbeatFormatter.java	11	1	71	71	2020-07-03	2020-07-03
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/CheckpointFormatter.java	11	1	71	71	2020-07-03	2020-07-03
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/OffsetSyncFormatter.java	11	1	71	71	2020-07-03	2020-07-03
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java	53	1	341	341	2019-10-07	2019-10-07
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultTopicFilter.java	58	1	341	341	2019-10-07	2019-10-07
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultConfigPropertyFilter.java	48	1	341	341	2019-10-07	2019-10-07
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMetrics.java	159	3	341	170	2019-10-07	2020-03-26
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java	529	5	341	78	2019-10-07	2020-06-26
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatConnector.java	50	2	341	226	2019-10-07	2020-01-30
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatTask.java	56	2	341	114	2019-10-07	2020-05-21
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java	223	4	341	170	2019-10-07	2020-03-26
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorTaskConfig.java	50	2	341	115	2019-10-07	2020-05-20
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/TopicFilter.java	12	1	341	341	2019-10-07	2019-10-07
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java	172	2	341	170	2019-10-07	2020-03-26
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java	125	2	341	226	2019-10-07	2020-01-30
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/GroupFilter.java	12	1	341	341	2019-10-07	2019-10-07
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java	350	4	341	99	2019-10-07	2020-06-05
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSync.java	83	2	341	71	2019-10-07	2020-07-03