apache / flink-connector-kafka
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 122 files with 12,107 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 4 files changed 21-50 times (1,557 lines of code)
    • 30 files changed 6-20 times (5,518 lines of code)
    • 88 files changed 1-5 times (5,032 lines of code)
0% | 0% | 12% | 45% | 41%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 122 files with 12,107 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 9 files changed by 11-25 contributors (3,235 lines of code)
    • 16 files changed by 6-10 contributors (2,118 lines of code)
    • 41 files changed by 2-5 contributors (3,752 lines of code)
    • 56 files changed by 1 contributor (3,002 lines of code)
0% | 26% | 17% | 30% | 24%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, md, yaml, txt, properties, py, sh, editorconfig, in, ini, gitignore, gitmodules, cmd
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 13% | 47% | 38%
py0% | 0% | 0% | 0% | 100%
in0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
flink-connector-kafka0% | 0% | 13% | 47% | 38%
flink-python0% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KafkaDynamicSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 391 15 2020-05-17 2025-03-25 29 18 yuzhao.cyz@gmail.com lvyanquan.lyq@alibaba-inc.com
KafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 260 15 2021-08-16 2025-04-03 27 12 fabianpaul@ververica.com arvid@apache.org
KafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 389 7 2020-05-17 2025-02-19 25 19 yuzhao.cyz@gmail.com arvid@apache.org
KafkaDynamicSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 517 21 2020-05-17 2025-03-25 21 14 yuzhao.cyz@gmail.com lvyanquan.lyq@alibaba-inc.com
KafkaPartitionSplitReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 425 29 2020-10-09 2025-03-06 19 12 jiangjie.qj@alibaba-inc.com trompa@gmail.com
KafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 158 8 2020-10-09 2025-03-25 17 9 jiangjie.qj@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com
KafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 213 14 2020-10-09 2024-11-14 17 13 jiangjie.qj@alibaba-inc.com leszczynski.pawel@gmail.com
UpsertKafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 332 19 2020-11-04 2025-02-19 16 13 1059623455@qq.com arvid@apache.org
KafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 257 23 2020-10-09 2024-12-03 15 13 jiangjie.qj@alibaba-inc.com liuml07@apache.org
KafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 451 31 2020-10-09 2024-09-19 15 12 jiangjie.qj@alibaba-inc.com 598457447@qq.com
KafkaCommitter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 163 8 2021-08-16 2025-04-03 13 5 fabianpaul@ververica.com arvid@apache.org
KafkaSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 157 9 2021-08-16 2025-03-26 12 6 fabianpaul@ververica.com arvid@apache.org
KafkaRecordSerializationSchemaBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 274 22 2021-08-11 2025-04-10 12 10 fabianpaul@ververica.com arvid@apache.org
KafkaConnectorOptionsUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 519 23 2021-06-30 2025-03-25 12 10 ingo.buerk@tngtech.com lvyanquan.lyq@alibaba-inc.com
KafkaSinkBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 113 9 2021-08-16 2025-02-27 10 7 fabianpaul@ververica.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 2025-03-25 9 6 jiangjie.qj@alibaba-inc.com lvyanquan.lyq@alibaba-inc.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
ReducingUpsertSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 71 5 2021-08-12 2025-03-25 8 5 fabianpaul@ververica.com lvyanquan.lyq@alibaba-inc.com
ReducingUpsertWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 148 13 2021-08-12 2023-03-26 8 4 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
ExactlyOnceKafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 291 14 2025-02-07 2025-04-08 8 2 arvid@apache.org arvid@apache.org
KafkaConnectorOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 293 5 2021-06-30 2025-02-19 8 7 ingo.buerk@tngtech.com arvid@apache.org
KafkaSourceEnumState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 59 7 2020-10-09 2024-09-19 7 7 jiangjie.qj@alibaba-inc.com 598457447@qq.com
KafkaPartitionSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split
 106 13 2020-10-09 2023-10-23 7 7 jiangjie.qj@alibaba-inc.com tzulitai@apache.org
DynamicKafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 173 8 2020-10-19 2025-03-25 7 5 twalthr@apache.org lvyanquan.lyq@alibaba-inc.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
DynamicKafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 246 9 2021-08-10 2025-04-10 7 4 fabianpaul@ververica.com arvid@apache.org
KafkaSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 21 3 2020-10-09 2024-11-14 6 6 jiangjie.qj@alibaba-inc.com leszczynski.pawel@gmail.com
KafkaRecordDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer
 28 3 2021-03-03 2025-03-25 6 5 lindong28@gmail.com lvyanquan.lyq@alibaba-inc.com
TopicListSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 40 2 2020-10-09 2025-03-31 6 6 jiangjie.qj@alibaba-inc.com arvid@apache.org
TopicPatternSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 42 2 2020-10-09 2025-03-31 6 6 jiangjie.qj@alibaba-inc.com arvid@apache.org
JSONKeyValueDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization
 49 4 2020-10-16 2025-03-25 6 6 twalthr@apache.org lvyanquan.lyq@alibaba-inc.com
OffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 50 8 2020-10-09 2023-09-26 6 6 jiangjie.qj@alibaba-inc.com tanjialiang@52tt.com
KafkaSourceEnumStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 128 4 2020-10-09 2024-09-19 6 6 jiangjie.qj@alibaba-inc.com 598457447@qq.com
DynamicKafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator
 408 15 2023-08-09 2025-04-10 6 5 mas.chen@berkeley.edu arvid@apache.org
KafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 24 2 2021-08-11 2024-11-14 5 4 fabianpaul@ververica.com leszczynski.pawel@gmail.com
FlinkFixedPartitioner.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner
 32 4 2020-10-16 2024-12-03 5 5 twalthr@apache.org lvyanquan.lyq@alibaba-inc.com
PartitionSetSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 58 3 2020-10-09 2025-03-31 5 5 jiangjie.qj@alibaba-inc.com arvid@apache.org
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...
ProducerPoolImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 196 13 2025-02-07 2025-03-31 5 1 arvid@apache.org arvid@apache.org
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 294 34 2025-02-07 2025-04-08 5 1 arvid@apache.org arvid@apache.org
ProducerPool.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 11 - 2025-02-08 2025-03-31 4 1 arvid@apache.org arvid@apache.org
StartupMode.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config
 18 1 2020-10-16 2021-08-31 4 4 twalthr@apache.org xbjtdcq@gmail.com
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
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...
ReaderHandledOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 43 3 2020-10-09 2023-09-26 4 4 jiangjie.qj@alibaba-inc.com tanjialiang@52tt.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
KafkaCommittable.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 73 8 2021-08-16 2025-02-07 4 3 fabianpaul@ververica.com arvid@apache.org
DynamicKafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader
 420 21 2023-08-09 2025-04-10 4 2 mas.chen@berkeley.edu arvid@apache.org
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
TransactionalIdFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 25 3 2025-02-07 2025-03-31 3 1 arvid@apache.org arvid@apache.org
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 389 7 2020-05-17 2025-02-19 25 19 yuzhao.cyz@gmail.com arvid@apache.org
KafkaDynamicSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 391 15 2020-05-17 2025-03-25 29 18 yuzhao.cyz@gmail.com lvyanquan.lyq@alibaba-inc.com
KafkaDynamicSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 517 21 2020-05-17 2025-03-25 21 14 yuzhao.cyz@gmail.com lvyanquan.lyq@alibaba-inc.com
KafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 213 14 2020-10-09 2024-11-14 17 13 jiangjie.qj@alibaba-inc.com leszczynski.pawel@gmail.com
UpsertKafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 332 19 2020-11-04 2025-02-19 16 13 1059623455@qq.com arvid@apache.org
KafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 257 23 2020-10-09 2024-12-03 15 13 jiangjie.qj@alibaba-inc.com liuml07@apache.org
KafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 260 15 2021-08-16 2025-04-03 27 12 fabianpaul@ververica.com arvid@apache.org
KafkaPartitionSplitReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 425 29 2020-10-09 2025-03-06 19 12 jiangjie.qj@alibaba-inc.com trompa@gmail.com
KafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 451 31 2020-10-09 2024-09-19 15 12 jiangjie.qj@alibaba-inc.com 598457447@qq.com
KafkaRecordSerializationSchemaBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 274 22 2021-08-11 2025-04-10 12 10 fabianpaul@ververica.com arvid@apache.org
KafkaConnectorOptionsUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 519 23 2021-06-30 2025-03-25 12 10 ingo.buerk@tngtech.com lvyanquan.lyq@alibaba-inc.com
KafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 158 8 2020-10-09 2025-03-25 17 9 jiangjie.qj@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com
KafkaSinkBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 113 9 2021-08-16 2025-02-27 10 7 fabianpaul@ververica.com 125648852+loserwang1024@use...
KafkaConnectorOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 293 5 2021-06-30 2025-02-19 8 7 ingo.buerk@tngtech.com arvid@apache.org
KafkaSourceEnumState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 59 7 2020-10-09 2024-09-19 7 7 jiangjie.qj@alibaba-inc.com 598457447@qq.com
KafkaPartitionSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split
 106 13 2020-10-09 2023-10-23 7 7 jiangjie.qj@alibaba-inc.com tzulitai@apache.org
KafkaSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 157 9 2021-08-16 2025-03-26 12 6 fabianpaul@ververica.com arvid@apache.org
KafkaSourceFetcherManager.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher
 69 3 2020-10-09 2025-03-25 9 6 jiangjie.qj@alibaba-inc.com lvyanquan.lyq@alibaba-inc.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
OffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 50 8 2020-10-09 2023-09-26 6 6 jiangjie.qj@alibaba-inc.com tanjialiang@52tt.com
KafkaSourceEnumStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 128 4 2020-10-09 2024-09-19 6 6 jiangjie.qj@alibaba-inc.com 598457447@qq.com
KafkaSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 21 3 2020-10-09 2024-11-14 6 6 jiangjie.qj@alibaba-inc.com leszczynski.pawel@gmail.com
TopicPatternSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 42 2 2020-10-09 2025-03-31 6 6 jiangjie.qj@alibaba-inc.com arvid@apache.org
TopicListSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 40 2 2020-10-09 2025-03-31 6 6 jiangjie.qj@alibaba-inc.com arvid@apache.org
JSONKeyValueDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization
 49 4 2020-10-16 2025-03-25 6 6 twalthr@apache.org lvyanquan.lyq@alibaba-inc.com
KafkaCommitter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 163 8 2021-08-16 2025-04-03 13 5 fabianpaul@ververica.com arvid@apache.org
ReducingUpsertSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 71 5 2021-08-12 2025-03-25 8 5 fabianpaul@ververica.com lvyanquan.lyq@alibaba-inc.com
DynamicKafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 173 8 2020-10-19 2025-03-25 7 5 twalthr@apache.org lvyanquan.lyq@alibaba-inc.com
DynamicKafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator
 408 15 2023-08-09 2025-04-10 6 5 mas.chen@berkeley.edu arvid@apache.org
KafkaRecordDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer
 28 3 2021-03-03 2025-03-25 6 5 lindong28@gmail.com lvyanquan.lyq@alibaba-inc.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...
PartitionSetSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 58 3 2020-10-09 2025-03-31 5 5 jiangjie.qj@alibaba-inc.com arvid@apache.org
FlinkFixedPartitioner.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner
 32 4 2020-10-16 2024-12-03 5 5 twalthr@apache.org lvyanquan.lyq@alibaba-inc.com
ReducingUpsertWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 148 13 2021-08-12 2023-03-26 8 4 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
DynamicKafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 246 9 2021-08-10 2025-04-10 7 4 fabianpaul@ververica.com arvid@apache.org
KafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 24 2 2021-08-11 2024-11-14 5 4 fabianpaul@ververica.com leszczynski.pawel@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...
ReaderHandledOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 43 3 2020-10-09 2023-09-26 4 4 jiangjie.qj@alibaba-inc.com tanjialiang@52tt.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
StartupMode.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config
 18 1 2020-10-16 2021-08-31 4 4 twalthr@apache.org xbjtdcq@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
KafkaCommittable.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 73 8 2021-08-16 2025-02-07 4 3 fabianpaul@ververica.com arvid@apache.org
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
KafkaWriterState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 85 9 2021-08-16 2025-03-31 3 3 fabianpaul@ververica.com arvid@apache.org
KafkaWriterStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 64 2 2021-08-16 2025-03-31 3 3 fabianpaul@ververica.com arvid@apache.org
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
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
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
kafka.py
in flink-python/pyflink/datastream/connectors
 276 48 2023-12-11 2025-03-31 3 3 peter.vary.apache@gmail.com lvyanquan.lyq@alibaba-inc.com
ExactlyOnceKafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 291 14 2025-02-07 2025-04-08 8 2 arvid@apache.org arvid@apache.org
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 294 34 2025-02-07 2025-04-08 5 1 arvid@apache.org arvid@apache.org
pyflink_gateway_server.py
in flink-python/pyflink
 204 11 2023-12-11 2023-12-11 1 1 peter.vary.apache@gmail.com peter.vary.apache@gmail.com
DynamicKafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source
 197 17 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
StoppableKafkaEnumContextProxy.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator
 196 17 2023-08-09 2024-01-17 2 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
ProducerPoolImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 196 13 2025-02-07 2025-03-31 5 1 arvid@apache.org arvid@apache.org
DynamicKafkaSourceEnumStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator
 135 5 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
DynamicKafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source
 114 8 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
AdminUtils.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util
 105 8 2025-03-31 2025-03-31 1 1 arvid@apache.org arvid@apache.org
TransactionOwnership.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 96 4 2025-03-31 2025-03-31 1 1 arvid@apache.org arvid@apache.org
KafkaClusterMetricGroup.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics
 92 15 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
TransactionAbortStrategyImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 90 5 2025-02-08 2025-03-31 2 1 arvid@apache.org arvid@apache.org
TransactionAbortStrategyContextImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 87 9 2025-02-08 2025-03-31 2 1 arvid@apache.org arvid@apache.org
LineageUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 82 6 2024-11-14 2024-11-14 1 1 leszczynski.pawel@gmail.com leszczynski.pawel@gmail.com
BackchannelImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 79 12 2025-02-10 2025-02-10 1 1 arvid@apache.org arvid@apache.org
SingleClusterTopicMetadataService.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata
 72 7 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
KafkaPartitionSplitReaderWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader
 65 6 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
TransactionNamingStrategyImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 63 5 2025-02-08 2025-03-31 2 1 arvid@apache.org arvid@apache.org
BackchannelFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 60 6 2025-02-10 2025-02-10 1 1 arvid@apache.org arvid@apache.org
TransactionNamingStrategyContextImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 59 10 2025-02-08 2025-02-08 1 1 arvid@apache.org arvid@apache.org
DefaultKafkaDatasetFacet.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 49 8 2024-11-14 2024-11-14 1 1 leszczynski.pawel@gmail.com leszczynski.pawel@gmail.com
KafkaClusterMetricGroupManager.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics
 49 4 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
TransactionFinished.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 49 8 2025-03-26 2025-03-26 1 1 arvid@apache.org arvid@apache.org
DefaultKafkaDatasetIdentifier.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 46 7 2024-11-14 2024-11-14 1 1 leszczynski.pawel@gmail.com leszczynski.pawel@gmail.com
CheckpointTransaction.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 45 6 2025-02-10 2025-02-10 1 1 arvid@apache.org arvid@apache.org
DefaultTypeDatasetFacet.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 33 5 2024-11-14 2024-11-14 1 1 leszczynski.pawel@gmail.com leszczynski.pawel@gmail.com
DynamicKafkaSourceOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source
 31 2 2023-08-09 2024-01-25 2 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
DynamicKafkaSourceEnumState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator
 29 4 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
TransactionNamingStrategy.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 26 2 2025-02-08 2025-02-08 1 1 arvid@apache.org arvid@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
JacksonMapperFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util
 25 4 2023-10-09 2023-10-09 1 1 mvisser@confluent.io mvisser@confluent.io
TransactionalIdFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 25 3 2025-02-07 2025-03-31 3 1 arvid@apache.org arvid@apache.org
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
KafkaPropertiesUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 20 3 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
KafkaDatasetIdentifier.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 19 1 2024-11-14 2024-11-14 1 1 leszczynski.pawel@gmail.com leszczynski.pawel@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
in
MANIFEST.in
in flink-python
 19 - 2023-12-11 2023-12-11 1 1 peter.vary.apache@gmail.com peter.vary.apache@gmail.com
LatestOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 18 2 2023-09-26 2023-09-26 1 1 tanjialiang@52tt.com tanjialiang@52tt.com
KafkaStreamSetSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber
 17 2 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
KafkaMetadataService.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata
 12 - 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
ProducerPool.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 11 - 2025-02-08 2025-03-31 4 1 arvid@apache.org arvid@apache.org
KafkaDatasetFacet.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 10 - 2024-11-14 2024-11-14 1 1 leszczynski.pawel@gmail.com leszczynski.pawel@gmail.com
KafkaStreamSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber
 10 - 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
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
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
Backchannel.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 9 - 2025-02-08 2025-02-10 2 1 arvid@apache.org arvid@apache.org
suppressions.xml
in tools/maven
 9 - 2025-04-10 2025-04-10 1 1 arvid@apache.org arvid@apache.org
TypeDatasetFacet.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 8 - 2024-11-14 2024-11-14 1 1 leszczynski.pawel@gmail.com leszczynski.pawel@gmail.com
KafkaPartitioner.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 8 1 2024-09-27 2024-09-27 1 1 aheise@users.noreply.github... aheise@users.noreply.github...
ReadableBackchannel.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 8 - 2025-02-08 2025-02-10 2 1 arvid@apache.org arvid@apache.org
KafkaDatasetIdentifierProvider.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 7 - 2024-11-14 2024-11-14 1 1 leszczynski.pawel@gmail.com leszczynski.pawel@gmail.com
Correlations

File Size vs. Number of Changes: 122 points

tools/maven/suppressions.xml x: 9 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReader.java x: 420 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java x: 40 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java x: 46 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java x: 36 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java x: 408 lines of code y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/StreamPatternSubscriber.java x: 27 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java x: 56 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 274 lines of code y: 12 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 246 lines of code y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java x: 291 lines of code y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java x: 294 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java x: 293 lines of code y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 391 lines of code y: 29 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 389 lines of code y: 25 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 332 lines of code y: 16 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 163 lines of code y: 13 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 157 lines of code y: 12 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 113 lines of code y: 10 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionNamingStrategy.java x: 26 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyContextImpl.java x: 59 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyImpl.java x: 63 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionalIdFactory.java x: 25 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 85 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializer.java x: 64 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPool.java x: 11 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPoolImpl.java x: 196 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyContextImpl.java x: 87 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyImpl.java x: 90 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionOwnership.java x: 96 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/PartitionSetSubscriber.java x: 58 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java x: 40 lines of code y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java x: 42 lines of code y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util/AdminUtils.java x: 105 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/Backchannel.java x: 9 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ReadableBackchannel.java x: 8 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/WritableBackchannel.java x: 6 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 260 lines of code y: 27 # changes flink-python/pyflink/datastream/connectors/kafka.py x: 276 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionFinished.java x: 49 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 20 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 158 lines of code y: 17 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchema.java x: 28 lines of code y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 69 lines of code y: 9 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 173 lines of code y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 519 lines of code y: 12 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java x: 517 lines of code y: 21 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 71 lines of code y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java x: 49 lines of code y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java x: 32 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 425 lines of code y: 19 # changes flink-python/setup.py x: 95 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 73 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java x: 45 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelFactory.java x: 60 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImpl.java x: 79 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java x: 257 lines of code y: 15 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java x: 46 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultTypeDatasetFacet.java x: 33 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetFacet.java x: 10 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetFacetProvider.java x: 7 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetIdentifier.java x: 19 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java x: 82 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/TypeDatasetFacet.java x: 8 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java x: 24 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java x: 213 lines of code y: 17 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java x: 21 lines of code y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java x: 59 lines of code y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java x: 128 lines of code y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java x: 451 lines of code y: 15 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceOptions.java x: 31 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/StoppableKafkaEnumContextProxy.java x: 196 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaMetadataService.java x: 12 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/SingleClusterTopicMetadataService.java x: 72 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSource.java x: 114 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceBuilder.java x: 197 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/GetMetadataUpdateEvent.java x: 5 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumState.java x: 29 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumStateSerializer.java x: 135 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/KafkaStreamSetSubscriber.java x: 17 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics/KafkaClusterMetricGroup.java x: 92 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/KafkaPartitionSplitReaderWrapper.java x: 65 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaPropertiesUtil.java x: 20 lines of code y: 1 # changes flink-python/pyflink/pyflink_gateway_server.py x: 204 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplit.java x: 106 lines of code y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/LatestOffsetsInitializer.java x: 18 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java x: 50 lines of code y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/ReaderHandledOffsetsInitializer.java x: 43 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util/JacksonMapperFactory.java x: 25 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java x: 40 lines of code y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java x: 148 lines of code y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java x: 73 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java x: 37 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java x: 22 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/DefaultKafkaSinkContext.java x: 45 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricMutableWrapper.java x: 19 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java x: 194 lines of code y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaRecordEmitter.java x: 49 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitSerializer.java x: 42 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java x: 60 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializerWrapper.java x: 71 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/MetricUtil.java x: 33 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java x: 48 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TopicSelector.java x: 6 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/StartupMode.java x: 18 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittableSerializer.java x: 34 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/NoStoppingOffsetsInitializer.java x: 23 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateSentinel.java x: 12 lines of code y: 2 # changes
29.0
# changes
  min: 1.0
  average: 4.63
  25th percentile: 1.0
  median: 2.0
  75th percentile: 6.0
  max: 29.0
0 519.0
lines of code
min: 5.0 | average: 99.24 | 25th percentile: 22.75 | median: 49.0 | 75th percentile: 117.5 | max: 519.0

Number of Contributors vs. Number of Changes: 122 points

tools/maven/suppressions.xml x: 1 # contributors y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReader.java x: 2 # contributors y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java x: 2 # contributors y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java x: 5 # contributors y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 10 # contributors y: 12 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 4 # contributors y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java x: 2 # contributors y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java x: 1 # contributors y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java x: 7 # contributors y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 18 # contributors y: 29 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 19 # contributors y: 25 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 13 # contributors y: 16 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 5 # contributors y: 13 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 6 # contributors y: 12 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 7 # contributors y: 10 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyImpl.java x: 1 # contributors y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionalIdFactory.java x: 1 # contributors y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 3 # contributors y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPool.java x: 1 # contributors y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/PartitionSetSubscriber.java x: 5 # contributors y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java x: 6 # contributors y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 12 # contributors y: 27 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 9 # contributors y: 17 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 6 # contributors y: 9 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 5 # contributors y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java x: 14 # contributors y: 21 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 5 # contributors y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 12 # contributors y: 19 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 3 # contributors y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java x: 13 # contributors y: 15 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java x: 4 # contributors y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java x: 13 # contributors y: 17 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java x: 7 # contributors y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java x: 12 # contributors y: 15 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/ReaderHandledOffsetsInitializer.java x: 4 # contributors y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java x: 6 # contributors y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java x: 4 # contributors y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java x: 3 # contributors y: 7 # changes
29.0
# changes
  min: 1.0
  average: 4.63
  25th percentile: 1.0
  median: 2.0
  75th percentile: 6.0
  max: 29.0
0 19.0
# contributors
min: 1.0 | average: 3.46 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 5.0 | max: 19.0

Number of Contributors vs. File Size: 122 points

tools/maven/suppressions.xml x: 1 # contributors y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReader.java x: 2 # contributors y: 420 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java x: 2 # contributors y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java x: 2 # contributors y: 46 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java x: 2 # contributors y: 36 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java x: 5 # contributors y: 408 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/StreamPatternSubscriber.java x: 2 # contributors y: 27 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java x: 2 # contributors y: 56 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 10 # contributors y: 274 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 4 # contributors y: 246 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java x: 2 # contributors y: 291 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java x: 1 # contributors y: 294 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java x: 7 # contributors y: 293 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 18 # contributors y: 391 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 19 # contributors y: 389 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 13 # contributors y: 332 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 5 # contributors y: 163 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 6 # contributors y: 157 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 7 # contributors y: 113 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionNamingStrategy.java x: 1 # contributors y: 26 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyContextImpl.java x: 1 # contributors y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyImpl.java x: 1 # contributors y: 63 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 3 # contributors y: 85 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializer.java x: 3 # contributors y: 64 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPool.java x: 1 # contributors y: 11 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPoolImpl.java x: 1 # contributors y: 196 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyContextImpl.java x: 1 # contributors y: 87 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyImpl.java x: 1 # contributors y: 90 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionOwnership.java x: 1 # contributors y: 96 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/PartitionSetSubscriber.java x: 5 # contributors y: 58 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java x: 6 # contributors y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java x: 6 # contributors y: 42 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util/AdminUtils.java x: 1 # contributors y: 105 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ReadableBackchannel.java x: 1 # contributors y: 8 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/WritableBackchannel.java x: 1 # contributors y: 6 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 12 # contributors y: 260 lines of code flink-python/pyflink/datastream/connectors/kafka.py x: 3 # contributors y: 276 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionFinished.java x: 1 # contributors y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 2 # contributors y: 20 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 9 # contributors y: 158 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchema.java x: 5 # contributors y: 28 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 6 # contributors y: 69 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 5 # contributors y: 173 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 10 # contributors y: 519 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java x: 14 # contributors y: 517 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 5 # contributors y: 71 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java x: 6 # contributors y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java x: 5 # contributors y: 32 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 12 # contributors y: 425 lines of code flink-python/setup.py x: 2 # contributors y: 95 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 3 # contributors y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java x: 1 # contributors y: 45 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelFactory.java x: 1 # contributors y: 60 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImpl.java x: 1 # contributors y: 79 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java x: 13 # contributors y: 257 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultTypeDatasetFacet.java x: 1 # contributors y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetIdentifier.java x: 1 # contributors y: 19 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java x: 1 # contributors y: 82 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java x: 4 # contributors y: 24 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java x: 13 # contributors y: 213 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java x: 6 # contributors y: 21 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java x: 7 # contributors y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java x: 6 # contributors y: 128 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java x: 12 # contributors y: 451 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceOptions.java x: 1 # contributors y: 31 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/SingleClusterTopicMetadataService.java x: 1 # contributors y: 72 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSource.java x: 1 # contributors y: 114 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceBuilder.java x: 1 # contributors y: 197 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumState.java x: 1 # contributors y: 29 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumStateSerializer.java x: 1 # contributors y: 135 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/KafkaStreamSetSubscriber.java x: 1 # contributors y: 17 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics/KafkaClusterMetricGroup.java x: 1 # contributors y: 92 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/KafkaPartitionSplitReaderWrapper.java x: 1 # contributors y: 65 lines of code flink-python/pyflink/pyflink_gateway_server.py x: 1 # contributors y: 204 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplit.java x: 7 # contributors y: 106 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java x: 6 # contributors y: 50 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/ReaderHandledOffsetsInitializer.java x: 4 # contributors y: 43 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java x: 4 # contributors y: 148 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java x: 5 # contributors y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java x: 4 # contributors y: 37 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java x: 1 # contributors y: 22 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricMutableWrapper.java x: 3 # contributors y: 19 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java x: 3 # contributors y: 194 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaRecordEmitter.java x: 4 # contributors y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitSerializer.java x: 3 # contributors y: 42 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitState.java x: 3 # contributors y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java x: 2 # contributors y: 60 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializerWrapper.java x: 3 # contributors y: 71 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/MetricUtil.java x: 2 # contributors y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java x: 2 # contributors y: 48 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/StartupMode.java x: 4 # contributors y: 18 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/NoStoppingOffsetsInitializer.java x: 2 # contributors y: 23 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateSentinel.java x: 2 # contributors y: 12 lines of code
519.0
lines of code
  min: 5.0
  average: 99.24
  25th percentile: 22.75
  median: 49.0
  75th percentile: 117.5
  max: 519.0
0 19.0
# contributors
min: 1.0 | average: 3.46 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 5.0 | max: 19.0