apache / flink-connector-kafka
File Age & Freshness

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

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 122 files with 12,107 lines of code in files.
    • 91 files that are 366+ days old (10,223 lines of code)
    • 1 files that are 181-365 days old (8 lines of code)
    • 10 files that are 91-180 days old (268 lines of code)
    • 19 files that are 31-90 days old (1,599 lines of code)
    • 1 files that are 1-30 days old (9 lines of code)
84% | <1% | 2% | 13% | <1%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 122 files with 12,107 lines of code in files.
    • 47 files have been last changed 366+ days ago (2,579 lines of code)
    • 4 files have been last changed 181-365 days ago (646 lines of code)
    • 15 files have been last changed 91-180 days ago (815 lines of code)
    • 43 files have been last changed 31-90 days ago (5,874 lines of code)
    • 13 files have been last changed 1-30 days ago (2,193 lines of code)
21% | 5% | 6% | 48% | 18%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, md, yaml, txt, properties, py, sh, editorconfig, in, ini, gitignore, gitmodules, cmd
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java83% | <1% | 2% | 13% | 0%
py100% | 0% | 0% | 0% | 0%
in100% | 0% | 0% | 0% | 0%
xml0% | 0% | 0% | 0% | 100%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java20% | 5% | 7% | 47% | 18%
py35% | 0% | 0% | 64% | 0%
in100% | 0% | 0% | 0% | 0%
xml0% | 0% | 0% | 0% | 100%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
flink-connector-kafka83% | <1% | 2% | 13% | 0%
flink-python100% | 0% | 0% | 0% | 0%
tools0% | 0% | 0% | 0% | 100%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
flink-connector-kafka20% | 5% | 7% | 47% | 18%
flink-python37% | 0% | 0% | 62% | 0%
tools0% | 0% | 0% | 0% | 100%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
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
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
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
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
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
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
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
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
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
SpecifiedOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 73 3 2020-10-09 2023-07-11 5 5 jiangjie.qj@alibaba-inc.com 125648852+loserwang1024@use...
KafkaSourceFetcherManager.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher
 69 3 2020-10-09 2025-03-25 9 6 jiangjie.qj@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com
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
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
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
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
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
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
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
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
KafkaSourceOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 40 1 2020-10-09 2023-05-06 8 6 jiangjie.qj@alibaba-inc.com loserwang1024@gmail.com
TimestampOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 37 2 2020-10-09 2023-07-11 4 4 jiangjie.qj@alibaba-inc.com 125648852+loserwang1024@use...
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
NoStoppingOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 23 2 2020-10-09 2020-12-28 2 2 jiangjie.qj@alibaba-inc.com dev@flink.apache.org
KafkaSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber
 21 3 2020-10-09 2024-11-14 6 6 jiangjie.qj@alibaba-inc.com leszczynski.pawel@gmail.com
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
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
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
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
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
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
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
KafkaValueOnlyDeserializerWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer
 71 3 2021-03-03 2022-01-19 3 3 lindong28@gmail.com gejing@gmail.com
KafkaRecordDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer
 28 3 2021-03-03 2025-03-25 6 5 lindong28@gmail.com lvyanquan.lyq@alibaba-inc.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
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
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
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
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
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
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
KafkaSerializerWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 60 1 2021-08-11 2022-01-19 2 2 fabianpaul@ververica.com gejing@gmail.com
KafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 24 2 2021-08-11 2024-11-14 5 4 fabianpaul@ververica.com leszczynski.pawel@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-26 8 4 fabianpaul@ververica.com aleksandr.sorokoumov@gmail.com
ReducingUpsertSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 71 5 2021-08-12 2025-03-25 8 5 fabianpaul@ververica.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
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
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...
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
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
KafkaSourceOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 40 1 2020-10-09 2023-05-06 8 6 jiangjie.qj@alibaba-inc.com loserwang1024@gmail.com
TimestampOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 37 2 2020-10-09 2023-07-11 4 4 jiangjie.qj@alibaba-inc.com 125648852+loserwang1024@use...
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...
GetMetadataUpdateEvent.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source
 5 - 2023-08-09 2023-08-09 1 1 mas.chen@berkeley.edu mas.chen@berkeley.edu
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
suppressions.xml
in tools/maven
 9 - 2025-04-10 2025-04-10 1 1 arvid@apache.org arvid@apache.org
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
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
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
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
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
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
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
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
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
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
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
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
WritableBackchannel.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 6 - 2025-02-08 2025-02-10 2 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
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
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
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
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
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
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
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
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
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
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
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
TypeDatasetFacetProvider.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
KafkaDatasetFacetProvider.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
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...
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
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
setup.py
in flink-python
 95 4 2023-12-11 2025-02-27 2 2 peter.vary.apache@gmail.com 125648852+loserwang1024@use...
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
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
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
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
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
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
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
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
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
DynamicKafkaSourceSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split
 56 7 2023-08-09 2025-04-10 2 2 mas.chen@berkeley.edu arvid@apache.org
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
KafkaStream.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata
 46 6 2023-08-09 2025-04-10 2 2 mas.chen@berkeley.edu arvid@apache.org
DynamicKafkaSourceSplitSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split
 46 3 2023-08-09 2025-04-10 2 2 mas.chen@berkeley.edu arvid@apache.org
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
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
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
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
DynamicKafkaSourceSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split
 56 7 2023-08-09 2025-04-10 2 2 mas.chen@berkeley.edu arvid@apache.org
KafkaStream.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata
 46 6 2023-08-09 2025-04-10 2 2 mas.chen@berkeley.edu arvid@apache.org
DynamicKafkaSourceSplitSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split
 46 3 2023-08-09 2025-04-10 2 2 mas.chen@berkeley.edu arvid@apache.org
ClusterMetadata.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata
 40 6 2023-08-09 2025-04-10 2 2 mas.chen@berkeley.edu arvid@apache.org
MetadataUpdateEvent.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source
 36 5 2023-08-09 2025-04-10 2 2 mas.chen@berkeley.edu arvid@apache.org
StreamPatternSubscriber.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber
 27 2 2023-08-09 2025-04-10 2 2 mas.chen@berkeley.edu arvid@apache.org
suppressions.xml
in tools/maven
 9 - 2025-04-10 2025-04-10 1 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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
TwoPhaseCommittingStatefulSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 20 1 2023-03-12 2025-03-25 2 2 aleksandr.sorokoumov@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
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...
setup.py
in flink-python
 95 4 2023-12-11 2025-02-27 2 2 peter.vary.apache@gmail.com 125648852+loserwang1024@use...
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
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
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
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
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
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