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/connector/kafka/lineage/DefaultKafkaDatasetFacet.java	49	1	175	175	1	1	2024-11-14	2024-11-14	leszczynski.pawel@gmail.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetIdentifierProvider.java	7	1	175	175	1	1	2024-11-14	2024-11-14	leszczynski.pawel@gmail.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/TypeDatasetFacetProvider.java	7	1	175	175	1	1	2024-11-14	2024-11-14	leszczynski.pawel@gmail.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetFacetProvider.java	7	1	175	175	1	1	2024-11-14	2024-11-14	leszczynski.pawel@gmail.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultTypeDatasetFacet.java	33	1	175	175	1	1	2024-11-14	2024-11-14	leszczynski.pawel@gmail.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetIdentifier.java	19	1	175	175	1	1	2024-11-14	2024-11-14	leszczynski.pawel@gmail.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java	46	1	175	175	1	1	2024-11-14	2024-11-14	leszczynski.pawel@gmail.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java	82	1	175	175	1	1	2024-11-14	2024-11-14	leszczynski.pawel@gmail.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetFacet.java	10	1	175	175	1	1	2024-11-14	2024-11-14	leszczynski.pawel@gmail.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/TypeDatasetFacet.java	8	1	175	175	1	1	2024-11-14	2024-11-14	leszczynski.pawel@gmail.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/MetricUtil.java	33	2	1360	1303	2	2	2021-08-17	2021-10-13	fabianpaul@ververica.com	flinker@126.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util/AdminUtils.java	105	1	38	38	1	1	2025-03-31	2025-03-31	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util/JacksonMapperFactory.java	25	1	577	577	1	1	2023-10-09	2023-10-09	mvisser@confluent.io	mvisser@confluent.io
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java	40	2	638	28	2	2	2023-08-09	2025-04-10	mas.chen@berkeley.edu	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/SingleClusterTopicMetadataService.java	72	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java	46	2	638	28	2	2	2023-08-09	2025-04-10	mas.chen@berkeley.edu	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaMetadataService.java	12	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics/KafkaClusterMetricGroupManager.java	49	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics/KafkaClusterMetricGroup.java	92	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSource.java	114	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceOptions.java	31	2	638	469	2	1	2023-08-09	2024-01-25	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumStateSerializer.java	135	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java	408	6	638	28	6	5	2023-08-09	2025-04-10	mas.chen@berkeley.edu	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/StoppableKafkaEnumContextProxy.java	196	2	638	477	2	1	2023-08-09	2024-01-17	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/KafkaStreamSubscriber.java	10	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/KafkaStreamSetSubscriber.java	17	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/StreamPatternSubscriber.java	27	2	638	28	2	2	2023-08-09	2025-04-10	mas.chen@berkeley.edu	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumState.java	29	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java	56	2	638	28	2	2	2023-08-09	2025-04-10	mas.chen@berkeley.edu	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplitSerializer.java	46	2	638	28	2	2	2023-08-09	2025-04-10	mas.chen@berkeley.edu	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/GetMetadataUpdateEvent.java	5	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/KafkaPartitionSplitReaderWrapper.java	65	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReader.java	420	4	638	28	5	2	2023-08-09	2025-04-10	mas.chen@berkeley.edu	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java	36	2	638	28	2	2	2023-08-09	2025-04-10	mas.chen@berkeley.edu	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceBuilder.java	197	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittableSerializer.java	34	2	1361	1358	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/KafkaSinkBuilder.java	113	10	1361	70	11	7	2021-08-16	2025-02-27	fabianpaul@ververica.com	125648852+loserwang1024@users.noreply.github.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/DefaultKafkaSinkContext.java	45	2	1361	1017	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/ExactlyOnceKafkaWriter.java	291	8	90	30	9	2	2025-02-07	2025-04-08	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java	60	2	1366	1205	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	85	3	1361	38	3	3	2021-08-16	2025-03-31	fabianpaul@ververica.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProvider.java	9	1	773	773	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/KafkaRecordSerializationSchemaBuilder.java	274	12	1366	28	12	10	2021-08-11	2025-04-10	fabianpaul@ververica.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java	163	13	1361	35	15	5	2021-08-16	2025-04-03	fabianpaul@ververica.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TopicSelector.java	6	1	1332	1332	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/KafkaCommittable.java	73	4	1361	90	6	3	2021-08-16	2025-02-07	fabianpaul@ververica.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaPartitioner.java	8	1	223	223	1	1	2024-09-27	2024-09-27	aheise@users.noreply.github.com	aheise@users.noreply.github.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java	157	12	1361	43	13	6	2021-08-16	2025-03-26	fabianpaul@ververica.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java	260	27	1361	35	32	12	2021-08-16	2025-04-03	fabianpaul@ververica.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializer.java	64	3	1361	38	3	3	2021-08-16	2025-03-31	fabianpaul@ververica.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionNamingStrategy.java	26	1	89	89	2	1	2025-02-08	2025-02-08	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java	24	5	1366	175	5	4	2021-08-11	2024-11-14	fabianpaul@ververica.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyContextImpl.java	59	1	89	89	2	1	2025-02-08	2025-02-08	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionOwnership.java	96	1	38	38	1	1	2025-03-31	2025-03-31	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelFactory.java	60	1	87	87	1	1	2025-02-10	2025-02-10	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionFinished.java	49	1	43	43	1	1	2025-03-26	2025-03-26	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPool.java	11	4	89	38	4	1	2025-02-08	2025-03-31	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyImpl.java	63	2	89	38	3	1	2025-02-08	2025-03-31	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyContextImpl.java	87	2	89	38	2	1	2025-02-08	2025-03-31	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java	294	5	90	30	7	1	2025-02-07	2025-04-08	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ReadableBackchannel.java	8	2	89	87	2	1	2025-02-08	2025-02-10	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPoolImpl.java	196	5	90	38	6	1	2025-02-07	2025-03-31	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyImpl.java	90	2	89	38	2	1	2025-02-08	2025-03-31	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImpl.java	79	1	87	87	1	1	2025-02-10	2025-02-10	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/WritableBackchannel.java	6	2	89	87	2	1	2025-02-08	2025-02-10	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/Backchannel.java	9	2	89	87	2	1	2025-02-08	2025-02-10	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java	45	1	87	87	1	1	2025-02-10	2025-02-10	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionalIdFactory.java	25	3	90	38	3	1	2025-02-07	2025-03-31	arvid@apache.org	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java	20	2	788	44	2	2	2023-03-12	2025-03-25	aleksandr.sorokoumov@gmail.com	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java	194	7	1430	1178	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/KafkaPropertiesUtil.java	20	1	638	638	1	1	2023-08-09	2023-08-09	mas.chen@berkeley.edu	mas.chen@berkeley.edu
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java	213	17	1672	175	19	13	2020-10-09	2024-11-14	jiangjie.qj@alibaba-inc.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java	59	7	1672	231	7	7	2020-10-09	2024-09-19	jiangjie.qj@alibaba-inc.com	598457447@qq.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/TopicPartitionAndAssignmentStatus.java	19	1	733	733	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/KafkaSourceEnumerator.java	451	15	1672	231	18	12	2020-10-09	2024-09-19	jiangjie.qj@alibaba-inc.com	598457447@qq.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java	73	5	1672	667	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	1672	667	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/OffsetsInitializer.java	50	6	1672	590	6	6	2020-10-09	2023-09-26	jiangjie.qj@alibaba-inc.com	tanjialiang@52tt.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializerValidator.java	7	1	1332	1332	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/NoStoppingOffsetsInitializer.java	23	2	1672	1592	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/ReaderHandledOffsetsInitializer.java	43	4	1672	590	4	4	2020-10-09	2023-09-26	jiangjie.qj@alibaba-inc.com	tanjialiang@52tt.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/LatestOffsetsInitializer.java	18	1	590	590	1	1	2023-09-26	2023-09-26	tanjialiang@52tt.com	tanjialiang@52tt.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java	128	6	1672	231	6	6	2020-10-09	2024-09-19	jiangjie.qj@alibaba-inc.com	598457447@qq.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java	22	1	733	733	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/PartitionSetSubscriber.java	58	5	1672	38	5	5	2020-10-09	2025-03-31	jiangjie.qj@alibaba-inc.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java	21	6	1672	175	6	6	2020-10-09	2024-11-14	jiangjie.qj@alibaba-inc.com	leszczynski.pawel@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java	42	6	1672	38	6	6	2020-10-09	2025-03-31	jiangjie.qj@alibaba-inc.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java	40	6	1672	38	6	6	2020-10-09	2025-03-31	jiangjie.qj@alibaba-inc.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitState.java	25	3	1672	1178	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/KafkaPartitionSplit.java	106	7	1672	563	7	7	2020-10-09	2023-10-23	jiangjie.qj@alibaba-inc.com	tzulitai@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitSerializer.java	42	3	1672	1178	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/reader/deserializer/KafkaValueOnlyDeserializerWrapper.java	71	3	1527	1205	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/deserializer/KafkaValueOnlyDeserializationSchemaWrapper.java	26	1	1527	1527	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/KafkaRecordDeserializationSchema.java	28	6	1527	44	7	5	2021-03-03	2025-03-25	lindong28@gmail.com	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java	69	9	1672	44	9	6	2020-10-09	2025-03-25	jiangjie.qj@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaRecordEmitter.java	49	4	1672	1178	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/reader/KafkaPartitionSplitReader.java	425	19	1672	63	19	12	2020-10-09	2025-03-06	jiangjie.qj@alibaba-inc.com	trompa@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java	158	17	1672	44	17	9	2020-10-09	2025-03-25	jiangjie.qj@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java	257	15	1672	156	17	13	2020-10-09	2024-12-03	jiangjie.qj@alibaba-inc.com	liuml07@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java	40	8	1672	733	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/streaming/util/serialization/JSONKeyValueDeserializationSchema.java	49	6	1665	44	7	6	2020-10-16	2025-03-25	twalthr@apache.org	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java	32	5	1665	156	5	5	2020-10-16	2024-12-03	twalthr@apache.org	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java	293	8	1408	78	8	7	2021-06-30	2025-02-19	ingo.buerk@tngtech.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java	391	29	1817	44	30	18	2020-05-17	2025-03-25	yuzhao.cyz@gmail.com	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java	48	2	1500	1295	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/KafkaConnectorOptionsUtil.java	519	12	1408	44	12	10	2021-06-30	2025-03-25	ingo.buerk@tngtech.com	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java	389	25	1817	78	28	19	2020-05-17	2025-02-19	yuzhao.cyz@gmail.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java	173	7	1662	44	7	5	2020-10-19	2025-03-25	twalthr@apache.org	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java	71	8	1365	44	8	5	2021-08-12	2025-03-25	fabianpaul@ververica.com	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java	517	21	1817	44	22	14	2020-05-17	2025-03-25	yuzhao.cyz@gmail.com	lvyanquan.lyq@alibaba-inc.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java	332	16	1646	78	16	13	2020-11-04	2025-02-19	1059623455@qq.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java	246	7	1367	28	7	4	2021-08-10	2025-04-10	fabianpaul@ververica.com	arvid@apache.org
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java	148	8	1365	774	8	4	2021-08-12	2023-03-26	fabianpaul@ververica.com	aleksandr.sorokoumov@gmail.com
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/StartupMode.java	18	4	1665	1346	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	1253	1253	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/internals/metrics/KafkaMetricMutableWrapper.java	19	4	1665	1099	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/KafkaTopicPartitionStateSentinel.java	12	2	1665	1592	2	2	2020-10-16	2020-12-28	twalthr@apache.org	dev@flink.apache.org
tools/maven/suppressions.xml	9	1	28	28	1	1	2025-04-10	2025-04-10	arvid@apache.org	arvid@apache.org
flink-python/MANIFEST.in	19	1	514	514	1	1	2023-12-11	2023-12-11	peter.vary.apache@gmail.com	peter.vary.apache@gmail.com
flink-python/pyflink/datastream/connectors/kafka.py	276	3	514	38	3	3	2023-12-11	2025-03-31	peter.vary.apache@gmail.com	lvyanquan.lyq@alibaba-inc.com
flink-python/pyflink/pyflink_gateway_server.py	204	1	514	514	1	1	2023-12-11	2023-12-11	peter.vary.apache@gmail.com	peter.vary.apache@gmail.com
flink-python/setup.py	95	2	514	70	2	2	2023-12-11	2025-02-27	peter.vary.apache@gmail.com	125648852+loserwang1024@users.noreply.github.com