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 113 files with 12,944 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 3 files changed 21-50 times (1,992 lines of code)
    • 21 files changed 6-20 times (4,992 lines of code)
    • 89 files changed 1-5 times (5,960 lines of code)
0% | 0% | 15% | 38% | 46%
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 113 files with 12,944 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 7 files changed by 11-25 contributors (3,304 lines of code)
    • 8 files changed by 6-10 contributors (2,194 lines of code)
    • 85 files changed by 2-5 contributors (7,023 lines of code)
    • 13 files changed by 1 contributor (423 lines of code)
0% | 25% | 16% | 54% | 3%
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, txt, properties, yml, json, yaml, gitignore, gitmodules
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 15% | 38% | 46%
xml0% | 0% | 0% | 0% | 0%
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% | 15% | 38% | 46%
tools0% | 0% | 0% | 0% | 0%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
FlinkKafkaProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 1262 87 2018-10-13 2021-11-04 36 25 yanghua1127@gmail.com fabianpaul@ververica.com
KafkaDynamicSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 360 14 2020-05-17 2023-03-12 25 14 yuzhao.cyz@gmail.com aleksandr.sorokoumov@gmail.com
KafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 370 18 2021-08-16 2023-03-30 21 9 fabianpaul@ververica.com mas.chen@berkeley.edu
KafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 372 7 2020-05-17 2023-05-06 20 14 yuzhao.cyz@gmail.com loserwang1024@gmail.com
KafkaDynamicSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 512 21 2020-05-17 2022-02-08 18 12 yuzhao.cyz@gmail.com francescoguard@gmail.com
KafkaPartitionSplitReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 410 26 2020-10-09 2023-03-23 16 9 jiangjie.qj@alibaba-inc.com aleksandr.sorokoumov@gmail.com
KafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 167 13 2020-10-09 2023-05-06 15 11 jiangjie.qj@alibaba-inc.com loserwang1024@gmail.com
KafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 159 8 2020-10-09 2022-03-25 14 6 jiangjie.qj@alibaba-inc.com dwysakowicz@apache.org
KafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 451 31 2020-10-09 2023-05-06 14 11 jiangjie.qj@alibaba-inc.com loserwang1024@gmail.com
UpsertKafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 331 20 2020-11-04 2023-04-05 13 10 1059623455@qq.com tzulitai@apache.org
KafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 211 21 2020-10-09 2022-04-05 12 10 jiangjie.qj@alibaba-inc.com mason.chen@apple.com
FlinkKafkaConsumer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 180 12 2018-10-13 2021-09-01 11 11 yanghua1127@gmail.com bin.huangxb@gmail.com
KafkaCommitter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 105 3 2021-08-16 2022-07-13 9 4 fabianpaul@ververica.com root@ip-10-31-1-150.us-west...
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
KafkaSourceFetcherManager.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher
 69 3 2020-10-09 2022-07-24 8 5 jiangjie.qj@alibaba-inc.com sebastian@ververica.com
FlinkKafkaShuffle.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 135 7 2020-05-15 2023-01-29 8 6 yuanmei.work@gmail.com jrlee.ljr@gmail.com
ReducingUpsertWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 148 13 2021-08-12 2023-03-27 8 4 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
KafkaConnectorOptionsUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 538 24 2021-06-30 2023-04-05 8 7 ingo.buerk@tngtech.com tzulitai@apache.org
KafkaSinkBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 99 9 2021-08-16 2022-05-09 7 4 fabianpaul@ververica.com 11444089+alpreu@users.norep...
KafkaRecordSerializationSchemaBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 194 17 2021-08-11 2023-04-12 7 5 fabianpaul@ververica.com tzulitai@apache.org
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
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 292 32 2021-08-16 2023-03-23 7 4 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
ReducingUpsertSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 71 3 2021-08-12 2023-03-12 6 3 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 314 29 2020-10-16 2023-03-23 6 5 twalthr@apache.org aleksandr.sorokoumov@gmail.com
KafkaSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 21 3 2020-10-09 2022-04-05 5 5 jiangjie.qj@alibaba-inc.com mason.chen@apple.com
OffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 51 8 2020-10-09 2022-11-25 5 5 jiangjie.qj@alibaba-inc.com mas.chen@berkeley.edu
KafkaSourceEnumState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 59 6 2020-10-09 2023-05-06 5 5 jiangjie.qj@alibaba-inc.com loserwang1024@gmail.com
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...
KafkaSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 76 7 2021-08-16 2023-03-12 5 3 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
KafkaPartitionSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split
 106 13 2020-10-09 2022-07-09 5 5 jiangjie.qj@alibaba-inc.com johnson5211.work@gmail.com
KafkaSourceEnumStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 128 4 2020-10-09 2023-05-06 5 5 jiangjie.qj@alibaba-inc.com loserwang1024@gmail.com
DynamicKafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 179 10 2020-10-19 2020-12-28 5 3 twalthr@apache.org dev@flink.apache.org
KafkaConnectorOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 276 5 2021-06-30 2023-05-06 5 4 ingo.buerk@tngtech.com loserwang1024@gmail.com
FlinkKafkaConsumerBase.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 677 29 2020-10-16 2020-12-28 5 5 twalthr@apache.org dev@flink.apache.org
KafkaMetricWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics
 15 2 2020-10-16 2022-08-17 4 4 twalthr@apache.org chesnay@apache.org
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
KafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 24 2 2021-08-11 2022-10-31 4 3 fabianpaul@ververica.com salcantaraphd@gmail.com
KafkaSubscriberUtils.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 25 3 2020-10-09 2022-10-25 4 4 jiangjie.qj@alibaba-inc.com snuyanzin@gmail.com
TopicListSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 33 1 2020-10-09 2021-09-01 4 4 jiangjie.qj@alibaba-inc.com w.gh123@qq.com
KafkaRecordDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer
 33 4 2021-03-03 2022-02-15 4 3 lindong28@gmail.com gejing@gmail.com
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...
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
FlinkKafkaShuffleConsumer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 63 1 2020-05-15 2020-12-28 4 3 yuanmei.work@gmail.com dev@flink.apache.org
FlinkKafkaShuffleProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 153 2 2020-05-15 2022-10-05 4 3 yuanmei.work@gmail.com zakelly.lan@gmail.com
KafkaConsumerThread.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 310 9 2020-10-16 2022-11-23 4 4 twalthr@apache.org snuyanzin@gmail.com
AbstractFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 324 11 2020-10-16 2022-04-25 4 4 twalthr@apache.org dwysakowicz@apache.org
KafkaTopicPartitionAssigner.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 12 2 2020-10-16 2022-10-05 3 3 twalthr@apache.org zakelly.lan@gmail.com
StreamKafkaShuffleSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 16 2 2020-05-15 2020-12-28 3 2 yuanmei.work@gmail.com dev@flink.apache.org
SourceContextWatermarkOutputAdapter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 22 4 2020-10-16 2021-07-08 3 3 twalthr@apache.org arvid@ververica.com
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
FlinkKafkaProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 1262 87 2018-10-13 2021-11-04 36 25 yanghua1127@gmail.com fabianpaul@ververica.com
KafkaDynamicSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 360 14 2020-05-17 2023-03-12 25 14 yuzhao.cyz@gmail.com aleksandr.sorokoumov@gmail.com
KafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 372 7 2020-05-17 2023-05-06 20 14 yuzhao.cyz@gmail.com loserwang1024@gmail.com
KafkaDynamicSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 512 21 2020-05-17 2022-02-08 18 12 yuzhao.cyz@gmail.com francescoguard@gmail.com
KafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 167 13 2020-10-09 2023-05-06 15 11 jiangjie.qj@alibaba-inc.com loserwang1024@gmail.com
KafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 451 31 2020-10-09 2023-05-06 14 11 jiangjie.qj@alibaba-inc.com loserwang1024@gmail.com
FlinkKafkaConsumer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 180 12 2018-10-13 2021-09-01 11 11 yanghua1127@gmail.com bin.huangxb@gmail.com
UpsertKafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 331 20 2020-11-04 2023-04-05 13 10 1059623455@qq.com tzulitai@apache.org
KafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 211 21 2020-10-09 2022-04-05 12 10 jiangjie.qj@alibaba-inc.com mason.chen@apple.com
KafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 370 18 2021-08-16 2023-03-30 21 9 fabianpaul@ververica.com mas.chen@berkeley.edu
KafkaPartitionSplitReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 410 26 2020-10-09 2023-03-23 16 9 jiangjie.qj@alibaba-inc.com aleksandr.sorokoumov@gmail.com
KafkaConnectorOptionsUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 538 24 2021-06-30 2023-04-05 8 7 ingo.buerk@tngtech.com tzulitai@apache.org
KafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 159 8 2020-10-09 2022-03-25 14 6 jiangjie.qj@alibaba-inc.com dwysakowicz@apache.org
FlinkKafkaShuffle.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 135 7 2020-05-15 2023-01-29 8 6 yuanmei.work@gmail.com jrlee.ljr@gmail.com
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
KafkaSourceFetcherManager.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher
 69 3 2020-10-09 2022-07-24 8 5 jiangjie.qj@alibaba-inc.com sebastian@ververica.com
KafkaRecordSerializationSchemaBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 194 17 2021-08-11 2023-04-12 7 5 fabianpaul@ververica.com tzulitai@apache.org
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 314 29 2020-10-16 2023-03-23 6 5 twalthr@apache.org aleksandr.sorokoumov@gmail.com
FlinkKafkaConsumerBase.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 677 29 2020-10-16 2020-12-28 5 5 twalthr@apache.org dev@flink.apache.org
KafkaPartitionSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split
 106 13 2020-10-09 2022-07-09 5 5 jiangjie.qj@alibaba-inc.com johnson5211.work@gmail.com
KafkaSourceEnumStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 128 4 2020-10-09 2023-05-06 5 5 jiangjie.qj@alibaba-inc.com loserwang1024@gmail.com
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...
OffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 51 8 2020-10-09 2022-11-25 5 5 jiangjie.qj@alibaba-inc.com mas.chen@berkeley.edu
KafkaSourceEnumState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 59 6 2020-10-09 2023-05-06 5 5 jiangjie.qj@alibaba-inc.com loserwang1024@gmail.com
KafkaSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 21 3 2020-10-09 2022-04-05 5 5 jiangjie.qj@alibaba-inc.com mason.chen@apple.com
KafkaCommitter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 105 3 2021-08-16 2022-07-13 9 4 fabianpaul@ververica.com root@ip-10-31-1-150.us-west...
ReducingUpsertWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 148 13 2021-08-12 2023-03-27 8 4 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
KafkaSinkBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 99 9 2021-08-16 2022-05-09 7 4 fabianpaul@ververica.com 11444089+alpreu@users.norep...
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 292 32 2021-08-16 2023-03-23 7 4 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
KafkaConnectorOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 276 5 2021-06-30 2023-05-06 5 4 ingo.buerk@tngtech.com loserwang1024@gmail.com
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
KafkaMetricWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics
 15 2 2020-10-16 2022-08-17 4 4 twalthr@apache.org chesnay@apache.org
AbstractFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 324 11 2020-10-16 2022-04-25 4 4 twalthr@apache.org dwysakowicz@apache.org
KafkaConsumerThread.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 310 9 2020-10-16 2022-11-23 4 4 twalthr@apache.org snuyanzin@gmail.com
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
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...
KafkaSubscriberUtils.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 25 3 2020-10-09 2022-10-25 4 4 jiangjie.qj@alibaba-inc.com snuyanzin@gmail.com
TopicListSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 33 1 2020-10-09 2021-09-01 4 4 jiangjie.qj@alibaba-inc.com w.gh123@qq.com
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
ReducingUpsertSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 71 3 2021-08-12 2023-03-12 6 3 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
DynamicKafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 179 10 2020-10-19 2020-12-28 5 3 twalthr@apache.org dev@flink.apache.org
KafkaSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 76 7 2021-08-16 2023-03-12 5 3 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
FlinkKafkaShuffleProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 153 2 2020-05-15 2022-10-05 4 3 yuanmei.work@gmail.com zakelly.lan@gmail.com
FlinkKafkaShuffleConsumer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 63 1 2020-05-15 2020-12-28 4 3 yuanmei.work@gmail.com dev@flink.apache.org
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
KafkaRecordDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer
 33 4 2021-03-03 2022-02-15 4 3 lindong28@gmail.com gejing@gmail.com
KafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 24 2 2021-08-11 2022-10-31 4 3 fabianpaul@ververica.com salcantaraphd@gmail.com
FlinkFixedPartitioner.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner
 31 4 2020-10-16 2020-12-28 3 3 twalthr@apache.org dev@flink.apache.org
FlinkKafkaProducerBase.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 281 14 2020-10-16 2020-12-28 3 3 twalthr@apache.org dev@flink.apache.org
KafkaTopicPartitionAssigner.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 12 2 2020-10-16 2022-10-05 3 3 twalthr@apache.org zakelly.lan@gmail.com
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
suppressions.xml
in tools/maven
 6 -
DynamicKafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 142 5 2021-08-10 2021-08-16 2 1 fabianpaul@ververica.com fabianpaul@ververica.com
TransactionAborter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 58 5 2021-08-27 2021-08-27 1 1 arvid@ververica.com arvid@ververica.com
TransactionsToAbortChecker.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 50 2 2021-08-16 2021-08-16 1 1 fabianpaul@ververica.com fabianpaul@ververica.com
KafkaDeserializationSchemaWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer
 32 3 2021-03-03 2021-03-03 1 1 lindong28@gmail.com lindong28@gmail.com
KafkaValueOnlyDeserializationSchemaWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer
 26 3 2021-03-03 2021-03-03 1 1 lindong28@gmail.com lindong28@gmail.com
Recyclable.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 25 4 2021-08-27 2021-09-05 2 1 arvid@ververica.com arvid@ververica.com
AssignmentStatus.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 22 2 2023-05-06 2023-05-06 1 1 loserwang1024@gmail.com loserwang1024@gmail.com
TopicPartitionAndAssignmentStatus.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 19 3 2023-05-06 2023-05-06 1 1 loserwang1024@gmail.com loserwang1024@gmail.com
TwoPhaseCommittingStatefulSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 17 1 2023-03-12 2023-03-12 1 1 aleksandr.sorokoumov@gmail.com aleksandr.sorokoumov@gmail.com
BoundedMode.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config
 10 - 2021-12-02 2021-12-02 1 1 2572805166@qq.com 2572805166@qq.com
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
OffsetsInitializerValidator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 7 - 2021-09-14 2021-09-14 1 1 renqschn@gmail.com renqschn@gmail.com
TopicSelector.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 6 - 2021-09-14 2021-09-14 1 1 fabianpaul@ververica.com fabianpaul@ververica.com
ClosableBlockingQueue.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 262 19 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaShuffleFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 211 14 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 159 11 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
TypeInformationKeyValueSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization
 115 5 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
AbstractPartitionDiscoverer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 107 8 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
Handover.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 86 5 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaTopicPartition.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 82 10 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaTopicPartitionLeader.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 73 6 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaSerializationSchemaWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 72 8 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaPartitionDiscoverer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 71 6 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaCommittable.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 70 8 2021-08-16 2021-08-27 3 2 fabianpaul@ververica.com arvid@ververica.com
KafkaSerializerWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 60 1 2021-08-11 2022-01-19 2 2 fabianpaul@ververica.com gejing@gmail.com
KafkaTopicPartitionState.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 58 14 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaTopicsDescriptor.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 49 6 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
SinkBufferFlushMode.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 48 6 2021-03-30 2021-10-21 2 2 1059623455@qq.com fabianpaul@ververica.com
KafkaTopicPartitionStateWithWatermarkGenerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 45 5 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
DefaultKafkaSinkContext.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 45 3 2021-08-16 2022-07-26 2 2 fabianpaul@ververica.com chesnay@apache.org
KafkaDeserializationSchemaWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 36 6 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaWriterState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 35 4 2021-08-16 2021-08-27 2 2 fabianpaul@ververica.com arvid@ververica.com
KafkaCommittableSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 34 2 2021-08-16 2021-08-19 2 2 fabianpaul@ververica.com arvid@ververica.com
MetricUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka
 33 3 2021-08-17 2021-10-13 2 2 fabianpaul@ververica.com flinker@126.com
FlinkKafkaProducer011.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 30 3 2019-02-11 2020-12-28 2 2 piotr.nowojski@gmail.com dev@flink.apache.org
ExceptionProxy.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 30 3 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaWriterStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 30 2 2021-08-16 2021-08-27 2 2 fabianpaul@ververica.com arvid@ververica.com
KeyedSerializationSchemaWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 27 3 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
NoStoppingOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 23 2 2020-10-09 2020-12-28 2 2 jiangjie.qj@alibaba-inc.com dev@flink.apache.org
KafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 20 2 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
FlinkKafkaException.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 19 3 2018-10-13 2020-12-28 2 2 yanghua1127@gmail.com dev@flink.apache.org
OffsetCommitModes.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config
 17 1 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
StreamKafkaShuffleSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 16 2 2020-05-15 2020-12-28 3 2 yuanmei.work@gmail.com dev@flink.apache.org
KeyedDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization
 16 1 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaConsumerMetricConstants.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics
 14 - 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
KafkaTopicPartitionStateSentinel.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 12 1 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
TransactionalIdFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 12 1 2021-08-16 2021-08-27 2 2 fabianpaul@ververica.com arvid@ververica.com
KafkaSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 11 1 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
FlinkKafkaPartitioner.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner
 11 1 2020-10-16 2020-12-28 2 2 twalthr@apache.org dev@flink.apache.org
Correlations

File Size vs. Number of Changes: 113 points

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/KafkaConnectorOptions.java x: 276 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 372 lines of code y: 20 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 76 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 370 lines of code y: 21 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 17 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 360 lines of code y: 25 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 71 lines of code y: 6 # 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/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 331 lines of code y: 13 # 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/KafkaSource.java x: 167 lines of code y: 15 # 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/source/enumerator/KafkaSourceEnumState.java x: 59 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java x: 128 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java x: 451 lines of code y: 14 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/TopicPartitionAndAssignmentStatus.java x: 19 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 194 lines of code y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProvider.java x: 9 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 538 lines of code y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java x: 292 lines of code y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 410 lines of code y: 16 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java x: 314 lines of code y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/BoundedMode.java x: 10 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java x: 512 lines of code y: 18 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java x: 135 lines of code y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaConsumerThread.java x: 310 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java x: 25 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java x: 51 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionAssigner.java x: 12 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java x: 153 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java x: 211 lines of code y: 12 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 69 lines of code y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 159 lines of code y: 14 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java x: 324 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricWrapper.java x: 15 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java x: 49 lines of code y: 3 # 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/connector/kafka/source/split/KafkaPartitionSplit.java x: 106 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 105 lines of code y: 9 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java x: 21 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 99 lines of code y: 7 # 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/reader/KafkaRecordEmitter.java x: 49 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchema.java x: 33 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/source/split/KafkaPartitionSplitState.java x: 25 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/streaming/connectors/kafka/FlinkKafkaProducer.java x: 1262 lines of code y: 36 # 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/connector/kafka/sink/Recyclable.java x: 25 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java x: 180 lines of code y: 11 # 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/KafkaCommittable.java x: 70 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 35 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializer.java x: 30 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionAborter.java x: 58 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionalIdFactory.java x: 12 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionsToAbortChecker.java x: 50 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 142 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SourceContextWatermarkOutputAdapter.java x: 22 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/PartitionSetSubscriber.java x: 46 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java x: 37 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaDeserializationSchemaWrapper.java x: 32 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializationSchemaWrapper.java x: 26 lines of code y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java x: 677 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaErrorCode.java x: 7 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaException.java x: 19 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java x: 281 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializationSchema.java x: 11 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/OffsetCommitModes.java x: 17 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java x: 107 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java x: 262 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Handover.java x: 86 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaFetcher.java x: 159 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaPartitionDiscoverer.java x: 71 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaShuffleFetcher.java x: 211 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java x: 82 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionLeader.java x: 73 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionState.java x: 58 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KeyedSerializationSchemaWrapper.java x: 27 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaConsumerMetricConstants.java x: 14 lines of code y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java x: 31 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java x: 63 lines of code y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/StreamKafkaShuffleSink.java x: 16 lines of code y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 179 lines of code y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationKeyValueSerializationSchema.java x: 115 lines of code y: 2 # changes
36.0
# changes
  min: 1.0
  average: 4.79
  25th percentile: 2.0
  median: 3.0
  75th percentile: 5.0
  max: 36.0
0 1262.0
lines of code
min: 6.0 | average: 114.55 | 25th percentile: 22.5 | median: 49.0 | 75th percentile: 145.0 | max: 1262.0

Number of Contributors vs. Number of Changes: 113 points

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/KafkaConnectorOptions.java x: 4 # contributors y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 14 # contributors y: 20 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 3 # contributors y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 9 # contributors y: 21 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 1 # contributors y: 1 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 14 # contributors y: 25 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 3 # contributors y: 6 # 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/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 10 # contributors y: 13 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java x: 5 # contributors y: 5 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java x: 4 # contributors y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java x: 11 # contributors y: 15 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java x: 11 # contributors y: 14 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 5 # contributors y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 7 # contributors y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java x: 4 # contributors y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 9 # contributors y: 16 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java x: 5 # contributors y: 6 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java x: 12 # contributors y: 18 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionAssigner.java x: 3 # contributors y: 3 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java x: 3 # contributors y: 4 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java x: 10 # contributors y: 12 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 5 # contributors y: 8 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 6 # contributors y: 14 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/DefaultKafkaSinkContext.java x: 2 # contributors y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 4 # contributors y: 9 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java x: 3 # contributors y: 7 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java x: 25 # contributors y: 36 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/Recyclable.java x: 1 # contributors y: 2 # changes flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java x: 11 # contributors y: 11 # changes flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 2 # contributors y: 3 # changes
36.0
# changes
  min: 1.0
  average: 4.79
  25th percentile: 2.0
  median: 3.0
  75th percentile: 5.0
  max: 36.0
0 25.0
# contributors
min: 1.0 | average: 3.73 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 4.0 | max: 25.0

Number of Contributors vs. File Size: 113 points

flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java x: 6 # contributors y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java x: 4 # contributors y: 276 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 14 # contributors y: 372 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 3 # contributors y: 76 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 9 # contributors y: 370 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 1 # contributors y: 17 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 14 # contributors y: 360 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 3 # contributors y: 71 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/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 10 # contributors y: 331 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/KafkaSource.java x: 11 # contributors y: 167 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/connector/kafka/source/enumerator/KafkaSourceEnumState.java x: 5 # contributors y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java x: 5 # contributors y: 128 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java x: 11 # contributors y: 451 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 5 # contributors y: 194 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProvider.java x: 1 # contributors y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 7 # contributors y: 538 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java x: 4 # contributors y: 292 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 9 # contributors y: 410 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java x: 5 # contributors y: 314 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/BoundedMode.java x: 1 # contributors y: 10 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java x: 12 # contributors y: 512 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java x: 6 # contributors y: 135 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaConsumerThread.java x: 4 # contributors y: 310 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java x: 4 # contributors y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java x: 5 # contributors y: 51 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionAssigner.java x: 3 # contributors y: 12 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java x: 3 # contributors y: 153 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java x: 3 # contributors y: 24 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java x: 10 # contributors y: 211 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 5 # contributors y: 69 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 6 # contributors y: 159 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java x: 4 # contributors y: 324 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricWrapper.java x: 4 # contributors y: 15 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java x: 3 # contributors y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/DefaultKafkaSinkContext.java x: 2 # contributors y: 45 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplit.java x: 5 # contributors y: 106 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 4 # contributors y: 105 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java x: 5 # contributors y: 21 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 4 # contributors y: 99 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/reader/deserializer/KafkaRecordDeserializationSchema.java x: 3 # contributors y: 33 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/MetricUtil.java x: 2 # contributors y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java x: 25 # contributors y: 1262 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/Recyclable.java x: 1 # contributors y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java x: 11 # contributors y: 180 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java x: 4 # contributors y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 2 # contributors y: 70 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 2 # contributors y: 35 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionAborter.java x: 1 # contributors y: 58 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionalIdFactory.java x: 2 # contributors y: 12 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionsToAbortChecker.java x: 1 # contributors y: 50 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 1 # contributors y: 142 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java x: 3 # contributors y: 37 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaDeserializationSchemaWrapper.java x: 1 # contributors y: 32 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/FlinkKafkaConsumerBase.java x: 5 # contributors y: 677 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaErrorCode.java x: 2 # contributors y: 7 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaException.java x: 2 # contributors y: 19 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java x: 3 # contributors y: 281 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java x: 2 # contributors y: 107 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java x: 2 # contributors y: 262 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Handover.java x: 2 # contributors y: 86 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaFetcher.java x: 2 # contributors y: 159 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaShuffleFetcher.java x: 2 # contributors y: 211 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java x: 2 # contributors y: 82 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionState.java x: 2 # contributors y: 58 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KeyedSerializationSchemaWrapper.java x: 2 # contributors y: 27 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java x: 3 # contributors y: 63 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 3 # contributors y: 179 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationKeyValueSerializationSchema.java x: 2 # contributors y: 115 lines of code
1262.0
lines of code
  min: 6.0
  average: 114.55
  25th percentile: 22.5
  median: 49.0
  75th percentile: 145.0
  max: 1262.0
0 25.0
# contributors
min: 1.0 | average: 3.73 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 4.0 | max: 25.0