apache / flink-connector-kafkaFile Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary

Number of files: 114
Daily file updates (only one update per file and date counted): 572
First update: 2018-02-12
Latest update: 2023-07-17
Days between first and latest update: 1,981 (283 weeks, estimated 1,415 working days)
Active days (at least one file change): 479
Files without commit history (ignored): 1 (6 lines of code)

Files without history

Data:

Organized per file

File Change History Overall

File Age Distribution Overall

Days since first update

There are 113 files with 12,944 lines of code in files.

109 files that are 366+ days old (12,877 lines of code)
0 files that are 181-365 days old (0 lines of code)
4 files that are 91-180 days old (67 lines of code)
0 files that are 31-90 days old (0 lines of code)
0 files that are 1-30 days old (0 lines of code)

Legend:

366+

181-365

91-180

31-90

1-30

explore: grouped by folders | grouped by age

File Freshness Distribution Overall

Days since last update

There are 113 files with 12,944 lines of code in files.

81 files have been last changed 366+ days ago (7,445 lines of code)
8 files have been last changed 181-365 days ago (725 lines of code)
22 files have been last changed 91-180 days ago (4,664 lines of code)
2 files have been last changed 31-90 days ago (110 lines of code)
0 files have been last changed 1-30 days ago (0 lines of code)

Legend:

366+

181-365

91-180

31-90

1-30

explore: grouped by folders | grouped by freshness

File Change History per File Extension

java, xml, md, txt, properties, yml, json, yaml, gitignore, gitmodules

File Age Distribution per Extension

Days since first update

366+

181-365

91-180

31-90

1-30

File Freshness Distribution per Extension

Days since last update

366+

181-365

91-180

31-90

1-30

File Change History per Logical Decomposition

primary

primary (file age distribution)

Days since first update

366+

181-365

91-180

31-90

1-30

primary (file freshness distribution)

Days since last update

366+

181-365

91-180

31-90

1-30

Oldest Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
FlinkKafkaProducer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	1262	87	2018-10-13	2021-11-04	36	25	yanghua1127@gmail.com	fabianpaul@ververica.com
FlinkKafkaConsumer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	180	12	2018-10-13	2021-09-01	11	11	yanghua1127@gmail.com	bin.huangxb@gmail.com
FlinkKafkaException.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	19	3	2018-10-13	2020-12-28	2	2	yanghua1127@gmail.com	dev@flink.apache.org
FlinkKafkaErrorCode.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	7	-	2018-10-13	2020-12-28	2	2	yanghua1127@gmail.com	dev@flink.apache.org
FlinkKafkaProducer011.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	30	3	2019-02-11	2020-12-28	2	2	piotr.nowojski@gmail.com	dev@flink.apache.org
FlinkKafkaShuffleProducer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle	153	2	2020-05-15	2022-10-05	4	3	yuanmei.work@gmail.com	zakelly.lan@gmail.com
FlinkKafkaShuffle.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle	135	7	2020-05-15	2023-01-29	8	6	yuanmei.work@gmail.com	jrlee.ljr@gmail.com
FlinkKafkaShuffleConsumer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle	63	1	2020-05-15	2020-12-28	4	3	yuanmei.work@gmail.com	dev@flink.apache.org
StreamKafkaShuffleSink.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle	16	2	2020-05-15	2020-12-28	3	2	yuanmei.work@gmail.com	dev@flink.apache.org
KafkaDynamicSource.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	512	21	2020-05-17	2022-02-08	18	12	yuzhao.cyz@gmail.com	francescoguard@gmail.com
KafkaDynamicTableFactory.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	372	7	2020-05-17	2023-05-06	20	14	yuzhao.cyz@gmail.com	loserwang1024@gmail.com
KafkaDynamicSink.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	360	14	2020-05-17	2023-03-12	25	14	yuzhao.cyz@gmail.com	aleksandr.sorokoumov@gmail.com
KafkaSourceEnumerator.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator	451	31	2020-10-09	2023-05-06	14	11	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
KafkaPartitionSplitReader.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader	410	26	2020-10-09	2023-03-23	16	9	jiangjie.qj@alibaba-inc.com	aleksandr.sorokoumov@gmail.com
KafkaSourceBuilder.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source	211	21	2020-10-09	2022-04-05	12	10	jiangjie.qj@alibaba-inc.com	mason.chen@apple.com
KafkaSource.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source	167	13	2020-10-09	2023-05-06	15	11	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
KafkaSourceReader.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader	159	8	2020-10-09	2022-03-25	14	6	jiangjie.qj@alibaba-inc.com	dwysakowicz@apache.org
KafkaSourceEnumStateSerializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator	128	4	2020-10-09	2023-05-06	5	5	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
KafkaPartitionSplit.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split	106	13	2020-10-09	2022-07-09	5	5	jiangjie.qj@alibaba-inc.com	johnson5211.work@gmail.com
SpecifiedOffsetsInitializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer	73	3	2020-10-09	2023-07-11	5	5	jiangjie.qj@alibaba-inc.com	125648852+loserwang1024@use...
KafkaSourceFetcherManager.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher	69	3	2020-10-09	2022-07-24	8	5	jiangjie.qj@alibaba-inc.com	sebastian@ververica.com
KafkaSourceEnumState.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator	59	6	2020-10-09	2023-05-06	5	5	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
OffsetsInitializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer	51	8	2020-10-09	2022-11-25	5	5	jiangjie.qj@alibaba-inc.com	mas.chen@berkeley.edu
KafkaRecordEmitter.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader	49	6	2020-10-09	2022-02-15	4	4	jiangjie.qj@alibaba-inc.com	gejing@gmail.com
PartitionSetSubscriber.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber	46	2	2020-10-09	2021-04-08	3	3	jiangjie.qj@alibaba-inc.com	renqschn@gmail.com
ReaderHandledOffsetsInitializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer	43	3	2020-10-09	2021-09-14	3	3	jiangjie.qj@alibaba-inc.com	renqschn@gmail.com
KafkaPartitionSplitSerializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split	42	2	2020-10-09	2022-02-15	3	3	jiangjie.qj@alibaba-inc.com	gejing@gmail.com
KafkaSourceOptions.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source	40	1	2020-10-09	2023-05-06	8	6	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
TimestampOffsetsInitializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer	37	2	2020-10-09	2023-07-11	4	4	jiangjie.qj@alibaba-inc.com	125648852+loserwang1024@use...
TopicPatternSubscriber.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber	37	1	2020-10-09	2021-04-08	3	3	jiangjie.qj@alibaba-inc.com	renqschn@gmail.com
TopicListSubscriber.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber	33	1	2020-10-09	2021-09-01	4	4	jiangjie.qj@alibaba-inc.com	w.gh123@qq.com
KafkaPartitionSplitState.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split	25	4	2020-10-09	2022-02-15	3	3	jiangjie.qj@alibaba-inc.com	gejing@gmail.com
KafkaSubscriberUtils.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber	25	3	2020-10-09	2022-10-25	4	4	jiangjie.qj@alibaba-inc.com	snuyanzin@gmail.com
NoStoppingOffsetsInitializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer	23	2	2020-10-09	2020-12-28	2	2	jiangjie.qj@alibaba-inc.com	dev@flink.apache.org
KafkaSubscriber.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber	21	3	2020-10-09	2022-04-05	5	5	jiangjie.qj@alibaba-inc.com	mason.chen@apple.com
FlinkKafkaConsumerBase.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	677	29	2020-10-16	2020-12-28	5	5	twalthr@apache.org	dev@flink.apache.org
AbstractFetcher.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	324	11	2020-10-16	2022-04-25	4	4	twalthr@apache.org	dwysakowicz@apache.org
FlinkKafkaInternalProducer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	314	29	2020-10-16	2023-03-23	6	5	twalthr@apache.org	aleksandr.sorokoumov@gmail.com
KafkaConsumerThread.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	310	9	2020-10-16	2022-11-23	4	4	twalthr@apache.org	snuyanzin@gmail.com
FlinkKafkaProducerBase.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	281	14	2020-10-16	2020-12-28	3	3	twalthr@apache.org	dev@flink.apache.org
ClosableBlockingQueue.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	262	19	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaShuffleFetcher.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	211	14	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaFetcher.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	159	11	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
TypeInformationKeyValueSerializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization	115	5	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
AbstractPartitionDiscoverer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	107	8	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
Handover.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	86	5	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaTopicPartition.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	82	10	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaTopicPartitionLeader.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	73	6	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaSerializationSchemaWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	72	8	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaPartitionDiscoverer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	71	6	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org

Files Not Recently Changed (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
FlinkKafkaErrorCode.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	7	-	2018-10-13	2020-12-28	2	2	yanghua1127@gmail.com	dev@flink.apache.org
KafkaCommitCallback.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	7	-	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
OffsetCommitMode.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config	8	-	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaContextAware.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	9	3	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KeyedSerializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization	11	-	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
FlinkKafkaPartitioner.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner	11	1	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaSerializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	11	1	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaTopicPartitionStateSentinel.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	12	1	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaConsumerMetricConstants.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics	14	-	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KeyedDeserializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization	16	1	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
StreamKafkaShuffleSink.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle	16	2	2020-05-15	2020-12-28	3	2	yuanmei.work@gmail.com	dev@flink.apache.org
OffsetCommitModes.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config	17	1	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
FlinkKafkaException.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	19	3	2018-10-13	2020-12-28	2	2	yanghua1127@gmail.com	dev@flink.apache.org
KafkaDeserializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	20	2	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
NoStoppingOffsetsInitializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer	23	2	2020-10-09	2020-12-28	2	2	jiangjie.qj@alibaba-inc.com	dev@flink.apache.org
KeyedSerializationSchemaWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	27	3	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
ExceptionProxy.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	30	3	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
FlinkKafkaProducer011.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	30	3	2019-02-11	2020-12-28	2	2	piotr.nowojski@gmail.com	dev@flink.apache.org
FlinkFixedPartitioner.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner	31	4	2020-10-16	2020-12-28	3	3	twalthr@apache.org	dev@flink.apache.org
KafkaDeserializationSchemaWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	36	6	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaTopicPartitionStateWithWatermarkGenerator.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	45	5	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
TransactionalIdsGenerator.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	48	4	2020-10-16	2020-12-28	3	3	twalthr@apache.org	dev@flink.apache.org
KafkaTopicsDescriptor.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	49	6	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaTopicPartitionState.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	58	14	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
FlinkKafkaShuffleConsumer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle	63	1	2020-05-15	2020-12-28	4	3	yuanmei.work@gmail.com	dev@flink.apache.org
KafkaPartitionDiscoverer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	71	6	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaSerializationSchemaWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	72	8	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaTopicPartitionLeader.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	73	6	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaTopicPartition.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	82	10	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
Handover.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	86	5	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
AbstractPartitionDiscoverer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	107	8	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
TypeInformationKeyValueSerializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization	115	5	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaFetcher.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	159	11	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
DynamicKafkaDeserializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	179	10	2020-10-19	2020-12-28	5	3	twalthr@apache.org	dev@flink.apache.org
KafkaShuffleFetcher.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	211	14	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
ClosableBlockingQueue.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	262	19	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
FlinkKafkaProducerBase.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	281	14	2020-10-16	2020-12-28	3	3	twalthr@apache.org	dev@flink.apache.org
FlinkKafkaConsumerBase.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	677	29	2020-10-16	2020-12-28	5	5	twalthr@apache.org	dev@flink.apache.org
KafkaValueOnlyDeserializationSchemaWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer	26	3	2021-03-03	2021-03-03	1	1	lindong28@gmail.com	lindong28@gmail.com
KafkaDeserializationSchemaWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer	32	3	2021-03-03	2021-03-03	1	1	lindong28@gmail.com	lindong28@gmail.com
TopicPatternSubscriber.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber	37	1	2020-10-09	2021-04-08	3	3	jiangjie.qj@alibaba-inc.com	renqschn@gmail.com
PartitionSetSubscriber.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber	46	2	2020-10-09	2021-04-08	3	3	jiangjie.qj@alibaba-inc.com	renqschn@gmail.com
SourceContextWatermarkOutputAdapter.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	22	4	2020-10-16	2021-07-08	3	3	twalthr@apache.org	arvid@ververica.com
TransactionsToAbortChecker.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	50	2	2021-08-16	2021-08-16	1	1	fabianpaul@ververica.com	fabianpaul@ververica.com
DynamicKafkaRecordSerializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	142	5	2021-08-10	2021-08-16	2	1	fabianpaul@ververica.com	fabianpaul@ververica.com
KafkaCommittableSerializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	34	2	2021-08-16	2021-08-19	2	2	fabianpaul@ververica.com	arvid@ververica.com
TransactionalIdFactory.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	12	1	2021-08-16	2021-08-27	2	2	fabianpaul@ververica.com	arvid@ververica.com
KafkaWriterStateSerializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	30	2	2021-08-16	2021-08-27	2	2	fabianpaul@ververica.com	arvid@ververica.com
KafkaWriterState.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	35	4	2021-08-16	2021-08-27	2	2	fabianpaul@ververica.com	arvid@ververica.com
TransactionAborter.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	58	5	2021-08-27	2021-08-27	1	1	arvid@ververica.com	arvid@ververica.com

Most Recently Created Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
suppressions.xml in tools/maven	6	-
AssignmentStatus.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator	22	2	2023-05-06	2023-05-06	1	1	loserwang1024@gmail.com	loserwang1024@gmail.com
TopicPartitionAndAssignmentStatus.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator	19	3	2023-05-06	2023-05-06	1	1	loserwang1024@gmail.com	loserwang1024@gmail.com
HeaderProvider.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	9	-	2023-03-27	2023-03-27	1	1	alex.gout@shopify.com	alex.gout@shopify.com
TwoPhaseCommittingStatefulSink.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	17	1	2023-03-12	2023-03-12	1	1	aleksandr.sorokoumov@gmail.com	aleksandr.sorokoumov@gmail.com
BoundedMode.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config	10	-	2021-12-02	2021-12-02	1	1	2572805166@qq.com	2572805166@qq.com
OffsetsInitializerValidator.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer	7	-	2021-09-14	2021-09-14	1	1	renqschn@gmail.com	renqschn@gmail.com
TopicSelector.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	6	-	2021-09-14	2021-09-14	1	1	fabianpaul@ververica.com	fabianpaul@ververica.com
TransactionAborter.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	58	5	2021-08-27	2021-08-27	1	1	arvid@ververica.com	arvid@ververica.com
Recyclable.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	25	4	2021-08-27	2021-09-05	2	1	arvid@ververica.com	arvid@ververica.com
MetricUtil.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka	33	3	2021-08-17	2021-10-13	2	2	fabianpaul@ververica.com	flinker@126.com
KafkaWriter.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	370	18	2021-08-16	2023-03-30	21	9	fabianpaul@ververica.com	mas.chen@berkeley.edu
FlinkKafkaInternalProducer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	292	32	2021-08-16	2023-03-23	7	4	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
KafkaCommitter.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	105	3	2021-08-16	2022-07-13	9	4	fabianpaul@ververica.com	root@ip-10-31-1-150.us-west...
KafkaSinkBuilder.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	99	9	2021-08-16	2022-05-09	7	4	fabianpaul@ververica.com	11444089+alpreu@users.norep...
KafkaSink.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	76	7	2021-08-16	2023-03-12	5	3	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
KafkaCommittable.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	70	8	2021-08-16	2021-08-27	3	2	fabianpaul@ververica.com	arvid@ververica.com
TransactionsToAbortChecker.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	50	2	2021-08-16	2021-08-16	1	1	fabianpaul@ververica.com	fabianpaul@ververica.com
DefaultKafkaSinkContext.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	45	3	2021-08-16	2022-07-26	2	2	fabianpaul@ververica.com	chesnay@apache.org
KafkaWriterState.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	35	4	2021-08-16	2021-08-27	2	2	fabianpaul@ververica.com	arvid@ververica.com
KafkaCommittableSerializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	34	2	2021-08-16	2021-08-19	2	2	fabianpaul@ververica.com	arvid@ververica.com
KafkaWriterStateSerializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	30	2	2021-08-16	2021-08-27	2	2	fabianpaul@ververica.com	arvid@ververica.com
TransactionalIdFactory.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	12	1	2021-08-16	2021-08-27	2	2	fabianpaul@ververica.com	arvid@ververica.com
ReducingUpsertWriter.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	148	13	2021-08-12	2023-03-27	8	4	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
ReducingUpsertSink.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	71	3	2021-08-12	2023-03-12	6	3	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
KafkaRecordSerializationSchemaBuilder.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	194	17	2021-08-11	2023-04-12	7	5	fabianpaul@ververica.com	tzulitai@apache.org
KafkaSerializerWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	60	1	2021-08-11	2022-01-19	2	2	fabianpaul@ververica.com	gejing@gmail.com
KafkaRecordSerializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	24	2	2021-08-11	2022-10-31	4	3	fabianpaul@ververica.com	salcantaraphd@gmail.com
DynamicKafkaRecordSerializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	142	5	2021-08-10	2021-08-16	2	1	fabianpaul@ververica.com	fabianpaul@ververica.com
KafkaConnectorOptionsUtil.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	538	24	2021-06-30	2023-04-05	8	7	ingo.buerk@tngtech.com	tzulitai@apache.org
KafkaConnectorOptions.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	276	5	2021-06-30	2023-05-06	5	4	ingo.buerk@tngtech.com	loserwang1024@gmail.com
KafkaSourceReaderMetrics.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics	194	13	2021-06-08	2022-02-15	7	3	renqschn@gmail.com	gejing@gmail.com
SinkBufferFlushMode.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	48	6	2021-03-30	2021-10-21	2	2	1059623455@qq.com	fabianpaul@ververica.com
KafkaValueOnlyDeserializerWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer	71	3	2021-03-03	2022-01-19	3	3	lindong28@gmail.com	gejing@gmail.com
KafkaRecordDeserializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer	33	4	2021-03-03	2022-02-15	4	3	lindong28@gmail.com	gejing@gmail.com
KafkaDeserializationSchemaWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer	32	3	2021-03-03	2021-03-03	1	1	lindong28@gmail.com	lindong28@gmail.com
KafkaValueOnlyDeserializationSchemaWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer	26	3	2021-03-03	2021-03-03	1	1	lindong28@gmail.com	lindong28@gmail.com
UpsertKafkaDynamicTableFactory.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	331	20	2020-11-04	2023-04-05	13	10	1059623455@qq.com	tzulitai@apache.org
DynamicKafkaDeserializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	179	10	2020-10-19	2020-12-28	5	3	twalthr@apache.org	dev@flink.apache.org
FlinkKafkaConsumerBase.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	677	29	2020-10-16	2020-12-28	5	5	twalthr@apache.org	dev@flink.apache.org
AbstractFetcher.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	324	11	2020-10-16	2022-04-25	4	4	twalthr@apache.org	dwysakowicz@apache.org
FlinkKafkaInternalProducer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	314	29	2020-10-16	2023-03-23	6	5	twalthr@apache.org	aleksandr.sorokoumov@gmail.com
KafkaConsumerThread.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	310	9	2020-10-16	2022-11-23	4	4	twalthr@apache.org	snuyanzin@gmail.com
FlinkKafkaProducerBase.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka	281	14	2020-10-16	2020-12-28	3	3	twalthr@apache.org	dev@flink.apache.org
ClosableBlockingQueue.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	262	19	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaShuffleFetcher.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	211	14	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
KafkaFetcher.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	159	11	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
TypeInformationKeyValueSerializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization	115	5	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
AbstractPartitionDiscoverer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	107	8	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org
Handover.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	86	5	2020-10-16	2020-12-28	2	2	twalthr@apache.org	dev@flink.apache.org

Most Recently Changed Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
suppressions.xml in tools/maven	6	-
SpecifiedOffsetsInitializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer	73	3	2020-10-09	2023-07-11	5	5	jiangjie.qj@alibaba-inc.com	125648852+loserwang1024@use...
TimestampOffsetsInitializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer	37	2	2020-10-09	2023-07-11	4	4	jiangjie.qj@alibaba-inc.com	125648852+loserwang1024@use...
KafkaSourceEnumerator.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator	451	31	2020-10-09	2023-05-06	14	11	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
KafkaDynamicTableFactory.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	372	7	2020-05-17	2023-05-06	20	14	yuzhao.cyz@gmail.com	loserwang1024@gmail.com
KafkaConnectorOptions.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	276	5	2021-06-30	2023-05-06	5	4	ingo.buerk@tngtech.com	loserwang1024@gmail.com
KafkaSource.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source	167	13	2020-10-09	2023-05-06	15	11	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
KafkaSourceEnumStateSerializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator	128	4	2020-10-09	2023-05-06	5	5	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
KafkaSourceEnumState.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator	59	6	2020-10-09	2023-05-06	5	5	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
KafkaSourceOptions.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source	40	1	2020-10-09	2023-05-06	8	6	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
AssignmentStatus.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator	22	2	2023-05-06	2023-05-06	1	1	loserwang1024@gmail.com	loserwang1024@gmail.com
TopicPartitionAndAssignmentStatus.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator	19	3	2023-05-06	2023-05-06	1	1	loserwang1024@gmail.com	loserwang1024@gmail.com
KafkaRecordSerializationSchemaBuilder.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	194	17	2021-08-11	2023-04-12	7	5	fabianpaul@ververica.com	tzulitai@apache.org
KafkaConnectorOptionsUtil.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	538	24	2021-06-30	2023-04-05	8	7	ingo.buerk@tngtech.com	tzulitai@apache.org
UpsertKafkaDynamicTableFactory.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	331	20	2020-11-04	2023-04-05	13	10	1059623455@qq.com	tzulitai@apache.org
KafkaWriter.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	370	18	2021-08-16	2023-03-30	21	9	fabianpaul@ververica.com	mas.chen@berkeley.edu
ReducingUpsertWriter.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	148	13	2021-08-12	2023-03-27	8	4	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
HeaderProvider.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	9	-	2023-03-27	2023-03-27	1	1	alex.gout@shopify.com	alex.gout@shopify.com
KafkaPartitionSplitReader.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader	410	26	2020-10-09	2023-03-23	16	9	jiangjie.qj@alibaba-inc.com	aleksandr.sorokoumov@gmail.com
FlinkKafkaInternalProducer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	314	29	2020-10-16	2023-03-23	6	5	twalthr@apache.org	aleksandr.sorokoumov@gmail.com
FlinkKafkaInternalProducer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	292	32	2021-08-16	2023-03-23	7	4	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
KafkaDynamicSink.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	360	14	2020-05-17	2023-03-12	25	14	yuzhao.cyz@gmail.com	aleksandr.sorokoumov@gmail.com
KafkaSink.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	76	7	2021-08-16	2023-03-12	5	3	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
ReducingUpsertSink.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	71	3	2021-08-12	2023-03-12	6	3	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
TwoPhaseCommittingStatefulSink.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	17	1	2023-03-12	2023-03-12	1	1	aleksandr.sorokoumov@gmail.com	aleksandr.sorokoumov@gmail.com
FlinkKafkaShuffle.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle	135	7	2020-05-15	2023-01-29	8	6	yuanmei.work@gmail.com	jrlee.ljr@gmail.com
OffsetsInitializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer	51	8	2020-10-09	2022-11-25	5	5	jiangjie.qj@alibaba-inc.com	mas.chen@berkeley.edu
KafkaConsumerThread.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	310	9	2020-10-16	2022-11-23	4	4	twalthr@apache.org	snuyanzin@gmail.com
KafkaRecordSerializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	24	2	2021-08-11	2022-10-31	4	3	fabianpaul@ververica.com	salcantaraphd@gmail.com
KafkaSubscriberUtils.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber	25	3	2020-10-09	2022-10-25	4	4	jiangjie.qj@alibaba-inc.com	snuyanzin@gmail.com
FlinkKafkaShuffleProducer.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle	153	2	2020-05-15	2022-10-05	4	3	yuanmei.work@gmail.com	zakelly.lan@gmail.com
KafkaTopicPartitionAssigner.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	12	2	2020-10-16	2022-10-05	3	3	twalthr@apache.org	zakelly.lan@gmail.com
KafkaMetricWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics	15	2	2020-10-16	2022-08-17	4	4	twalthr@apache.org	chesnay@apache.org
JSONKeyValueDeserializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization	49	5	2020-10-16	2022-07-28	3	3	twalthr@apache.org	chesnay@apache.org
DefaultKafkaSinkContext.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	45	3	2021-08-16	2022-07-26	2	2	fabianpaul@ververica.com	chesnay@apache.org
KafkaSourceFetcherManager.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher	69	3	2020-10-09	2022-07-24	8	5	jiangjie.qj@alibaba-inc.com	sebastian@ververica.com
KafkaCommitter.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	105	3	2021-08-16	2022-07-13	9	4	fabianpaul@ververica.com	root@ip-10-31-1-150.us-west...
KafkaPartitionSplit.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split	106	13	2020-10-09	2022-07-09	5	5	jiangjie.qj@alibaba-inc.com	johnson5211.work@gmail.com
KafkaSinkBuilder.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink	99	9	2021-08-16	2022-05-09	7	4	fabianpaul@ververica.com	11444089+alpreu@users.norep...
KafkaMetricMutableWrapper.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics	19	3	2020-10-16	2022-05-05	4	3	twalthr@apache.org	fabianpaul@ververica.com
AbstractFetcher.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals	324	11	2020-10-16	2022-04-25	4	4	twalthr@apache.org	dwysakowicz@apache.org
KafkaSourceBuilder.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source	211	21	2020-10-09	2022-04-05	12	10	jiangjie.qj@alibaba-inc.com	mason.chen@apple.com
KafkaSubscriber.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber	21	3	2020-10-09	2022-04-05	5	5	jiangjie.qj@alibaba-inc.com	mason.chen@apple.com
KafkaSourceReader.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader	159	8	2020-10-09	2022-03-25	14	6	jiangjie.qj@alibaba-inc.com	dwysakowicz@apache.org
KafkaSourceReaderMetrics.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics	194	13	2021-06-08	2022-02-15	7	3	renqschn@gmail.com	gejing@gmail.com
KafkaRecordEmitter.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader	49	6	2020-10-09	2022-02-15	4	4	jiangjie.qj@alibaba-inc.com	gejing@gmail.com
KafkaPartitionSplitSerializer.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split	42	2	2020-10-09	2022-02-15	3	3	jiangjie.qj@alibaba-inc.com	gejing@gmail.com
KafkaRecordDeserializationSchema.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer	33	4	2021-03-03	2022-02-15	4	3	lindong28@gmail.com	gejing@gmail.com
KafkaPartitionSplitState.java in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split	25	4	2020-10-09	2022-02-15	3	3	jiangjie.qj@alibaba-inc.com	gejing@gmail.com
KafkaDynamicSource.java in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table	512	21	2020-05-17	2022-02-08	18	12	yuzhao.cyz@gmail.com	francescoguard@gmail.com