path	# lines of code	# active days	days since first update	days since last update	# commits	# contributors	first updated	last updated	first contributor	last contributor
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java	1262	36	1764	646	38	25	2018-10-13	2021-11-04	yanghua1127@gmail.com	fabianpaul@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java	153	4	1184	311	4	3	2020-05-15	2022-10-05	yuanmei.work@gmail.com	zakelly.lan@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java	63	4	1184	957	4	3	2020-05-15	2020-12-28	yuanmei.work@gmail.com	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java	135	8	1184	195	8	6	2020-05-15	2023-01-29	yuanmei.work@gmail.com	jrlee.ljr@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/StreamKafkaShuffleSink.java	16	3	1184	957	3	2	2020-05-15	2020-12-28	yuanmei.work@gmail.com	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java	180	11	1764	710	12	11	2018-10-13	2021-09-01	yanghua1127@gmail.com	bin.huangxb@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializationSchema.java	11	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/OffsetCommitModes.java	17	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/OffsetCommitMode.java	8	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/StartupMode.java	18	4	1030	711	4	4	2020-10-16	2021-08-31	twalthr@apache.org	xbjtdcq@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/BoundedMode.java	10	1	618	618	1	1	2021-12-02	2021-12-02	2572805166@qq.com	2572805166@qq.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkKafkaPartitioner.java	11	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java	31	3	1030	957	3	3	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java	30	2	1643	957	2	2	2019-02-11	2020-12-28	piotr.nowojski@gmail.com	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java	677	5	1030	957	5	5	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java	281	3	1030	957	3	3	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionLeader.java	73	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaSerializationSchemaWrapper.java	72	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaConsumerMetricConstants.java	14	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricWrapper.java	15	4	1030	360	4	4	2020-10-16	2022-08-17	twalthr@apache.org	chesnay@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricMutableWrapper.java	19	4	1030	464	4	3	2020-10-16	2022-05-05	twalthr@apache.org	fabianpaul@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java	82	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Handover.java	86	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java	107	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaShuffleFetcher.java	211	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaCommitCallback.java	7	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionAssigner.java	12	3	1030	311	3	3	2020-10-16	2022-10-05	twalthr@apache.org	zakelly.lan@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java	324	4	1030	474	4	4	2020-10-16	2022-04-25	twalthr@apache.org	dwysakowicz@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaDeserializationSchemaWrapper.java	36	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionState.java	58	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateWithWatermarkGenerator.java	45	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/TransactionalIdsGenerator.java	48	3	1030	957	3	3	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateSentinel.java	12	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaFetcher.java	159	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ExceptionProxy.java	30	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KeyedSerializationSchemaWrapper.java	27	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java	262	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SourceContextWatermarkOutputAdapter.java	22	3	1030	765	3	3	2020-10-16	2021-07-08	twalthr@apache.org	arvid@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java	314	6	1030	142	6	5	2020-10-16	2023-03-23	twalthr@apache.org	aleksandr.sorokoumov@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicsDescriptor.java	49	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaPartitionDiscoverer.java	71	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaConsumerThread.java	310	4	1030	262	4	4	2020-10-16	2022-11-23	twalthr@apache.org	snuyanzin@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaErrorCode.java	7	2	1764	957	2	2	2018-10-13	2020-12-28	yanghua1127@gmail.com	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java	360	25	1182	153	26	14	2020-05-17	2023-03-12	yuzhao.cyz@gmail.com	aleksandr.sorokoumov@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java	142	2	732	726	2	1	2021-08-10	2021-08-16	fabianpaul@ververica.com	fabianpaul@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java	276	5	773	98	5	4	2021-06-30	2023-05-06	ingo.buerk@tngtech.com	loserwang1024@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java	71	6	730	153	6	3	2021-08-12	2023-03-12	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java	48	2	865	660	2	2	2021-03-30	2021-10-21	1059623455@qq.com	fabianpaul@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java	512	18	1182	550	19	12	2020-05-17	2022-02-08	yuzhao.cyz@gmail.com	francescoguard@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java	538	8	773	129	8	7	2021-06-30	2023-04-05	ingo.buerk@tngtech.com	tzulitai@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java	148	8	730	138	8	4	2021-08-12	2023-03-27	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java	179	5	1027	957	5	3	2020-10-19	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java	372	20	1182	98	23	14	2020-05-17	2023-05-06	yuzhao.cyz@gmail.com	loserwang1024@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java	331	13	1011	129	13	10	2020-11-04	2023-04-05	1059623455@qq.com	tzulitai@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaException.java	19	2	1764	957	2	2	2018-10-13	2020-12-28	yanghua1127@gmail.com	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaContextAware.java	9	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaDeserializationSchema.java	20	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java	49	3	1030	380	4	3	2020-10-16	2022-07-28	twalthr@apache.org	chesnay@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationKeyValueSerializationSchema.java	115	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/KeyedSerializationSchema.java	11	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/KeyedDeserializationSchema.java	16	2	1030	957	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchema.java	33	4	892	543	5	3	2021-03-03	2022-02-15	lindong28@gmail.com	gejing@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaDeserializationSchemaWrapper.java	32	1	892	892	1	1	2021-03-03	2021-03-03	lindong28@gmail.com	lindong28@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializationSchemaWrapper.java	26	1	892	892	1	1	2021-03-03	2021-03-03	lindong28@gmail.com	lindong28@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializerWrapper.java	71	3	892	570	3	3	2021-03-03	2022-01-19	lindong28@gmail.com	gejing@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java	69	8	1037	384	8	5	2020-10-09	2022-07-24	jiangjie.qj@alibaba-inc.com	sebastian@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java	410	16	1037	142	16	9	2020-10-09	2023-03-23	jiangjie.qj@alibaba-inc.com	aleksandr.sorokoumov@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java	159	14	1037	505	14	6	2020-10-09	2022-03-25	jiangjie.qj@alibaba-inc.com	dwysakowicz@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaRecordEmitter.java	49	4	1037	543	4	4	2020-10-09	2022-02-15	jiangjie.qj@alibaba-inc.com	gejing@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplit.java	106	5	1037	399	5	5	2020-10-09	2022-07-09	jiangjie.qj@alibaba-inc.com	johnson5211.work@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitState.java	25	3	1037	543	3	3	2020-10-09	2022-02-15	jiangjie.qj@alibaba-inc.com	gejing@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitSerializer.java	42	3	1037	543	3	3	2020-10-09	2022-02-15	jiangjie.qj@alibaba-inc.com	gejing@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java	194	7	795	543	7	3	2021-06-08	2022-02-15	renqschn@gmail.com	gejing@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java	167	15	1037	98	17	11	2020-10-09	2023-05-06	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java	40	8	1037	98	8	6	2020-10-09	2023-05-06	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java	211	12	1037	494	14	10	2020-10-09	2022-04-05	jiangjie.qj@alibaba-inc.com	mason.chen@apple.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java	128	5	1037	98	5	5	2020-10-09	2023-05-06	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/ReaderHandledOffsetsInitializer.java	43	3	1037	697	3	3	2020-10-09	2021-09-14	jiangjie.qj@alibaba-inc.com	renqschn@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializerValidator.java	7	1	697	697	1	1	2021-09-14	2021-09-14	renqschn@gmail.com	renqschn@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java	73	5	1037	32	5	5	2020-10-09	2023-07-11	jiangjie.qj@alibaba-inc.com	125648852+loserwang1024@users.noreply.github.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java	37	4	1037	32	4	4	2020-10-09	2023-07-11	jiangjie.qj@alibaba-inc.com	125648852+loserwang1024@users.noreply.github.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/NoStoppingOffsetsInitializer.java	23	2	1037	957	2	2	2020-10-09	2020-12-28	jiangjie.qj@alibaba-inc.com	dev@flink.apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java	51	5	1037	260	5	5	2020-10-09	2022-11-25	jiangjie.qj@alibaba-inc.com	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java	59	5	1037	98	5	5	2020-10-09	2023-05-06	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/TopicPartitionAndAssignmentStatus.java	19	1	98	98	1	1	2023-05-06	2023-05-06	loserwang1024@gmail.com	loserwang1024@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java	22	1	98	98	1	1	2023-05-06	2023-05-06	loserwang1024@gmail.com	loserwang1024@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java	37	3	1037	856	3	3	2020-10-09	2021-04-08	jiangjie.qj@alibaba-inc.com	renqschn@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java	25	4	1037	291	4	4	2020-10-09	2022-10-25	jiangjie.qj@alibaba-inc.com	snuyanzin@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java	33	4	1037	710	4	4	2020-10-09	2021-09-01	jiangjie.qj@alibaba-inc.com	w.gh123@qq.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/PartitionSetSubscriber.java	46	3	1037	856	3	3	2020-10-09	2021-04-08	jiangjie.qj@alibaba-inc.com	renqschn@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java	21	5	1037	494	5	5	2020-10-09	2022-04-05	jiangjie.qj@alibaba-inc.com	mason.chen@apple.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java	451	14	1037	98	17	11	2020-10-09	2023-05-06	jiangjie.qj@alibaba-inc.com	loserwang1024@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TopicSelector.java	6	1	697	697	1	1	2021-09-14	2021-09-14	fabianpaul@ververica.com	fabianpaul@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionAborter.java	58	1	715	715	1	1	2021-08-27	2021-08-27	arvid@ververica.com	arvid@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializer.java	30	2	726	715	2	2	2021-08-16	2021-08-27	fabianpaul@ververica.com	arvid@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java	60	2	731	570	2	2	2021-08-11	2022-01-19	fabianpaul@ververica.com	gejing@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java	35	2	726	715	2	2	2021-08-16	2021-08-27	fabianpaul@ververica.com	arvid@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/DefaultKafkaSinkContext.java	45	2	726	382	2	2	2021-08-16	2022-07-26	fabianpaul@ververica.com	chesnay@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProvider.java	9	1	138	138	1	1	2023-03-27	2023-03-27	alex.gout@shopify.com	alex.gout@shopify.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java	17	1	153	153	1	1	2023-03-12	2023-03-12	aleksandr.sorokoumov@gmail.com	aleksandr.sorokoumov@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java	24	4	731	285	4	3	2021-08-11	2022-10-31	fabianpaul@ververica.com	salcantaraphd@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java	370	21	726	135	26	9	2021-08-16	2023-03-30	fabianpaul@ververica.com	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java	99	7	726	460	7	4	2021-08-16	2022-05-09	fabianpaul@ververica.com	11444089+alpreu@users.noreply.github.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionsToAbortChecker.java	50	1	726	726	1	1	2021-08-16	2021-08-16	fabianpaul@ververica.com	fabianpaul@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java	292	7	726	142	11	4	2021-08-16	2023-03-23	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java	70	3	726	715	4	2	2021-08-16	2021-08-27	fabianpaul@ververica.com	arvid@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java	76	5	726	153	5	3	2021-08-16	2023-03-12	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittableSerializer.java	34	2	726	723	2	2	2021-08-16	2021-08-19	fabianpaul@ververica.com	arvid@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java	194	7	731	122	7	5	2021-08-11	2023-04-12	fabianpaul@ververica.com	tzulitai@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/Recyclable.java	25	2	715	706	2	1	2021-08-27	2021-09-05	arvid@ververica.com	arvid@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java	105	9	726	395	10	4	2021-08-16	2022-07-13	fabianpaul@ververica.com	root@ip-10-31-1-150.us-west-2.compute.internal
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionalIdFactory.java	12	2	726	715	2	2	2021-08-16	2021-08-27	fabianpaul@ververica.com	arvid@ververica.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/MetricUtil.java	33	2	725	668	2	2	2021-08-17	2021-10-13	fabianpaul@ververica.com	flinker@126.com