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/ApiVersions.java	32	3	1774	1459	2017-03-24	2018-02-02
clients/src/main/java/org/apache/kafka/clients/ClientRequest.java	63	14	2791	1459	2014-06-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/ClientResponse.java	72	7	2791	1459	2014-06-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/ClientUtils.java	61	21	2554	1459	2015-02-03	2018-02-02
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java	143	18	2791	1459	2014-06-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java	62	24	2577	1459	2015-01-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/ConnectionState.java	7	7	2791	1459	2014-06-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java	93	15	2791	1459	2014-06-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/KafkaClient.java	28	21	2791	1459	2014-06-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java	47	6	2343	1459	2015-09-02	2018-02-02
clients/src/main/java/org/apache/kafka/clients/Metadata.java	214	28	2554	1459	2015-02-03	2018-02-02
clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java	15	7	2343	1459	2015-09-02	2018-02-02
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java	690	75	2791	1459	2014-06-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/NetworkClientUtils.java	50	4	1764	1459	2017-04-03	2018-02-02
clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java	124	11	1846	1459	2017-01-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/RequestCompletionHandler.java	4	2	2577	1798	2015-01-11	2017-02-28
clients/src/main/java/org/apache/kafka/clients/admin/AbstractOptions.java	12	4	1611	1459	2017-09-03	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java	90	17	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java	127	9	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java	18	6	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsResult.java	18	4	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsOptions.java	6	2	1581	1459	2017-10-03	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsResult.java	18	2	1581	1459	2017-10-03	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/Config.java	37	3	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java	139	6	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsOptions.java	10	5	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsResult.java	19	4	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsOptions.java	16	2	1593	1459	2017-09-21	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsResult.java	17	2	1593	1459	2017-09-21	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java	18	6	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsResult.java	18	4	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsOptions.java	10	5	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsResult.java	68	5	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsOptions.java	6	2	1537	1459	2017-11-16	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsResult.java	18	3	1537	1459	2017-11-16	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java	10	5	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsResult.java	18	4	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DeletedRecords.java	12	2	1537	1459	2017-11-16	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsOptions.java	10	5	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsResult.java	16	4	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java	9	5	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java	27	3	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsOptions.java	18	6	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsResult.java	35	5	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsOptions.java	6	3	1611	1459	2017-09-03	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java	35	4	1611	1459	2017-09-03	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsOptions.java	6	3	1581	1459	2017-10-03	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsResult.java	82	3	1581	1459	2017-10-03	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsOptions.java	10	5	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java	34	5	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java	1534	34	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsOptions.java	17	6	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsResult.java	32	5	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitions.java	29	2	1593	1459	2017-09-21	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/NewTopic.java	70	6	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/RecordsToDelete.java	31	3	1537	1459	2017-11-16	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/TopicDescription.java	44	7	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/admin/TopicListing.java	19	5	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/CommitFailedException.java	13	4	2276	1798	2015-11-08	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java	45	23	2813	1459	2014-05-20	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java	343	53	2813	1459	2014-05-20	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerInterceptor.java	9	4	2182	1798	2016-02-10	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java	7	9	2349	1459	2015-08-27	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java	113	15	2813	1459	2014-05-20	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java	76	12	2813	1798	2014-05-20	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/InvalidOffsetException.java	10	2	2276	1798	2015-11-08	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java	693	158	2813	1459	2014-05-20	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java	343	37	2813	1459	2014-05-20	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java	25	5	2577	1459	2015-01-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndMetadata.java	44	6	2322	1459	2015-09-23	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndTimestamp.java	33	4	1950	1798	2016-09-29	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetCommitCallback.java	7	7	2334	1459	2015-09-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java	19	2	2276	1798	2015-11-08	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java	4	2	2414	1798	2015-06-23	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java	48	6	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/RetriableCommitFailedException.java	20	6	2097	1459	2016-05-05	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java	45	7	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/StickyAssignor.java	579	6	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java	711	55	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java	56	6	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java	673	60	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptors.java	47	2	2182	1798	2016-02-10	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetrics.java	27	2	1711	1459	2017-05-26	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java	384	42	2392	1459	2015-07-15	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java	96	7	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java	1034	104	2519	1459	2015-03-10	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetcherMetricsRegistry.java	133	4	1711	1459	2017-05-26	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java	68	8	2577	1798	2015-01-11	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java	5	2	2392	1798	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoOpConsumerRebalanceListener.java	10	3	2349	1798	2015-08-27	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java	59	6	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java	141	11	2414	1459	2015-06-23	2018-02-02
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureAdapter.java	7	2	2392	1798	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureListener.java	5	2	2392	1798	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StaleMetadataException.java	5	2	2392	1798	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java	329	36	2577	1459	2015-01-11	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/BufferExhaustedException.java	8	5	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/Callback.java	4	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java	612	123	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java	318	28	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java	8	3	2440	1798	2015-05-28	2017-02-28
clients/src/main/java/org/apache/kafka/clients/producer/Producer.java	27	12	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java	281	67	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/ProducerInterceptor.java	7	4	2182	1798	2016-02-10	2017-02-28
clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java	101	16	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java	63	13	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java	189	21	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java	43	5	2440	1794	2015-05-28	2017-03-04
clients/src/main/java/org/apache/kafka/clients/producer/internals/ErrorLoggingCallback.java	33	6	2881	1778	2014-03-13	2017-03-20
clients/src/main/java/org/apache/kafka/clients/producer/internals/FutureRecordMetadata.java	80	12	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/IncompleteBatches.java	32	2	1690	1459	2017-06-16	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java	50	6	2915	1774	2014-02-07	2017-03-24
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java	316	22	1791	1459	2017-03-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerIdAndEpoch.java	19	4	1724	1459	2017-05-13	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerInterceptors.java	68	6	2182	1459	2016-02-10	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetrics.java	28	3	1608	1459	2017-09-06	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java	476	69	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java	629	90	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/SenderMetricsRegistry.java	169	5	1608	1459	2017-09-06	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java	986	29	1740	1459	2017-04-27	2018-02-02
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java	44	4	1740	1459	2017-04-27	2018-02-02
clients/src/main/java/org/apache/kafka/common/Cluster.java	163	24	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/ClusterResource.java	14	2	1962	1798	2016-09-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/ClusterResourceListener.java	4	2	1962	1798	2016-09-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/Configurable.java	5	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/KafkaException.java	16	3	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/KafkaFuture.java	74	6	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/common/Metric.java	7	7	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/MetricName.java	71	8	2575	1459	2015-01-13	2018-02-02
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java	56	3	1711	1459	2017-05-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/Node.java	83	10	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/PartitionInfo.java	58	11	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/Reconfigurable.java	8	2	1469	1459	2018-01-23	2018-02-02
clients/src/main/java/org/apache/kafka/common/TopicPartition.java	50	6	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/TopicPartitionInfo.java	50	5	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/TopicPartitionReplica.java	61	2	1611	1459	2017-09-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntry.java	51	4	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryData.java	65	3	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryFilter.java	64	4	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/acl/AclBinding.java	42	5	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/acl/AclBindingFilter.java	55	5	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/acl/AclOperation.java	50	5	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/acl/AclPermissionType.java	41	4	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/annotation/InterfaceStability.java	16	4	2364	1459	2015-08-12	2018-02-02
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java	259	39	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/config/Config.java	11	3	2146	1798	2016-03-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java	801	45	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/config/ConfigException.java	14	3	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java	43	4	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/config/ConfigValue.java	79	5	2146	1798	2016-03-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/config/SaslConfigs.java	50	11	2295	1459	2015-10-20	2018-02-02
clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java	86	13	2291	1459	2015-10-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java	119	6	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java	39	2	1600	1459	2017-09-14	2018-02-02
clients/src/main/java/org/apache/kafka/common/config/types/Password.java	26	2	2272	1798	2015-11-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/ApiException.java	21	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/AuthenticationException.java	11	5	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/AuthorizationException.java	9	4	2286	1798	2015-10-29	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/BrokerNotAvailableException.java	10	2	2343	1798	2015-09-02	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/ClusterAuthorizationException.java	10	2	2216	1798	2016-01-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/ConcurrentTransactionsException.java	7	2	1741	1459	2017-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/ControllerMovedException.java	10	2	2343	1798	2015-09-02	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/CoordinatorLoadInProgressException.java	10	2	1756	1459	2017-04-11	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/CoordinatorNotAvailableException.java	14	2	1756	1459	2017-04-11	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java	16	8	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenAuthorizationException.java	10	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenDisabledException.java	10	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenExpiredException.java	10	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenNotFoundException.java	10	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenOwnerMismatchException.java	10	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/DisconnectException.java	17	3	2392	1798	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/DuplicateSequenceException.java	6	2	1600	1459	2017-09-14	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/GroupAuthorizationException.java	11	2	2280	1798	2015-11-04	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.java	18	5	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/GroupIdNotFoundException.java	11	2	1461	1459	2018-01-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/GroupLoadInProgressException.java	17	5	2281	1459	2015-11-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/GroupNotEmptyException.java	11	2	1461	1459	2018-01-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/IllegalGenerationException.java	16	3	2392	1798	2015-07-15	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/IllegalSaslStateException.java	10	4	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/InconsistentGroupProtocolException.java	10	2	2205	1798	2016-01-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InterruptException.java	17	3	2550	1798	2015-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidCommitOffsetSizeException.java	10	2	2205	1798	2016-01-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidConfigurationException.java	10	2	2029	1798	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidFetchSizeException.java	10	2	2216	1798	2016-01-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidGroupIdException.java	10	2	2205	1798	2016-01-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidMetadataException.java	16	3	2909	1798	2014-02-13	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidOffsetException.java	10	2	2216	1798	2016-01-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidPartitionsException.java	10	2	2029	1798	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidPidMappingException.java	6	2	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/InvalidPrincipalTypeException.java	10	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/InvalidReplicaAssignmentException.java	10	2	2029	1798	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidReplicationFactorException.java	10	2	2029	1798	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequestException.java	10	2	2029	1798	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequiredAcksException.java	7	2	2544	1798	2015-02-13	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidSessionTimeoutException.java	10	2	2205	1798	2016-01-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidTimestampException.java	10	2	2173	1798	2016-02-19	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/InvalidTopicException.java	16	4	2726	1459	2014-08-15	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnStateException.java	6	2	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnTimeoutException.java	10	4	1756	1459	2017-04-11	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/KafkaStorageException.java	16	3	1654	1459	2017-07-22	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/LeaderNotAvailableException.java	10	5	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/LogDirNotFoundException.java	13	2	1611	1459	2017-09-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/NetworkException.java	16	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/NotControllerException.java	10	2	2029	1798	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/NotCoordinatorException.java	10	2	1756	1459	2017-04-11	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/NotCoordinatorForGroupException.java	17	4	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.java	7	4	2670	1798	2014-10-10	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/NotEnoughReplicasException.java	16	3	2670	1798	2014-10-10	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderForPartitionException.java	16	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/OffsetMetadataTooLarge.java	15	5	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/OffsetOutOfRangeException.java	10	6	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/OperationNotAttemptedException.java	6	2	1704	1459	2017-06-02	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/OutOfOrderSequenceException.java	6	3	1764	1459	2017-04-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/PolicyViolationException.java	9	3	1843	1798	2017-01-14	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/ProducerFencedException.java	6	3	1764	1459	2017-04-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/ReassignmentInProgressException.java	9	2	1593	1459	2017-09-21	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/RebalanceInProgressException.java	16	2	2288	1798	2015-10-27	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/RecordBatchTooLargeException.java	16	2	2671	1798	2014-10-09	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/RecordTooLargeException.java	26	5	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/ReplicaNotAvailableException.java	13	2	2216	1798	2016-01-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/RetriableException.java	15	3	2909	1798	2014-02-13	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/SaslAuthenticationException.java	11	3	1593	1459	2017-09-21	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/SecurityDisabledException.java	10	2	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/SerializationException.java	21	2	2601	1798	2014-12-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/SslAuthenticationException.java	11	2	1592	1459	2017-09-22	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/TimeoutException.java	16	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/TopicAuthorizationException.java	16	2	2280	1798	2015-11-04	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/TopicExistsException.java	10	2	2029	1798	2016-07-12	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/TransactionCoordinatorFencedException.java	10	2	1731	1459	2017-05-06	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/TransactionalIdAuthorizationException.java	6	3	1721	1459	2017-05-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/UnknownMemberIdException.java	16	2	2294	1798	2015-10-21	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/UnknownProducerIdException.java	6	2	1593	1459	2017-09-21	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/UnknownServerException.java	15	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java	15	7	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedByAuthenticationException.java	10	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedForMessageFormatException.java	10	4	1950	1459	2016-09-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedSaslMechanismException.java	10	4	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedVersionException.java	11	4	2105	1459	2016-04-27	2018-02-02
clients/src/main/java/org/apache/kafka/common/errors/WakeupException.java	5	2	2287	1798	2015-10-28	2017-02-28
clients/src/main/java/org/apache/kafka/common/header/Header.java	5	2	1738	1459	2017-04-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/header/Headers.java	9	2	1738	1459	2017-04-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java	51	2	1738	1459	2017-04-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java	158	4	1738	1459	2017-04-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/internals/ClusterResourceListeners.java	26	2	1962	1798	2016-09-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/internals/FatalExitError.java	17	4	1824	1459	2017-02-02	2018-02-02
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java	211	6	1736	1459	2017-05-01	2018-02-02
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java	104	2	1961	1798	2016-09-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/internals/Topic.java	44	4	1781	1459	2017-03-17	2018-02-02
clients/src/main/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPool.java	110	2	1650	1459	2017-07-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/memory/MemoryPool.java	34	2	1650	1459	2017-07-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/memory/SimpleMemoryPool.java	92	2	1650	1459	2017-07-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/CompoundStat.java	21	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/Gauge.java	4	2	1586	1459	2017-09-28	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java	197	16	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java	64	12	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/Measurable.java	4	7	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/MeasurableStat.java	3	3	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/MetricConfig.java	65	7	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/MetricValueProvider.java	2	2	1586	1459	2017-09-28	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java	309	22	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java	9	6	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/Quota.java	45	7	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/QuotaViolationException.java	28	5	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java	166	18	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/Stat.java	4	5	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/Avg.java	22	7	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/Count.java	19	6	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequencies.java	112	3	1587	1459	2017-09-27	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequency.java	16	2	1587	1459	2017-09-27	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/stats/Histogram.java	132	7	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/stats/Max.java	19	6	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/Meter.java	40	2	1600	1459	2017-09-14	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/stats/Min.java	19	7	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentile.java	17	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentiles.java	92	12	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java	80	12	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java	87	8	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/SimpleRate.java	10	2	1963	1798	2016-09-16	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/Sum.java	19	2	1704	1459	2017-06-02	2018-02-02
clients/src/main/java/org/apache/kafka/common/metrics/stats/Total.java	20	5	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/metrics/stats/Value.java	14	2	1844	1798	2017-01-13	2017-02-28
clients/src/main/java/org/apache/kafka/common/network/Authenticator.java	10	9	2357	1459	2015-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java	40	11	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilder.java	10	8	2357	1459	2015-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java	125	14	2343	1459	2015-09-02	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/ChannelState.java	34	4	1722	1459	2017-05-15	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/InvalidReceiveException.java	10	2	2433	1798	2015-06-04	2017-02-28
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java	176	18	2357	1459	2015-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/ListenerName.java	39	6	1844	1459	2017-01-13	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/ListenerReconfigurable.java	5	2	1469	1459	2018-01-23	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/Mode.java	2	4	2295	1798	2015-10-20	2017-02-28
clients/src/main/java/org/apache/kafka/common/network/MultiSend.java	63	4	2433	1798	2015-06-04	2017-02-28
clients/src/main/java/org/apache/kafka/common/network/NetworkReceive.java	115	10	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java	16	6	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java	59	11	2357	1459	2015-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java	107	11	2357	1459	2015-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/Receive.java	11	7	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java	180	26	2295	1459	2015-10-20	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/Selectable.java	23	14	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/Selector.java	739	63	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/Send.java	9	9	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java	104	12	2291	1459	2015-10-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java	546	16	2291	1459	2015-10-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/TransportLayer.java	25	11	2357	1459	2015-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/network/TransportLayers.java	10	2	1853	1798	2017-01-04	2017-02-28
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java	300	37	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/protocol/CommonFields.java	31	5	1595	1459	2017-09-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java	678	64	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java	144	62	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java	76	7	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/protocol/types/BoundField.java	15	2	1595	1459	2017-09-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/protocol/types/Field.java	62	9	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/protocol/types/Schema.java	123	11	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/protocol/types/SchemaException.java	8	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java	293	25	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java	424	13	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java	450	12	1774	1459	2017-03-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/AbstractRecordBatch.java	15	3	1774	1459	2017-03-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/AbstractRecords.java	168	13	1875	1459	2016-12-13	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/BufferSupplier.java	49	2	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/ByteBufferLogInputStream.java	38	5	1875	1774	2016-12-13	2017-03-24
clients/src/main/java/org/apache/kafka/common/record/CompressionRatioEstimator.java	58	2	1715	1459	2017-05-22	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/CompressionType.java	128	15	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java	57	5	1774	1459	2017-03-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/ConvertedRecords.java	15	2	1586	1459	2017-09-28	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java	363	14	1774	1459	2017-03-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java	483	19	1774	1459	2017-03-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/EndTransactionMarker.java	82	2	1731	1459	2017-05-06	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java	178	9	1875	1459	2016-12-13	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java	303	19	1903	1459	2016-11-15	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/InvalidRecordException.java	11	7	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java	192	8	2554	1459	2015-02-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java	260	10	2554	1459	2015-02-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/LegacyRecord.java	337	5	1774	1459	2017-03-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java	5	4	1903	1774	2016-11-15	2017-03-24
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java	468	47	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java	455	34	1875	1459	2016-12-13	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/MutableRecordBatch.java	8	5	1774	1459	2017-03-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/Record.java	23	23	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/RecordBatch.java	38	9	1774	1459	2017-03-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/RecordBatchIterator.java	21	1	1774	1774	2017-03-24	2017-03-24
clients/src/main/java/org/apache/kafka/common/record/Records.java	21	14	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/RecordsProcessingStats.java	26	3	1586	1459	2017-09-28	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java	79	4	1774	1459	2017-03-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/record/TimestampType.java	21	6	2173	1774	2016-02-19	2017-03-24
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java	164	39	2501	1459	2015-03-28	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java	12	4	2754	1798	2014-07-18	2017-02-28
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java	136	24	1903	1459	2016-11-15	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnRequest.java	97	9	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java	54	10	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java	134	9	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java	93	10	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsRequest.java	152	3	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java	80	5	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequest.java	121	2	1581	1459	2017-10-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java	88	2	1581	1459	2017-10-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ApiError.java	56	4	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsRequest.java	64	12	2105	1459	2016-04-27	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java	145	16	2105	1459	2016-04-27	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/BasePartitionState.java	18	2	1650	1459	2017-07-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownRequest.java	72	15	2343	1459	2015-09-02	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownResponse.java	75	12	2343	1459	2015-09-02	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java	115	5	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java	83	6	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenRequest.java	100	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java	129	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsRequest.java	172	3	1593	1459	2017-09-21	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsResponse.java	77	3	1593	1459	2017-09-21	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java	263	13	2029	1459	2016-07-12	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java	83	14	2029	1459	2016-07-12	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java	100	5	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java	158	7	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsRequest.java	80	2	1461	1459	2018-01-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java	81	2	1461	1459	2018-01-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java	127	6	1770	1459	2017-03-28	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java	118	7	1770	1459	2017-03-28	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsRequest.java	96	9	1998	1459	2016-08-12	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsResponse.java	78	11	1998	1459	2016-08-12	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsRequest.java	79	5	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java	114	7	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsRequest.java	133	4	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java	283	6	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenRequest.java	91	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java	139	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsRequest.java	73	10	2281	1459	2015-11-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java	221	14	2281	1459	2015-11-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsRequest.java	114	3	1611	1459	2017-09-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java	170	6	1611	1459	2017-09-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/EndTxnRequest.java	99	9	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java	54	9	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/EpochEndOffset.java	47	3	1761	1459	2017-04-06	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenRequest.java	74	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java	61	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java	300	29	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java	345	28	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorRequest.java	126	6	1756	1459	2017-04-11	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java	97	8	1756	1459	2017-04-11	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java	92	17	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java	52	19	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRequest.java	76	4	1724	1459	2017-05-13	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java	78	8	1724	1459	2017-05-13	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/IsolationLevel.java	21	1	1774	1774	2017-03-24	2017-03-24
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java	212	21	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java	157	24	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java	241	21	2343	1459	2015-09-02	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java	79	11	2343	1459	2015-09-02	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java	80	13	2298	1459	2015-10-17	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupResponse.java	52	14	2298	1459	2015-10-17	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsRequest.java	53	11	2281	1459	2015-11-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java	99	14	2281	1459	2015-11-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java	281	24	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java	180	20	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java	148	24	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java	402	32	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java	264	21	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java	97	23	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java	168	20	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java	155	27	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java	118	6	1761	1459	2017-04-06	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java	91	5	1761	1459	2017-04-06	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java	289	31	2791	1459	2014-06-11	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java	179	29	2889	1459	2014-03-05	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/RecordsSend.java	46	3	1903	1798	2016-11-15	2017-02-28
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenRequest.java	74	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java	61	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/RequestAndSize.java	9	2	1809	1798	2017-02-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java	64	5	1620	1459	2017-08-25	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/RequestHeader.java	118	14	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/RequestUtils.java	67	5	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/Resource.java	34	2	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ResourceType.java	19	2	1719	1459	2017-05-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/ResponseHeader.java	33	9	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateRequest.java	68	3	1599	1459	2017-09-15	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateResponse.java	62	5	1599	1459	2017-09-15	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeRequest.java	75	11	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeResponse.java	58	9	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaRequest.java	139	14	2350	1459	2015-08-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaResponse.java	78	12	2350	1459	2015-08-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupRequest.java	137	11	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java	64	15	2294	1459	2015-10-21	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/TransactionResult.java	14	2	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java	191	10	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java	99	9	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataRequest.java	373	22	2343	1459	2015-09-02	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataResponse.java	42	10	2343	1459	2015-09-02	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersRequest.java	197	7	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java	111	7	1760	1459	2017-04-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/resource/Resource.java	43	5	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/resource/ResourceFilter.java	57	5	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/resource/ResourceType.java	44	6	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java	81	5	1864	1459	2016-12-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/JaasContext.java	125	2	1830	1798	2017-01-27	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java	31	15	2297	1459	2015-10-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/auth/AuthenticationContext.java	6	3	1600	1459	2017-09-14	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/auth/DefaultPrincipalBuilder.java	18	5	2357	1459	2015-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipal.java	52	7	2357	1459	2015-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipalBuilder.java	4	2	1600	1459	2017-09-14	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/auth/PlaintextAuthenticationContext.java	16	3	1600	1459	2017-09-14	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/auth/PrincipalBuilder.java	15	6	2357	1459	2015-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/auth/SaslAuthenticationContext.java	24	3	1600	1459	2017-09-14	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/auth/SecurityProtocol.java	41	2	1580	1459	2017-10-04	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/auth/SslAuthenticationContext.java	22	3	1600	1459	2017-09-14	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/authenticator/AbstractLogin.java	57	6	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/authenticator/AuthCallbackHandler.java	9	2	1580	1459	2017-10-04	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/authenticator/CredentialCache.java	42	2	1847	1798	2017-01-10	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultKafkaPrincipalBuilder.java	100	4	1600	1459	2017-09-14	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultLogin.java	10	2	2106	1798	2016-04-26	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/authenticator/Login.java	13	2	1580	1459	2017-10-04	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java	90	8	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java	353	19	2295	1459	2015-10-20	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientCallbackHandler.java	68	6	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java	399	29	2295	1459	2015-10-20	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerCallbackHandler.java	50	9	2295	1459	2015-10-20	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/kerberos/BadFormatString.java	10	2	2285	1798	2015-10-30	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java	285	15	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosName.java	51	4	2295	1798	2015-10-20	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosRule.java	133	5	2295	1459	2015-10-20	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosShortNamer.java	62	5	2285	1459	2015-10-30	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/kerberos/NoMatchingRule.java	7	2	2295	1798	2015-10-20	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/plain/PlainLoginModule.java	38	2	2106	1798	2016-04-26	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/plain/PlainSaslServer.java	107	9	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/plain/PlainSaslServerProvider.java	15	4	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/scram/DelegationTokenAuthenticationCallback.java	11	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredential.java	25	2	1847	1798	2017-01-10	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredentialCallback.java	30	4	1847	1459	2017-01-10	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredentialUtils.java	52	5	1847	1459	2017-01-10	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/scram/ScramFormatter.java	121	2	1847	1798	2017-01-10	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/scram/ScramLoginModule.java	42	4	1847	1459	2017-01-10	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/scram/ScramMechanism.java	47	2	1847	1798	2017-01-10	2017-02-28
clients/src/main/java/org/apache/kafka/common/security/scram/ScramMessages.java	227	5	1847	1459	2017-01-10	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/scram/ScramSaslClient.java	186	4	1847	1459	2017-01-10	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/scram/ScramSaslClientProvider.java	16	4	1847	1459	2017-01-10	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/scram/ScramSaslServer.java	184	6	1847	1459	2017-01-10	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/scram/ScramSaslServerProvider.java	16	4	1847	1459	2017-01-10	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/scram/ScramServerCallbackHandler.java	43	6	1847	1459	2017-01-10	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java	379	14	2291	1459	2015-10-24	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/token/delegation/DelegationToken.java	51	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/token/delegation/DelegationTokenCache.java	71	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/security/token/delegation/TokenInformation.java	100	2	1476	1459	2018-01-16	2018-02-02
clients/src/main/java/org/apache/kafka/common/serialization/ByteArrayDeserializer.java	14	2	2582	1798	2015-01-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/ByteArraySerializer.java	14	2	2582	1798	2015-01-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/ByteBufferDeserializer.java	14	2	2169	1798	2016-02-23	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/ByteBufferSerializer.java	24	2	2169	1798	2016-02-23	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/BytesDeserializer.java	14	2	2106	1798	2016-04-26	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/BytesSerializer.java	14	2	2106	1798	2016-04-26	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java	9	10	2582	1459	2015-01-06	2018-02-02
clients/src/main/java/org/apache/kafka/common/serialization/DoubleDeserializer.java	25	2	2146	1798	2016-03-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/DoubleSerializer.java	26	2	2146	1798	2016-03-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/ExtendedDeserializer.java	31	4	1738	1459	2017-04-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/serialization/ExtendedSerializer.java	31	4	1738	1459	2017-04-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/serialization/FloatDeserializer.java	25	1	1785	1785	2017-03-13	2017-03-13
clients/src/main/java/org/apache/kafka/common/serialization/FloatSerializer.java	22	1	1785	1785	2017-03-13	2017-03-13
clients/src/main/java/org/apache/kafka/common/serialization/IntegerDeserializer.java	22	4	2479	1459	2015-04-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/serialization/IntegerSerializer.java	18	2	2479	1798	2015-04-19	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/LongDeserializer.java	22	4	2319	1459	2015-09-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/serialization/LongSerializer.java	22	2	2319	1798	2015-09-26	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/Serde.java	10	3	2146	1798	2016-03-17	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java	145	9	2146	1459	2016-03-17	2018-02-02
clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java	9	9	2582	1459	2015-01-06	2018-02-02
clients/src/main/java/org/apache/kafka/common/serialization/ShortDeserializer.java	22	2	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/serialization/ShortSerializer.java	16	2	1706	1459	2017-05-31	2018-02-02
clients/src/main/java/org/apache/kafka/common/serialization/StringDeserializer.java	30	3	2582	1798	2015-01-06	2017-02-28
clients/src/main/java/org/apache/kafka/common/serialization/StringSerializer.java	30	5	2582	1459	2015-01-06	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/AbstractIterator.java	56	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/utils/AppInfoParser.java	98	9	2356	1459	2015-08-20	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/Base64.java	231	3	1626	1459	2017-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java	23	1	1790	1790	2017-03-08	2017-03-08
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferOutputStream.java	65	5	1790	1459	2017-03-08	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java	158	3	1790	1459	2017-03-08	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/Bytes.java	97	7	2106	1459	2016-04-26	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/Checksums.java	35	2	1769	1459	2017-03-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/CircularIterator.java	30	2	2292	1798	2015-10-23	2017-02-28
clients/src/main/java/org/apache/kafka/common/utils/CloseableIterator.java	6	2	1768	1459	2017-03-30	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/CollectionUtils.java	36	5	2754	1459	2014-07-18	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/CopyOnWriteMap.java	105	4	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/utils/Crc32.java	313	10	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/Crc32C.java	57	3	1769	1459	2017-03-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/Exit.java	44	2	1824	1798	2017-02-02	2017-02-28
clients/src/main/java/org/apache/kafka/common/utils/Java.java	40	5	1769	1459	2017-03-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/KafkaThread.java	28	7	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/LogContext.java	631	4	1626	1459	2017-08-19	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/MappedByteBuffers.java	87	2	1592	1459	2017-09-22	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/OperatingSystem.java	12	2	1745	1459	2017-04-22	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java	581	2	1769	1459	2017-03-29	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/Sanitizer.java	41	4	1573	1459	2017-10-11	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/Scheduler.java	10	2	1550	1459	2017-11-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/SecurityUtils.java	14	2	1600	1459	2017-09-14	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/Shell.java	168	6	2295	1459	2015-10-20	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/SystemScheduler.java	18	2	1550	1459	2017-11-03	2018-02-02
clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java	24	7	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/utils/Time.java	8	5	2915	1798	2014-02-07	2017-02-28
clients/src/main/java/org/apache/kafka/common/utils/Utils.java	493	60	2915	1459	2014-02-07	2018-02-02
clients/src/main/java/org/apache/kafka/server/policy/AlterConfigPolicy.java	27	2	1703	1459	2017-06-03	2018-02-02
clients/src/main/java/org/apache/kafka/server/policy/CreateTopicPolicy.java	47	5	1843	1459	2017-01-14	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java	113	8	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java	30	4	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectorContext.java	5	4	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/connector/Task.java	7	3	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java	231	12	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/data/Date.java	32	4	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/data/Decimal.java	35	3	2275	1777	2015-11-09	2017-03-21
connect/api/src/main/java/org/apache/kafka/connect/data/Field.java	34	2	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/data/Schema.java	72	4	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaAndValue.java	36	2	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaBuilder.java	210	11	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaProjector.java	150	3	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/data/Struct.java	136	8	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/data/Time.java	33	4	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/data/Timestamp.java	21	5	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/data/Values.java	824	2	1461	1459	2018-01-31	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java	12	2	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/ConnectException.java	13	3	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/DataException.java	12	2	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/IllegalWorkerStateException.java	12	2	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java	12	2	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/RetriableException.java	12	2	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/SchemaBuilderException.java	12	2	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/errors/SchemaProjectorException.java	12	2	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeader.java	64	2	1461	1459	2018-01-31	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java	419	2	1461	1459	2018-01-31	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/header/Header.java	9	2	1461	1459	2018-01-31	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/header/Headers.java	44	2	1461	1459	2018-01-31	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java	5	3	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java	64	7	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java	36	8	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java	13	4	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java	4	3	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java	86	8	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java	18	8	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java	5	3	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java	9	4	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/storage/ConverterConfig.java	22	2	1461	1459	2018-01-31	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/storage/ConverterType.java	32	2	1461	1459	2018-01-31	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/storage/HeaderConverter.java	12	2	1461	1459	2018-01-31	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReader.java	7	3	2275	1798	2015-11-09	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/storage/SimpleHeaderConverter.java	54	2	1461	1459	2018-01-31	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverter.java	65	4	2275	1459	2015-11-09	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverterConfig.java	27	2	1461	1459	2018-01-31	2018-02-02
connect/api/src/main/java/org/apache/kafka/connect/transforms/Transformation.java	11	2	1844	1798	2017-01-13	2017-02-28
connect/api/src/main/java/org/apache/kafka/connect/util/ConnectorUtils.java	23	3	2275	1798	2015-11-09	2017-02-28
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkConnector.java	47	5	2275	1459	2015-11-09	2018-02-02
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkTask.java	64	4	2275	1778	2015-11-09	2017-03-20
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java	67	6	2275	1459	2015-11-09	2018-02-02
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java	187	9	2275	1459	2015-11-09	2018-02-02
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java	641	14	2275	1459	2015-11-09	2018-02-02
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java	39	2	1461	1459	2018-01-31	2018-02-02
connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java	29	2	2275	1798	2015-11-09	2017-02-28
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSchema.java	58	2	2275	1798	2015-11-09	2017-02-28
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java	27	2	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java	65	14	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java	76	13	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/converters/ByteArrayConverter.java	45	3	1783	1459	2017-03-15	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java	310	24	2168	1459	2016-02-24	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractStatus.java	70	3	2168	1798	2016-02-24	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java	63	5	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java	216	7	1592	1459	2017-09-22	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java	290	3	1580	1459	2017-10-04	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java	183	14	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorStatus.java	17	3	2168	1798	2016-02-24	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java	59	10	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderConnectorContext.java	18	4	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java	27	6	2093	1459	2016-05-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java	13	6	2093	1459	2016-05-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java	74	6	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/StateTracker.java	96	3	1587	1459	2017-09-27	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TargetState.java	5	2	2112	1798	2016-04-20	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java	23	3	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskStatus.java	17	3	2168	1798	2016-02-24	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java	39	2	1844	1798	2017-01-13	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java	500	29	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java	200	14	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java	245	11	2112	1459	2016-04-20	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerInfo.java	63	2	1586	1459	2017-09-28	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java	641	32	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTaskContext.java	90	4	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java	442	28	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTaskContext.java	13	2	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java	287	17	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java	95	5	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java	204	3	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java	192	13	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java	987	33	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/NotAssignedException.java	6	2	2114	1798	2016-04-18	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/NotLeaderException.java	6	3	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/RebalanceNeededException.java	7	2	2112	1798	2016-04-20	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/RequestTargetException.java	20	2	2114	1798	2016-04-18	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java	291	15	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java	154	24	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerRebalanceListener.java	7	3	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java	286	4	1719	1459	2017-05-18	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java	50	4	1719	1459	2017-05-18	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginDesc.java	80	3	1719	1459	2017-05-18	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanResult.java	31	2	1719	1459	2017-05-18	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginType.java	34	2	1719	1459	2017-05-18	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java	251	6	1719	1459	2017-05-18	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java	193	4	1719	1459	2017-05-18	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java	106	2	1462	1459	2018-01-30	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java	202	12	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigInfo.java	39	2	2146	1798	2016-03-17	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigInfos.java	69	2	2146	1798	2016-03-17	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigKeyInfo.java	135	3	2146	1798	2016-03-17	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigValueInfo.java	76	3	2146	1798	2016-03-17	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorInfo.java	52	6	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorPluginInfo.java	62	5	2138	1459	2016-03-25	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorStateInfo.java	94	5	2168	1459	2016-02-24	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorType.java	28	2	1725	1459	2017-05-12	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequest.java	34	2	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ErrorMessage.java	33	3	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ServerInfo.java	25	4	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/TaskInfo.java	33	2	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/errors/BadRequestException.java	7	2	1905	1798	2016-11-13	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/errors/ConnectExceptionMapper.java	49	4	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/errors/ConnectRestException.java	39	2	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java	79	8	2146	1459	2016-03-17	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java	247	17	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/RootResource.java	20	4	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/util/SSLUtils.java	86	2	1462	1459	2018-01-30	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneConfig.java	19	4	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java	261	17	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConfigBackingStore.java	28	4	2112	1798	2016-04-20	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/storage/FileOffsetBackingStore.java	72	7	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java	417	9	2112	1459	2016-04-20	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java	176	8	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java	382	9	2168	1459	2016-02-24	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java	117	4	2112	1798	2016-04-20	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryOffsetBackingStore.java	80	5	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java	69	3	2168	1798	2016-02-24	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetBackingStore.java	17	4	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReaderImpl.java	74	5	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java	101	6	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetUtils.java	31	4	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/storage/StatusBackingStore.java	21	4	2168	1798	2016-02-24	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockConnector.java	71	3	2048	1798	2016-06-23	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkConnector.java	51	2	2048	1798	2016-06-23	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkTask.java	53	3	2048	1798	2016-06-23	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceConnector.java	51	2	2048	1798	2016-06-23	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceTask.java	45	3	2048	1798	2016-06-23	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceConnector.java	41	2	2033	1798	2016-07-08	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java	136	5	2033	1459	2016-07-08	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/tools/TransformationDoc.java	61	5	1836	1459	2017-01-21	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkConnector.java	41	3	2272	1798	2015-11-12	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkTask.java	74	2	2272	1798	2015-11-12	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceConnector.java	41	3	2272	1798	2015-11-12	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java	102	5	2272	1459	2015-11-12	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/util/Callback.java	4	2	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectUtils.java	43	5	1813	1459	2017-02-13	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java	51	4	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConvertingFutureCallback.java	55	2	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/FutureCallback.java	13	2	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java	211	10	2275	1459	2015-11-09	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/util/ReflectionsUtil.java	57	2	2104	1798	2016-04-28	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/SafeObjectInputStream.java	43	2	1655	1459	2017-07-21	2018-02-02
connect/runtime/src/main/java/org/apache/kafka/connect/util/ShutdownableThread.java	58	2	2275	1798	2015-11-09	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/SinkUtils.java	7	2	1905	1798	2016-11-13	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/Table.java	39	2	2168	1798	2016-02-24	2017-02-28
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java	145	5	1719	1459	2017-05-18	2018-02-02
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java	339	3	1720	1459	2017-05-17	2018-02-02
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java	75	5	1836	1459	2017-01-21	2018-02-02
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java	208	2	1720	1459	2017-05-17	2018-02-02
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java	85	3	1836	1776	2017-01-21	2017-03-22
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java	209	4	1844	1776	2017-01-13	2017-03-22
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java	127	3	1836	1776	2017-01-21	2017-03-22
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/RegexRouter.java	46	2	1836	1798	2017-01-21	2017-02-28
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java	170	3	1836	1776	2017-01-21	2017-03-22
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java	96	5	1836	1459	2017-01-21	2018-02-02
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java	348	3	1718	1459	2017-05-19	2018-02-02
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java	64	3	1844	1798	2017-01-13	2017-02-28
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ValueToKey.java	74	2	1836	1798	2017-01-21	2017-02-28
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidator.java	16	4	1836	1459	2017-01-21	2018-02-02
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/RegexValidator.java	18	2	1836	1798	2017-01-21	2017-02-28
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/Requirements.java	48	6	1836	1459	2017-01-21	2018-02-02
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java	19	4	1836	1459	2017-01-21	2018-02-02
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SimpleConfig.java	9	2	1844	1798	2017-01-13	2017-02-28
core/src/main/scala/kafka/Kafka.scala	67	29	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/admin/AclCommand.scala	289	28	2313	1459	2015-10-02	2018-02-02
core/src/main/scala/kafka/admin/AdminClient.scala	439	44	2281	1459	2015-11-03	2018-02-02
core/src/main/scala/kafka/admin/AdminOperationException.scala	5	1	3251	3251	2013-03-08	2013-03-08
core/src/main/scala/kafka/admin/AdminUtils.scala	453	96	3671	1459	2012-01-13	2018-02-02
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala	52	6	1839	1459	2017-01-18	2018-02-02
core/src/main/scala/kafka/admin/BrokerMetadata.scala	2	1	2148	2148	2016-03-15	2016-03-15
core/src/main/scala/kafka/admin/ConfigCommand.scala	259	29	2372	1459	2015-08-04	2018-02-02
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala	892	50	2547	1459	2015-02-10	2018-02-02
core/src/main/scala/kafka/admin/DelegationTokenCommand.scala	158	2	1476	1459	2018-01-16	2018-02-02
core/src/main/scala/kafka/admin/DeleteRecordsCommand.scala	76	5	1770	1459	2017-03-28	2018-02-02
core/src/main/scala/kafka/admin/LogDirsCommand.scala	82	3	1611	1459	2017-09-03	2018-02-02
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala	100	30	3397	1459	2012-10-13	2018-02-02
core/src/main/scala/kafka/admin/RackAwareMode.scala	7	1	2148	2148	2016-03-15	2016-03-15
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala	529	54	3400	1459	2012-10-10	2018-02-02
core/src/main/scala/kafka/admin/TopicCommand.scala	339	69	3251	1459	2013-03-08	2018-02-02
core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala	180	13	2292	1459	2015-10-23	2018-02-02
core/src/main/scala/kafka/api/ApiUtils.scala	51	8	3397	1853	2012-10-13	2017-01-04
core/src/main/scala/kafka/api/ApiVersion.scala	118	21	2492	1459	2015-04-06	2018-02-02
core/src/main/scala/kafka/api/FetchRequest.scala	213	62	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/api/FetchResponse.scala	115	40	3640	1459	2012-02-13	2018-02-02
core/src/main/scala/kafka/api/GroupCoordinatorRequest.scala	42	8	2281	1459	2015-11-03	2018-02-02
core/src/main/scala/kafka/api/GroupCoordinatorResponse.scala	33	5	2281	1459	2015-11-03	2018-02-02
core/src/main/scala/kafka/api/LeaderAndIsr.scala	21	11	2239	1459	2015-12-15	2018-02-02
core/src/main/scala/kafka/api/OffsetCommitRequest.scala	130	20	3314	1459	2013-01-04	2018-02-02
core/src/main/scala/kafka/api/OffsetCommitResponse.scala	53	14	3314	1459	2013-01-04	2018-02-02
core/src/main/scala/kafka/api/OffsetFetchRequest.scala	75	18	3314	1459	2013-01-04	2018-02-02
core/src/main/scala/kafka/api/OffsetFetchResponse.scala	74	11	3314	1459	2013-01-04	2018-02-02
core/src/main/scala/kafka/api/OffsetRequest.scala	94	32	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/api/OffsetResponse.scala	70	22	3526	1459	2012-06-06	2018-02-02
core/src/main/scala/kafka/api/ProducerRequest.scala	109	49	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/api/ProducerResponse.scala	75	27	3618	1459	2012-03-06	2018-02-02
core/src/main/scala/kafka/api/RequestOrResponse.scala	16	21	3526	1459	2012-06-06	2018-02-02
core/src/main/scala/kafka/api/TopicMetadata.scala	105	28	3660	1816	2012-01-24	2017-02-10
core/src/main/scala/kafka/api/TopicMetadataRequest.scala	46	38	3660	1459	2012-01-24	2018-02-02
core/src/main/scala/kafka/api/TopicMetadataResponse.scala	32	15	3421	1459	2012-09-19	2018-02-02
core/src/main/scala/kafka/client/ClientUtils.scala	151	39	3397	1459	2012-10-13	2018-02-02
core/src/main/scala/kafka/cluster/Broker.scala	32	37	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/cluster/BrokerEndPoint.scala	37	7	2492	1924	2015-04-06	2016-10-25
core/src/main/scala/kafka/cluster/Cluster.scala	16	4	3827	2065	2011-08-10	2016-06-06
core/src/main/scala/kafka/cluster/EndPoint.scala	36	10	2492	1459	2015-04-06	2018-02-02
core/src/main/scala/kafka/cluster/Partition.scala	447	122	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/cluster/Replica.scala	121	31	3603	1459	2012-03-21	2018-02-02
core/src/main/scala/kafka/common/AdminCommandFailedException.scala	5	2	3400	3353	2012-10-10	2012-11-26
core/src/main/scala/kafka/common/AppInfo.scala	30	3	2629	2065	2014-11-20	2016-06-06
core/src/main/scala/kafka/common/AuthorizationException.scala	12	3	2342	2280	2015-09-03	2015-11-04
core/src/main/scala/kafka/common/BaseEnum.scala	4	1	2313	2313	2015-10-02	2015-10-02
core/src/main/scala/kafka/common/BrokerEndPointNotAvailableException.scala	4	1	2492	2492	2015-04-06	2015-04-06
core/src/main/scala/kafka/common/BrokerNotAvailableException.scala	4	2	3430	3353	2012-09-10	2012-11-26
core/src/main/scala/kafka/common/ClientIdAndBroker.scala	9	3	3332	2629	2012-12-17	2014-11-20
core/src/main/scala/kafka/common/ClientIdAndTopic.scala	9	3	3332	2629	2012-12-17	2014-11-20
core/src/main/scala/kafka/common/Config.scala	15	3	3332	3303	2012-12-17	2013-01-15
core/src/main/scala/kafka/common/ConsumerCoordinatorNotAvailableException.scala	4	1	2880	2880	2014-03-14	2014-03-14
core/src/main/scala/kafka/common/ConsumerRebalanceFailedException.scala	4	1	2472	2472	2015-04-26	2015-04-26
core/src/main/scala/kafka/common/ControllerMovedException.scala	5	2	3361	3353	2012-11-18	2012-11-26
core/src/main/scala/kafka/common/ErrorMapping.scala	66	38	3827	1816	2011-08-10	2017-02-10
core/src/main/scala/kafka/common/FailedToSendMessageException.scala	3	2	3645	3353	2012-02-08	2012-11-26
core/src/main/scala/kafka/common/GenerateBrokerIdException.scala	6	1	2576	2576	2015-01-12	2015-01-12
core/src/main/scala/kafka/common/InconsistentBrokerIdException.scala	6	1	2576	2576	2015-01-12	2015-01-12
core/src/main/scala/kafka/common/InterBrokerSendThread.scala	53	7	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/common/InvalidConfigException.scala	4	1	3827	3827	2011-08-10	2011-08-10
core/src/main/scala/kafka/common/InvalidMessageSizeException.scala	4	1	3770	3770	2011-10-06	2011-10-06
core/src/main/scala/kafka/common/InvalidOffsetException.scala	4	2	3163	3126	2013-06-04	2013-07-11
core/src/main/scala/kafka/common/KafkaException.scala	5	2	3478	3353	2012-07-24	2012-11-26
core/src/main/scala/kafka/common/KafkaStorageException.scala	6	4	3406	1459	2012-10-04	2018-02-02
core/src/main/scala/kafka/common/LeaderElectionNotNeededException.scala	5	2	3231	3129	2013-03-28	2013-07-08
core/src/main/scala/kafka/common/LeaderNotAvailableException.scala	5	4	3478	3255	2012-07-24	2013-03-04
core/src/main/scala/kafka/common/LogCleaningAbortedException.scala	3	2	2945	2926	2014-01-08	2014-01-27
core/src/main/scala/kafka/common/LongRef.scala	30	1	2168	2168	2016-02-24	2016-02-24
core/src/main/scala/kafka/common/MessageFormatter.scala	9	1	2162	2162	2016-03-01	2016-03-01
core/src/main/scala/kafka/common/MessageReader.scala	9	1	2162	2162	2016-03-01	2016-03-01
core/src/main/scala/kafka/common/MessageSetSizeTooLargeException.scala	4	1	2671	2671	2014-10-09	2014-10-09
core/src/main/scala/kafka/common/MessageSizeTooLargeException.scala	4	2	3402	3353	2012-10-08	2012-11-26
core/src/main/scala/kafka/common/MessageStreamsExistException.scala	3	2	2817	2239	2014-05-16	2015-12-15
core/src/main/scala/kafka/common/NoBrokersForPartitionException.scala	4	1	3770	3770	2011-10-06	2011-10-06
core/src/main/scala/kafka/common/NoEpochForPartitionException.scala	4	2	3570	3353	2012-04-23	2012-11-26
core/src/main/scala/kafka/common/NoReplicaOnlineException.scala	5	3	3234	2876	2013-03-25	2014-03-18
core/src/main/scala/kafka/common/NotAssignedReplicaException.scala	5	2	3013	2996	2013-11-01	2013-11-18
core/src/main/scala/kafka/common/NotCoordinatorForConsumerException.scala	4	1	2880	2880	2014-03-14	2014-03-14
core/src/main/scala/kafka/common/NotEnoughReplicasAfterAppendException.scala	4	1	2670	2670	2014-10-10	2014-10-10
core/src/main/scala/kafka/common/NotEnoughReplicasException.scala	4	1	2670	2670	2014-10-10	2014-10-10
core/src/main/scala/kafka/common/NotLeaderForPartitionException.scala	4	3	3535	3353	2012-05-28	2012-11-26
core/src/main/scala/kafka/common/OffsetMetadataAndError.scala	42	15	3314	1459	2013-01-04	2018-02-02
core/src/main/scala/kafka/common/OffsetMetadataTooLargeException.scala	4	1	3314	3314	2013-01-04	2013-01-04
core/src/main/scala/kafka/common/OffsetOutOfRangeException.scala	4	1	3827	3827	2011-08-10	2011-08-10
core/src/main/scala/kafka/common/OffsetsLoadInProgressException.scala	4	1	2880	2880	2014-03-14	2014-03-14
core/src/main/scala/kafka/common/QueueFullException.scala	4	2	3570	3353	2012-04-23	2012-11-26
core/src/main/scala/kafka/common/ReplicaNotAvailableException.scala	5	3	3478	3353	2012-07-24	2012-11-26
core/src/main/scala/kafka/common/RequestTimedOutException.scala	4	2	3503	3353	2012-06-29	2012-11-26
core/src/main/scala/kafka/common/StateChangeFailedException.scala	5	3	3422	3353	2012-09-18	2012-11-26
core/src/main/scala/kafka/common/StreamEndException.scala	3	1	2271	2271	2015-11-13	2015-11-13
core/src/main/scala/kafka/common/ThreadShutdownException.scala	3	2	2945	2926	2014-01-08	2014-01-27
core/src/main/scala/kafka/common/TopicAlreadyMarkedForDeletionException.scala	3	1	2390	2390	2015-07-17	2015-07-17
core/src/main/scala/kafka/common/TopicAndPartition.scala	6	14	3423	1459	2012-09-17	2018-02-02
core/src/main/scala/kafka/common/UnavailableProducerException.scala	4	1	3827	3827	2011-08-10	2011-08-10
core/src/main/scala/kafka/common/UnknownCodecException.scala	4	1	3827	3827	2011-08-10	2011-08-10
core/src/main/scala/kafka/common/UnknownException.scala	2	1	3827	3827	2011-08-10	2011-08-10
core/src/main/scala/kafka/common/UnknownMagicByteException.scala	4	1	3827	3827	2011-08-10	2011-08-10
core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala	4	3	3450	2628	2012-08-21	2014-11-21
core/src/main/scala/kafka/common/ZkNodeChangeNotificationListener.scala	90	17	2323	1459	2015-09-22	2018-02-02
core/src/main/scala/kafka/consumer/BaseConsumer.scala	118	17	2356	1459	2015-08-20	2018-02-02
core/src/main/scala/kafka/consumer/ConsumerConfig.scala	113	40	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/consumer/ConsumerConnector.scala	36	18	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala	119	51	3491	1459	2012-07-11	2018-02-02
core/src/main/scala/kafka/consumer/ConsumerFetcherThread.scala	112	43	3491	1459	2012-07-11	2018-02-02
core/src/main/scala/kafka/consumer/ConsumerIterator.scala	85	37	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/consumer/ConsumerTopicStats.scala	36	9	3350	1459	2012-11-29	2018-02-02
core/src/main/scala/kafka/consumer/FetchRequestAndResponseStats.scala	46	9	3332	1459	2012-12-17	2018-02-02
core/src/main/scala/kafka/consumer/FetchedDataChunk.scala	6	5	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/consumer/KafkaStream.scala	22	14	3586	1459	2012-04-07	2018-02-02
core/src/main/scala/kafka/consumer/PartitionAssignor.scala	96	12	2711	1459	2014-08-30	2018-02-02
core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala	48	24	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/consumer/SimpleConsumer.scala	119	59	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/consumer/TopicCount.scala	104	28	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/consumer/TopicEventHandler.scala	5	3	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/consumer/TopicFilter.scala	37	11	3586	1459	2012-04-07	2018-02-02
core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala	765	127	3830	1459	2011-08-07	2018-02-02
core/src/main/scala/kafka/consumer/ZookeeperTopicEventWatcher.scala	66	20	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/consumer/package.html	1	2	2915	2898	2014-02-07	2014-02-24
core/src/main/scala/kafka/controller/ControllerChannelManager.scala	420	111	3422	1459	2012-09-18	2018-02-02
core/src/main/scala/kafka/controller/ControllerContext.scala	70	3	1562	1459	2017-10-22	2018-02-02
core/src/main/scala/kafka/controller/ControllerEventManager.scala	52	6	1714	1459	2017-05-23	2018-02-02
core/src/main/scala/kafka/controller/ControllerState.scala	54	5	1714	1459	2017-05-23	2018-02-02
core/src/main/scala/kafka/controller/KafkaController.scala	1104	151	3422	1459	2012-09-18	2018-02-02
core/src/main/scala/kafka/controller/PartitionStateMachine.scala	362	73	3422	1459	2012-09-18	2018-02-02
core/src/main/scala/kafka/controller/ReplicaStateMachine.scala	296	76	3422	1459	2012-09-18	2018-02-02
core/src/main/scala/kafka/controller/StateChangeLogger.scala	19	3	1596	1459	2017-09-18	2018-02-02
core/src/main/scala/kafka/controller/TopicDeletionManager.scala	185	29	2915	1459	2014-02-07	2018-02-02
core/src/main/scala/kafka/coordinator/group/DelayedHeartbeat.scala	12	5	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala	35	6	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala	723	15	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala	286	13	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala	926	23	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/group/MemberMetadata.scala	66	3	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/group/OffsetConfig.scala	24	2	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/transaction/DelayedTxnMarker.scala	21	6	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/transaction/ProducerIdManager.scala	104	9	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala	411	22	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala	178	6	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala	300	20	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala	139	17	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala	267	16	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala	463	22	1741	1459	2017-04-26	2018-02-02
core/src/main/scala/kafka/javaapi/FetchRequest.scala	42	10	3423	1459	2012-09-17	2018-02-02
core/src/main/scala/kafka/javaapi/FetchResponse.scala	19	8	3640	1459	2012-02-13	2018-02-02
core/src/main/scala/kafka/javaapi/GroupCoordinatorResponse.scala	23	4	2281	1459	2015-11-03	2018-02-02
core/src/main/scala/kafka/javaapi/Implicits.scala	24	17	3827	2472	2011-08-10	2015-04-26
core/src/main/scala/kafka/javaapi/OffsetCommitRequest.scala	34	10	3314	1459	2013-01-04	2018-02-02
core/src/main/scala/kafka/javaapi/OffsetCommitResponse.scala	14	6	3314	1816	2013-01-04	2017-02-10
core/src/main/scala/kafka/javaapi/OffsetFetchRequest.scala	33	7	3314	1459	2013-01-04	2018-02-02
core/src/main/scala/kafka/javaapi/OffsetFetchResponse.scala	10	4	3314	1900	2013-01-04	2016-11-18
core/src/main/scala/kafka/javaapi/OffsetRequest.scala	26	9	3413	1459	2012-09-27	2018-02-02
core/src/main/scala/kafka/javaapi/OffsetResponse.scala	19	5	3413	1459	2012-09-27	2018-02-02
core/src/main/scala/kafka/javaapi/TopicMetadata.scala	33	12	3421	1459	2012-09-19	2018-02-02
core/src/main/scala/kafka/javaapi/TopicMetadataRequest.scala	39	20	3421	1459	2012-09-19	2018-02-02
core/src/main/scala/kafka/javaapi/TopicMetadataResponse.scala	17	5	3421	1459	2012-09-19	2018-02-02
core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java	23	16	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/javaapi/consumer/ConsumerRebalanceListener.java	9	6	2614	1459	2014-12-05	2018-02-02
core/src/main/scala/kafka/javaapi/consumer/SimpleConsumer.scala	40	12	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala	58	22	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/javaapi/message/ByteBufferMessageSet.scala	35	15	3827	2168	2011-08-10	2016-02-24
core/src/main/scala/kafka/javaapi/message/MessageSet.scala	14	8	3827	3353	2011-08-10	2012-11-26
core/src/main/scala/kafka/javaapi/producer/Producer.scala	18	13	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/log/AbstractIndex.scala	166	16	1991	1459	2016-08-19	2018-02-02
core/src/main/scala/kafka/log/CleanerConfig.scala	11	4	3289	2472	2013-01-29	2015-04-26
core/src/main/scala/kafka/log/CorruptIndexException.scala	2	2	1511	1459	2017-12-12	2018-02-02
core/src/main/scala/kafka/log/IndexEntry.scala	17	3	1991	1459	2016-08-19	2018-02-02
core/src/main/scala/kafka/log/Log.scala	1086	173	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/log/LogCleaner.scala	615	65	3289	1459	2013-01-29	2018-02-02
core/src/main/scala/kafka/log/LogCleanerManager.scala	241	29	2945	1459	2014-01-08	2018-02-02
core/src/main/scala/kafka/log/LogConfig.scala	262	49	3289	1459	2013-01-29	2018-02-02
core/src/main/scala/kafka/log/LogManager.scala	682	105	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/log/LogSegment.scala	334	64	3402	1459	2012-10-08	2018-02-02
core/src/main/scala/kafka/log/LogValidator.scala	272	18	1875	1459	2016-12-13	2018-02-02
core/src/main/scala/kafka/log/OffsetIndex.scala	100	47	3402	1459	2012-10-08	2018-02-02
core/src/main/scala/kafka/log/OffsetMap.scala	99	10	3289	1459	2013-01-29	2018-02-02
core/src/main/scala/kafka/log/ProducerStateManager.scala	503	18	1731	1459	2017-05-06	2018-02-02
core/src/main/scala/kafka/log/TimeIndex.scala	112	12	1991	1459	2016-08-19	2018-02-02
core/src/main/scala/kafka/log/TransactionIndex.scala	165	5	1731	1459	2017-05-06	2018-02-02
core/src/main/scala/kafka/log/package.html	4	3	3347	2898	2012-12-02	2014-02-24
core/src/main/scala/kafka/message/ByteBufferMessageSet.scala	79	55	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/message/CompressionCodec.scala	67	10	3827	2111	2011-08-10	2016-04-21
core/src/main/scala/kafka/message/InvalidMessageException.scala	6	5	3827	2093	2011-08-10	2016-05-09
core/src/main/scala/kafka/message/Message.scala	172	27	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/message/MessageAndMetadata.scala	14	9	3586	2114	2012-04-07	2016-04-18
core/src/main/scala/kafka/message/MessageAndOffset.scala	25	10	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/message/MessageLengthException.scala	2	2	3827	2239	2011-08-10	2015-12-15
core/src/main/scala/kafka/message/MessageSet.scala	46	17	3827	1774	2011-08-10	2017-03-24
core/src/main/scala/kafka/message/package.html	1	2	2915	2898	2014-02-07	2014-02-24
core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala	52	13	3455	1459	2012-08-16	2018-02-02
core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala	6	5	3455	2492	2012-08-16	2015-04-06
core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala	131	23	3455	1459	2012-08-16	2018-02-02
core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala	37	8	3455	1962	2012-08-16	2016-09-17
core/src/main/scala/kafka/metrics/KafkaTimer.scala	9	5	3455	1459	2012-08-16	2018-02-02
core/src/main/scala/kafka/network/BlockingChannel.scala	92	17	3598	1459	2012-03-26	2018-02-02
core/src/main/scala/kafka/network/RequestChannel.scala	336	98	3671	1459	2012-01-13	2018-02-02
core/src/main/scala/kafka/network/RequestOrResponseSend.scala	29	5	2433	1459	2015-06-04	2018-02-02
core/src/main/scala/kafka/network/SocketServer.scala	566	101	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/network/package.html	11	2	2915	2898	2014-02-07	2014-02-24
core/src/main/scala/kafka/producer/BaseProducer.scala	41	4	2828	2145	2014-05-05	2016-03-18
core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala	69	35	3827	1816	2011-08-10	2017-02-10
core/src/main/scala/kafka/producer/ByteArrayPartitioner.scala	10	5	3113	2145	2013-07-24	2016-03-18
core/src/main/scala/kafka/producer/DefaultPartitioner.scala	10	14	3827	1924	2011-08-10	2016-10-25
core/src/main/scala/kafka/producer/KeyedMessage.scala	18	5	3364	2145	2012-11-15	2016-03-18
core/src/main/scala/kafka/producer/Partitioner.scala	6	5	3827	2145	2011-08-10	2016-03-18
core/src/main/scala/kafka/producer/Producer.scala	101	39	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/producer/ProducerClosedException.scala	4	3	3645	2145	2012-02-08	2016-03-18
core/src/main/scala/kafka/producer/ProducerConfig.scala	48	27	3827	2145	2011-08-10	2016-03-18
core/src/main/scala/kafka/producer/ProducerPool.scala	59	24	3830	1459	2011-08-07	2018-02-02
core/src/main/scala/kafka/producer/ProducerRequestStats.scala	36	9	3332	2065	2012-12-17	2016-06-06
core/src/main/scala/kafka/producer/ProducerStats.scala	22	7	3332	2145	2012-12-17	2016-03-18
core/src/main/scala/kafka/producer/ProducerTopicStats.scala	37	7	3332	2145	2012-12-17	2016-03-18
core/src/main/scala/kafka/producer/SyncProducer.scala	116	52	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/producer/SyncProducerConfig.scala	29	20	3827	2145	2011-08-10	2016-03-18
core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala	13	9	3827	2145	2011-08-10	2016-03-18
core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala	292	74	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/producer/async/EventHandler.scala	7	7	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/producer/async/IllegalQueueStateException.scala	5	2	3813	2145	2011-08-24	2016-03-18
core/src/main/scala/kafka/producer/async/MissingConfigException.scala	5	2	3827	2145	2011-08-10	2016-03-18
core/src/main/scala/kafka/producer/async/ProducerSendThread.scala	78	34	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/security/CredentialProvider.scala	29	3	1847	1459	2017-01-10	2018-02-02
core/src/main/scala/kafka/security/SecurityUtils.scala	29	2	1689	1459	2017-06-17	2018-02-02
core/src/main/scala/kafka/security/auth/Acl.scala	45	6	2342	1459	2015-09-03	2018-02-02
core/src/main/scala/kafka/security/auth/Authorizer.scala	14	6	2342	1834	2015-09-03	2017-01-23
core/src/main/scala/kafka/security/auth/Operation.scala	59	8	2342	1459	2015-09-03	2018-02-02
core/src/main/scala/kafka/security/auth/PermissionType.scala	22	8	2342	1459	2015-09-03	2018-02-02
core/src/main/scala/kafka/security/auth/Resource.scala	19	6	2342	1459	2015-09-03	2018-02-02
core/src/main/scala/kafka/security/auth/ResourceType.scala	41	13	2342	1459	2015-09-03	2018-02-02
core/src/main/scala/kafka/security/auth/SimpleAclAuthorizer.scala	235	31	2323	1459	2015-09-22	2018-02-02
core/src/main/scala/kafka/serializer/Decoder.scala	29	9	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/serializer/Encoder.scala	35	8	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/server/AbstractFetcherManager.scala	139	32	3509	1459	2012-06-23	2018-02-02
core/src/main/scala/kafka/server/AbstractFetcherThread.scala	306	89	3509	1459	2012-06-23	2018-02-02
core/src/main/scala/kafka/server/AdminManager.scala	365	17	2029	1459	2016-07-12	2018-02-02
core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala	56	8	2576	1459	2015-01-12	2018-02-02
core/src/main/scala/kafka/server/BrokerStates.scala	17	2	2826	2042	2014-05-07	2016-06-29
core/src/main/scala/kafka/server/ClientQuotaManager.scala	320	27	2361	1459	2015-08-15	2018-02-02
core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala	53	7	1736	1459	2017-05-01	2018-02-02
core/src/main/scala/kafka/server/ConfigHandler.scala	145	26	2372	1459	2015-08-04	2018-02-02
core/src/main/scala/kafka/server/DelayedCreatePartitions.scala	45	3	1593	1459	2017-09-21	2018-02-02
core/src/main/scala/kafka/server/DelayedDeleteRecords.scala	77	4	1770	1459	2017-03-28	2018-02-02
core/src/main/scala/kafka/server/DelayedDeleteTopics.scala	35	1	1998	1998	2016-08-12	2016-08-12
core/src/main/scala/kafka/server/DelayedFetch.scala	113	23	2735	1459	2014-08-06	2018-02-02
core/src/main/scala/kafka/server/DelayedOperation.scala	213	20	2615	1459	2014-12-04	2018-02-02
core/src/main/scala/kafka/server/DelayedOperationKey.scala	21	9	2615	1459	2014-12-04	2018-02-02
core/src/main/scala/kafka/server/DelayedProduce.scala	84	17	2735	1459	2014-08-06	2018-02-02
core/src/main/scala/kafka/server/DelegationTokenManager.scala	345	2	1476	1459	2018-01-16	2018-02-02
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala	444	6	1469	1459	2018-01-23	2018-02-02
core/src/main/scala/kafka/server/DynamicConfig.scala	67	8	1952	1459	2016-09-27	2018-02-02
core/src/main/scala/kafka/server/DynamicConfigManager.scala	100	19	2372	1459	2015-08-04	2018-02-02
core/src/main/scala/kafka/server/FetchDataInfo.scala	7	6	2735	1459	2014-08-06	2018-02-02
core/src/main/scala/kafka/server/KafkaApis.scala	1829	259	3671	1459	2012-01-13	2018-02-02
core/src/main/scala/kafka/server/KafkaConfig.scala	1063	185	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/server/KafkaRequestHandler.scala	182	48	3671	1459	2012-01-13	2018-02-02
core/src/main/scala/kafka/server/KafkaServer.scala	480	199	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/server/KafkaServerStartable.scala	34	29	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/server/LogDirFailureChannel.scala	15	3	1654	1459	2017-07-22	2018-02-02
core/src/main/scala/kafka/server/LogOffsetMetadata.scala	40	7	2735	1459	2014-08-06	2018-02-02
core/src/main/scala/kafka/server/MetadataCache.scala	181	31	2840	1459	2014-04-23	2018-02-02
core/src/main/scala/kafka/server/QuotaFactory.scala	79	7	1963	1459	2016-09-16	2018-02-02
core/src/main/scala/kafka/server/ReplicaAlterLogDirsManager.scala	18	2	1567	1459	2017-10-17	2018-02-02
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala	200	2	1567	1459	2017-10-17	2018-02-02
core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala	82	4	1761	1459	2017-04-06	2018-02-02
core/src/main/scala/kafka/server/ReplicaFetcherManager.scala	19	20	3509	1824	2012-06-23	2017-02-02
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala	269	101	3531	1459	2012-06-01	2018-02-02
core/src/main/scala/kafka/server/ReplicaManager.scala	1101	180	3601	1459	2012-03-23	2018-02-02
core/src/main/scala/kafka/server/ReplicationQuotaManager.scala	103	5	1963	1459	2016-09-16	2018-02-02
core/src/main/scala/kafka/server/SensorAccess.scala	26	3	1963	1459	2016-09-16	2018-02-02
core/src/main/scala/kafka/server/ThrottledResponse.scala	16	2	2361	2350	2015-08-15	2015-08-26
core/src/main/scala/kafka/server/checkpoints/CheckpointFile.scala	99	6	1761	1459	2017-04-06	2018-02-02
core/src/main/scala/kafka/server/checkpoints/LeaderEpochCheckpointFile.scala	34	4	1761	1459	2017-04-06	2018-02-02
core/src/main/scala/kafka/server/checkpoints/OffsetCheckpointFile.scala	33	5	1761	1459	2017-04-06	2018-02-02
core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala	114	10	1761	1459	2017-04-06	2018-02-02
core/src/main/scala/kafka/server/package.html	1	2	2915	2898	2014-02-07	2014-02-24
core/src/main/scala/kafka/tools/ConsoleConsumer.scala	495	53	2797	1459	2014-06-05	2018-02-02
core/src/main/scala/kafka/tools/ConsoleProducer.scala	287	26	2797	1459	2014-06-05	2018-02-02
core/src/main/scala/kafka/tools/ConsumerPerformance.scala	349	26	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/tools/DumpLogSegments.scala	406	62	3814	1459	2011-08-23	2018-02-02
core/src/main/scala/kafka/tools/EndToEndLatency.scala	90	12	2378	1778	2015-07-29	2017-03-20
core/src/main/scala/kafka/tools/ExportZkOffsets.scala	77	20	3632	1459	2012-02-21	2018-02-02
core/src/main/scala/kafka/tools/GetOffsetShell.scala	81	17	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/tools/ImportZkOffsets.scala	58	17	3632	1459	2012-02-21	2018-02-02
core/src/main/scala/kafka/tools/JmxTool.scala	149	25	3752	1459	2011-10-24	2018-02-02
core/src/main/scala/kafka/tools/MirrorMaker.scala	583	79	3586	1459	2012-04-07	2018-02-02
core/src/main/scala/kafka/tools/PerfConfig.scala	22	8	2797	1459	2014-06-05	2018-02-02
core/src/main/scala/kafka/tools/ProducerPerformance.scala	257	26	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/tools/ReplayLogProducer.scala	128	31	3830	1459	2011-08-07	2018-02-02
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala	319	28	2994	1459	2013-11-20	2018-02-02
core/src/main/scala/kafka/tools/SimpleConsumerPerformance.scala	123	12	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/tools/SimpleConsumerShell.scala	219	44	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/tools/StateChangeLogMerger.scala	129	12	3253	1459	2013-03-06	2018-02-02
core/src/main/scala/kafka/tools/StreamsResetter.java	500	22	2008	1459	2016-08-02	2018-02-02
core/src/main/scala/kafka/tools/UpdateOffsetsInZK.scala	62	14	3413	1459	2012-09-27	2018-02-02
core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala	96	24	3651	1459	2012-02-02	2018-02-02
core/src/main/scala/kafka/tools/ZooKeeperMainWrapper.scala	15	3	2708	1824	2014-09-02	2017-02-02
core/src/main/scala/kafka/utils/Annotations.scala	5	4	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/utils/CommandLineUtils.scala	41	16	3397	1824	2012-10-13	2017-02-02
core/src/main/scala/kafka/utils/CoreUtils.scala	175	28	2705	1459	2014-09-05	2018-02-02
core/src/main/scala/kafka/utils/DelayedItem.scala	15	9	3827	1886	2011-08-10	2016-12-02
core/src/main/scala/kafka/utils/Exit.scala	23	4	1824	1459	2017-02-02	2018-02-02
core/src/main/scala/kafka/utils/FileLock.scala	40	8	3377	1459	2012-11-02	2018-02-02
core/src/main/scala/kafka/utils/Implicits.scala	12	2	1626	1459	2017-08-19	2018-02-02
core/src/main/scala/kafka/utils/IteratorTemplate.scala	52	12	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/utils/Json.scala	40	12	3397	1459	2012-10-13	2018-02-02
core/src/main/scala/kafka/utils/KafkaScheduler.scala	75	24	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/utils/Log4jController.scala	50	5	3446	1459	2012-08-25	2018-02-02
core/src/main/scala/kafka/utils/Logging.scala	40	17	3722	1459	2011-11-23	2018-02-02
core/src/main/scala/kafka/utils/Mx4jLoader.scala	37	12	3770	1459	2011-10-06	2018-02-02
core/src/main/scala/kafka/utils/NotNothing.scala	8	1	1802	1802	2017-02-24	2017-02-24
core/src/main/scala/kafka/utils/Pool.scala	47	13	3827	1459	2011-08-10	2018-02-02
core/src/main/scala/kafka/utils/ReplicationUtils.scala	33	17	2792	1459	2014-06-10	2018-02-02
core/src/main/scala/kafka/utils/ShutdownableThread.scala	60	13	3450	1459	2012-08-21	2018-02-02
core/src/main/scala/kafka/utils/Throttler.scala	65	9	3827	1886	2011-08-10	2016-12-02
core/src/main/scala/kafka/utils/ToolsUtils.scala	37	6	2684	1459	2014-09-26	2018-02-02
core/src/main/scala/kafka/utils/VerifiableProperties.scala	118	16	3446	1900	2012-08-25	2016-11-18
core/src/main/scala/kafka/utils/ZkUtils.scala	915	150	3830	1459	2011-08-07	2018-02-02
core/src/main/scala/kafka/utils/json/DecodeJson.scala	69	2	1649	1459	2017-07-27	2018-02-02
core/src/main/scala/kafka/utils/json/JsonArray.scala	7	2	1649	1459	2017-07-27	2018-02-02
core/src/main/scala/kafka/utils/json/JsonObject.scala	13	2	1649	1459	2017-07-27	2018-02-02
core/src/main/scala/kafka/utils/json/JsonValue.scala	40	3	1649	1459	2017-07-27	2018-02-02
core/src/main/scala/kafka/utils/timer/Timer.scala	71	7	2490	1459	2015-04-08	2018-02-02
core/src/main/scala/kafka/utils/timer/TimerTask.scala	21	3	2490	2118	2015-04-08	2016-04-14
core/src/main/scala/kafka/utils/timer/TimerTaskList.scala	103	5	2490	1886	2015-04-08	2016-12-02
core/src/main/scala/kafka/utils/timer/TimingWheel.scala	49	4	2490	2118	2015-04-08	2016-04-14
core/src/main/scala/kafka/zk/AdminZkClient.scala	248	4	1531	1459	2017-11-22	2018-02-02
core/src/main/scala/kafka/zk/KafkaZkClient.scala	901	19	1558	1459	2017-10-26	2018-02-02
core/src/main/scala/kafka/zk/ZkData.scala	406	17	1558	1459	2017-10-26	2018-02-02
core/src/main/scala/kafka/zookeeper/ZooKeeperClient.scala	324	7	1558	1459	2017-10-26	2018-02-02
doap_Kafka.rdf	34	2	2851	2090	2014-04-12	2016-05-12
gradle/resources/rat-output-to-html.xsl	153	1	2401	2401	2015-07-06	2015-07-06
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/TopicBenchmark.java	31	2	1700	1459	2017-06-06	2018-02-02
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRecordBenchmark.java	25	2	1702	1459	2017-06-04	2018-02-02
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java	104	3	1706	1459	2017-05-31	2018-02-02
kafka-merge-pr.py	306	22	2398	1459	2015-07-09	2018-02-02
log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java	212	9	2401	1459	2015-07-06	2018-02-02
release.py	275	6	1727	1459	2017-05-10	2018-02-02
release_notes.py	64	5	2014	1459	2016-07-27	2018-02-02
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java	45	2	1634	1459	2017-08-11	2018-02-02
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java	36	2	1634	1459	2017-08-11	2018-02-02
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java	59	3	1634	1459	2017-08-11	2018-02-02
streams/src/main/java/org/apache/kafka/streams/Consumed.java	56	3	1606	1459	2017-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/KafkaClientSupplier.java	12	7	2096	1459	2016-05-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java	577	71	2201	1459	2016-01-22	2018-02-02
streams/src/main/java/org/apache/kafka/streams/KeyValue.java	32	6	2201	1798	2016-01-22	2017-02-28
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java	166	13	1645	1459	2017-07-31	2018-02-02
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java	584	65	2201	1459	2016-01-22	2018-02-02
streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java	31	10	2201	1459	2016-01-22	2018-02-02
streams/src/main/java/org/apache/kafka/streams/Topology.java	194	6	1648	1459	2017-07-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java	30	6	1652	1459	2017-07-24	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java	13	3	1746	1459	2017-04-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java	13	2	1508	1459	2017-12-15	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/DeserializationExceptionHandler.java	19	2	1666	1459	2017-07-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java	13	5	1971	1459	2016-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/LockException.java	13	5	1875	1459	2016-12-13	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java	23	3	1666	1459	2017-07-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java	23	3	1666	1459	2017-07-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java	13	6	2197	1459	2016-01-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/ProductionExceptionHandler.java	18	2	1508	1459	2017-12-15	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java	14	5	2197	1459	2016-01-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/TaskAssignmentException.java	13	4	2197	1798	2016-01-26	2017-02-28
streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java	13	6	2197	1459	2016-01-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/TaskMigratedException.java	24	2	1585	1459	2017-09-29	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/TopologyBuilderException.java	14	7	2197	1459	2016-01-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/errors/TopologyException.java	14	2	1648	1459	2017-07-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java	4	13	2215	1459	2016-01-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java	4	10	2124	1459	2016-04-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java	10	11	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java	4	11	2190	1459	2016-02-02	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java	60	18	2215	1459	2016-01-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java	49	2	1608	1459	2017-09-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java	123	24	2055	1459	2016-06-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java	58	19	2111	1459	2016-04-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java	193	65	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java	306	40	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java	191	48	2250	1459	2015-12-04	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java	5	12	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Materialized.java	85	5	1606	1459	2017-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java	4	6	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java	5	12	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Printed.java	49	3	1606	1459	2017-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java	53	3	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java	5	12	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Serialized.java	24	3	1608	1459	2017-09-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java	23	4	1593	1459	2017-09-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java	42	9	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java	21	3	1593	1459	2017-09-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java	69	12	2103	1459	2016-04-29	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java	14	15	2306	1459	2015-10-09	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java	4	9	2306	1459	2015-10-09	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java	56	15	2215	1459	2016-01-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java	4	11	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java	4	12	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapperWithKey.java	4	2	1476	1459	2018-01-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java	15	14	2306	1459	2015-10-09	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java	4	10	2306	1459	2015-10-09	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java	12	2	1476	1459	2018-01-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java	4	2	1476	1459	2018-01-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Window.java	48	14	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java	33	14	2215	1459	2016-01-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java	32	17	2215	1459	2016-01-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java	150	18	2245	1459	2015-12-09	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CacheFlushListener.java	5	2	1963	1798	2016-09-16	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/Change.java	26	3	2238	1798	2015-12-16	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedDeserializer.java	41	5	2209	1459	2016-01-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java	50	7	2209	1459	2016-01-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ConsumedInternal.java	31	2	1606	1459	2017-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ForwardingCacheFlushListener.java	28	3	1963	1798	2016-09-16	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GlobalKTableImpl.java	25	5	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java	63	4	1596	1459	2017-09-18	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalNameProvider.java	5	2	1578	1459	2017-10-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java	161	10	1645	1459	2017-07-31	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalValueTransformerWithKey.java	5	2	1476	1459	2018-01-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalValueTransformerWithKeySupplier.java	4	2	1476	1459	2018-01-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java	441	20	2055	1459	2016-06-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java	234	19	2111	1459	2016-04-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggProcessorSupplier.java	6	2	2163	1798	2016-02-29	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java	75	18	2205	1459	2016-01-18	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamBranch.java	27	3	2319	1798	2015-09-26	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFilter.java	25	4	2319	1798	2015-09-26	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMap.java	24	6	2319	1798	2015-09-26	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValues.java	24	7	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoin.java	24	3	1845	1798	2017-01-12	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java	769	68	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamJoinWindow.java	36	9	2217	1459	2016-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java	53	12	2217	1459	2016-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoin.java	25	4	1929	1798	2016-10-20	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java	35	5	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMap.java	23	6	2319	1798	2015-09-26	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMapValues.java	22	7	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPassThrough.java	16	4	2319	1798	2015-09-26	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPeek.java	26	4	1810	1459	2017-02-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPrint.java	27	3	1720	1459	2017-05-17	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java	73	14	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java	122	4	1851	1798	2017-01-06	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransform.java	46	9	2306	1459	2015-10-09	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java	137	10	2306	1459	2015-10-09	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java	108	14	2163	1459	2016-02-29	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowReduce.java	106	14	2163	1459	2016-02-29	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java	64	14	2209	1459	2016-01-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java	95	11	2250	1459	2015-12-04	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java	710	58	2250	1459	2015-12-04	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java	25	6	2238	1459	2015-12-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoinValueGetterSupplier.java	22	4	1474	1459	2018-01-18	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java	91	2	1462	1459	2018-01-30	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java	76	7	2238	1459	2015-12-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java	78	14	2245	1459	2015-12-09	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinValueGetter.java	34	2	1845	1798	2017-01-12	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java	78	14	2244	1459	2015-12-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java	77	14	2244	1459	2015-12-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java	89	12	2250	1459	2015-12-04	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMaterializedValueGetterSupplier.java	28	2	1474	1459	2018-01-18	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableProcessorSupplier.java	6	5	2250	1798	2015-12-04	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java	60	11	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java	65	14	2209	1459	2016-01-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java	39	11	2250	1798	2015-12-04	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSourceValueGetterSupplier.java	26	5	2250	1798	2015-12-04	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetter.java	6	2	2250	1798	2015-12-04	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetterSupplier.java	5	3	2250	1798	2015-12-04	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KeyValueStoreMaterializer.java	31	3	1606	1459	2017-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.java	47	4	1606	1459	2017-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintForeachAction.java	30	2	1606	1459	2017-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintedInternal.java	12	2	1606	1459	2017-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ProducedInternal.java	18	2	1603	1459	2017-09-11	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SerializedInternal.java	14	2	1603	1459	2017-09-11	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionKeySerde.java	116	9	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindow.java	17	3	1845	1798	2017-01-12	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java	172	4	1593	1459	2017-09-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindow.java	21	4	2103	1798	2016-04-29	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java	152	4	1593	1459	2017-09-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java	42	6	1901	1459	2016-11-17	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindow.java	17	5	2215	1798	2016-01-08	2017-02-28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedDeserializer.java	63	5	2209	1459	2016-01-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedSerializer.java	50	7	2209	1459	2016-01-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedStreamPartitioner.java	17	7	2208	1459	2016-01-15	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingBatchingRestoreCallback.java	26	2	1648	1459	2017-07-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingRestoreCallback.java	21	2	1648	1459	2017-07-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/AbstractProcessor.java	20	5	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java	6	2	1648	1459	2017-07-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/Cancellable.java	4	3	1678	1459	2017-06-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/DefaultPartitionGrouper.java	51	15	2289	1796	2015-10-26	2017-03-02
streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java	17	4	1878	1459	2016-12-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java	22	5	1878	1459	2016-12-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java	16	4	1878	1459	2016-12-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/PartitionGrouper.java	8	13	2289	1459	2015-10-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/Processor.java	10	9	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java	31	24	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorSupplier.java	4	4	2306	1798	2015-10-09	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/PunctuationType.java	5	3	1678	1459	2017-06-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/Punctuator.java	4	3	1678	1459	2017-06-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java	6	4	2312	1459	2015-10-03	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreListener.java	15	2	1648	1459	2017-07-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java	10	11	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/StateStoreSupplier.java	9	9	2282	1459	2015-11-02	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/StreamPartitioner.java	5	5	2216	1798	2016-01-07	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java	67	9	2288	1798	2015-10-27	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java	44	2	1609	1459	2017-09-05	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/ThreadMetadata.java	59	2	1609	1459	2017-09-05	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java	8	11	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java	391	52	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java	18	4	1878	1459	2016-12-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java	10	7	2145	1459	2016-03-18	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java	159	12	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractStateManager.java	77	4	1512	1459	2017-12-11	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java	190	47	2268	1459	2015-11-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStandbyTasks.java	7	2	1547	1459	2017-11-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasks.java	98	3	1547	1459	2017-11-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java	385	17	1623	1459	2017-08-22	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java	10	7	1802	1459	2017-02-24	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/Checkpointable.java	7	2	1809	1798	2017-02-17	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListener.java	72	4	1648	1459	2017-07-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultKafkaClientSupplier.java	28	5	2096	1459	2016-05-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamPartitioner.java	22	2	2000	1798	2016-08-10	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java	41	7	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java	11	2	1845	1798	2017-01-12	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManager.java	7	5	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java	297	18	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java	77	11	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java	243	14	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java	12	6	1963	1459	2016-09-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java	38	9	1971	1459	2016-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java	180	25	2169	1459	2016-02-23	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java	1507	18	1652	1459	2017-07-24	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/MinTimestampTracker.java	40	7	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java	99	13	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java	93	28	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java	150	17	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java	6	2	1678	1459	2017-06-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java	45	2	1963	1798	2016-09-16	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java	263	62	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java	152	11	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationQueue.java	36	7	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationSchedule.java	61	7	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/QuickUnion.java	37	5	2289	1459	2015-10-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java	28	21	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java	201	17	1882	1459	2016-12-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordContext.java	8	2	1963	1798	2016-09-16	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java	61	4	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java	101	16	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java	45	2	1503	1459	2017-12-20	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/RestoringTasks.java	5	3	1585	1459	2017-09-29	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java	79	22	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java	68	14	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java	16	2	2319	1798	2015-09-26	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/internals/StampedRecord.java	26	2	2319	1798	2015-09-26	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyContextImpl.java	124	24	2268	1459	2015-11-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java	89	36	2268	1459	2015-11-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java	241	15	2022	1459	2016-07-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java	19	7	1845	1459	2017-01-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestorer.java	81	8	1802	1459	2017-02-24	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java	246	20	1802	1459	2017-02-24	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java	523	60	2201	1459	2016-01-22	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java	418	79	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java	836	136	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java	183	12	2000	1459	2016-08-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetricsImpl.java	151	9	1846	1459	2017-01-11	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java	29	7	1634	1459	2017-08-11	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskAction.java	5	3	1623	1459	2017-08-22	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java	325	18	1634	1459	2017-08-11	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/ThreadStateTransitionValidator.java	4	2	1670	1459	2017-07-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/TimestampTracker.java	9	4	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java	42	2	1503	1459	2017-12-20	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.java	53	2	1503	1459	2017-12-20	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/WrappedBatchingStateRestoreCallback.java	22	2	1648	1459	2017-07-28	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java	137	10	2272	1459	2015-11-12	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java	112	8	2272	1788	2015-11-12	2017-03-10
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.java	247	7	1825	1459	2017-02-01	2018-02-02
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java	109	6	2272	1798	2015-11-12	2017-02-28
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignor.java	4	7	2272	1798	2015-11-12	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/HostInfo.java	44	6	2000	1459	2016-08-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/KeyValueBytesStoreSupplier.java	4	2	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/KeyValueIterator.java	9	9	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java	10	12	2319	1459	2015-09-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java	7	4	2022	1459	2016-07-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java	58	5	2022	1459	2016-07-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java	8	6	2022	1459	2016-07-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java	6	8	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java	9	11	2022	1459	2016-07-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/RocksDBConfigSetter.java	6	2	2020	1798	2016-07-21	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/SessionBytesStoreSupplier.java	5	2	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java	9	8	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/StateSerdes.java	60	9	2146	1459	2016-03-17	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/StoreBuilder.java	12	2	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/StoreSupplier.java	7	2	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/Stores.java	288	24	2301	1459	2015-10-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java	61	5	2000	1459	2016-08-10	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/WindowBytesStoreSupplier.java	8	2	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java	6	12	2218	1459	2016-01-05	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/WindowStoreIterator.java	7	10	2218	1459	2016-01-05	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterator.java	104	6	1840	1459	2017-01-17	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractStoreBuilder.java	58	2	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractStoreSupplier.java	36	7	1971	1459	2016-09-08	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFunction.java	6	2	1718	1459	2017-05-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/CachedStateStore.java	6	4	1963	1459	2016-09-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java	232	20	1963	1459	2016-09-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java	168	15	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java	195	16	1963	1459	2016-09-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java	70	5	1840	1459	2017-01-17	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java	59	2	1619	1459	2017-08-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java	65	5	1623	1459	2017-08-22	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeKeyValueIterator.java	46	2	1627	1459	2017-08-18	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java	79	9	2022	1459	2016-07-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStore.java	55	5	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java	82	11	2022	1459	2016-07-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIterator.java	61	6	1963	1798	2016-09-16	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/FilteredCacheIterator.java	76	3	1784	1459	2017-03-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProvider.java	25	2	1845	1798	2017-01-12	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/HasNextCondition.java	6	2	1851	1798	2017-01-06	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueLoggedStore.java	86	16	2190	1459	2016-02-02	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java	137	7	1823	1459	2017-02-03	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStoreSupplier.java	18	18	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryLRUCacheStoreSupplier.java	20	12	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/InnerMeteredKeyValueStore.java	256	3	1631	1459	2017-08-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueIterators.java	40	2	1718	1459	2017-05-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java	38	2	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java	55	4	1963	1798	2016-09-16	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java	134	18	2190	1459	2016-02-02	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java	58	5	2190	1798	2016-02-02	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreIterator.java	30	2	1631	1459	2017-08-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheSessionStoreIterator.java	40	7	1840	1459	2017-01-17	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIterator.java	35	5	1840	1459	2017-01-17	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreKeyValueIterator.java	48	3	1718	1459	2017-05-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueBytesStore.java	105	4	1631	1459	2017-08-14	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java	84	20	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java	139	3	1619	1459	2017-08-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java	117	11	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java	52	2	1623	1459	2017-08-22	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java	58	2	1623	1459	2017-08-22	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java	317	17	1963	1459	2016-09-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/NextIteratorFunction.java	5	2	1627	1459	2017-08-18	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/OffsetCheckpoint.java	111	10	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/OrderedBytes.java	32	2	1718	1459	2017-05-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/PeekingKeyValueIterator.java	6	3	1963	1798	2016-09-16	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java	32	8	2022	1459	2016-07-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBKeyValueStoreSupplier.java	28	14	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java	114	8	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java	87	9	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStoreSupplier.java	32	10	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java	448	57	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java	100	24	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreSupplier.java	42	19	2202	1459	2016-01-21	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.java	25	2	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbSessionBytesStoreSupplier.java	39	3	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java	62	3	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java	27	7	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java	65	6	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java	25	7	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedCacheFunction.java	47	3	1718	1459	2017-05-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java	197	13	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/SerializedKeyValueIterator.java	43	3	1840	1798	2017-01-17	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java	68	8	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilder.java	39	2	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/StateStoreProvider.java	8	3	2022	1798	2016-07-19	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreChangeLogger.java	30	11	2202	1798	2016-01-21	2017-02-28
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java	38	10	2022	1459	2016-07-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java	250	19	1963	1459	2016-09-16	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java	65	8	1823	1459	2017-02-03	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java	43	2	1607	1459	2017-09-07	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java	149	2	1718	1459	2017-05-19	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreSupplier.java	6	5	1851	1459	2017-01-06	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreUtils.java	47	11	2106	1459	2016-04-26	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java	57	4	1823	1459	2017-02-03	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java	54	5	1840	1459	2017-01-17	2018-02-02
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java	24	7	2022	1459	2016-07-19	2018-02-02
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java	345	2	1462	1459	2018-01-30	2018-02-02
tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java	450	13	1833	1459	2017-01-24	2018-02-02
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java	344	17	2288	1459	2015-10-27	2018-02-02
tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java	257	3	1544	1459	2017-11-09	2018-02-02
tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java	67	7	2288	1798	2015-10-27	2017-02-28
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java	36	3	1748	1459	2017-04-19	2018-02-02
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java	256	6	1705	1459	2017-06-01	2018-02-02
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java	496	11	2274	1459	2015-11-10	2018-02-02
tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java	188	10	2288	1459	2015-10-27	2018-02-02
tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java	364	16	2288	1459	2015-10-27	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java	106	4	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java	131	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentRestResource.java	55	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java	403	3	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicNode.java	83	2	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicPlatform.java	82	4	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicTopology.java	34	2	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/common/JsonUtil.java	27	2	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/common/Node.java	24	2	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/common/Platform.java	33	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/common/ThreadUtils.java	23	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/common/Topology.java	20	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java	88	2	1503	1459	2017-12-20	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java	110	6	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java	142	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorRestResource.java	62	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java	201	5	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java	351	3	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/fault/FilesUnreadableFaultSpec.java	52	2	1537	1459	2017-11-16	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/fault/Kibosh.java	144	2	1537	1459	2017-11-16	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultController.java	14	2	1537	1459	2017-11-16	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultWorker.java	30	2	1537	1459	2017-11-16	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultController.java	20	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultSpec.java	47	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultWorker.java	53	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultController.java	14	2	1503	1459	2017-12-20	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultSpec.java	38	2	1503	1459	2017-12-20	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultWorker.java	55	2	1503	1459	2017-12-20	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/AgentStatusResponse.java	22	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorShutdownRequest.java	14	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorStatusResponse.java	14	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateTaskRequest.java	22	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateTaskResponse.java	15	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateWorkerRequest.java	22	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateWorkerResponse.java	15	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/Empty.java	23	2	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/ErrorResponse.java	39	2	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java	187	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/Message.java	19	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/RestExceptionMapper.java	49	3	1620	1459	2017-08-25	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/StopTaskRequest.java	14	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/StopTaskResponse.java	15	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/StopWorkerRequest.java	14	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/StopWorkerResponse.java	15	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskDone.java	38	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskPending.java	10	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRunning.java	17	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskState.java	24	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStopping.java	17	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/TasksResponse.java	15	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerDone.java	44	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerReceiving.java	10	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerRunning.java	30	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStarting.java	10	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerState.java	41	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStopping.java	34	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskController.java	14	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskSpec.java	18	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskWorker.java	22	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/task/TaskController.java	6	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/task/TaskSpec.java	42	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/task/TaskWorker.java	9	2	1550	1459	2017-11-03	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/workload/Histogram.java	127	2	1525	1459	2017-11-28	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java	79	3	1525	1459	2017-11-28	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java	248	3	1525	1459	2017-11-28	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java	286	2	1503	1459	2017-12-20	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java	66	2	1503	1459	2017-12-20	2018-02-02
tools/src/main/java/org/apache/kafka/trogdor/workload/Throttle.java	41	2	1525	1459	2017-11-28	2018-02-02