Skip to content

Commit a6e9aed

Browse files
committed
chore: cleanup quality
1 parent 52ccf3e commit a6e9aed

File tree

364 files changed

+1294
-1353
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

364 files changed

+1294
-1353
lines changed
File renamed without changes.
File renamed without changes.

README.md

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -13,21 +13,21 @@
1313
[![Coverage](https://sonarcloud.io/api/project_badges/measure?project=streamthoughts_kafka-connect-file-pulse&metric=coverage)](https://sonarcloud.io/summary/new_code?id=streamthoughts_kafka-connect-file-pulse)
1414

1515
<p align="center">
16-
<img width="400" height="400" src="https://github.com/streamthoughts/kafka-connect-file-pulse/raw/master/assets/logo.png">
16+
<img width="400" height="400" src="https://github.com/streamthoughts/kafka-connect-file-pulse/raw/master/assets/logo.png">
1717
</p>
1818

19-
**Connect FilePulse** is a multipurpose, scalable and reliable,
19+
**Connect FilePulse** is a multipurpose, scalable and reliable,
2020
[Kafka Connector](http://kafka.apache.org/documentation.html#connect) that makes it easy to parse, transform and stream any file, in any format, into Apache Kafka™.
21-
It provides capabilities for reading files from: **local-filesystem**, **Amazon S3**, **Azure Storage** and **Google Cloud Storage**.
21+
It provides capabilities for reading files from: **local-filesystem**, **Amazon S3**, **Azure Storage** and **Google Cloud Storage**.
2222

2323
## Motivation
2424

2525
In organizations, data is frequently exported, shared and integrated from legacy systems through the use of
2626
files in a wide variety of formats (e.g. CSV, XML, JSON, Avro, etc.). Dealing with all of these formats can
2727
quickly become a real challenge for enterprise that usually end up with a complex and hard
2828
to maintain data integration mess.
29-
30-
29+
30+
3131
A modern approach consists in building a scalable data streaming platform as a central nervous
3232
system to decouple applications from each other. **Apache Kafka™** is one of the most widely
3333
used technologies to build such a system. The Apache Kafka project packs with Kafka Connect a distributed,
@@ -54,7 +54,7 @@ Connect FilePulse provides a set of built-in features for streaming files from m
5454

5555
## 🙏 Show your support
5656

57-
You think this project can help you or your team to ingest data into Kafka ?
57+
You think this project can help you or your team to ingest data into Kafka ?
5858
Please 🌟 this repository to support us!
5959

6060
## 🏁 How to get started ?
@@ -87,4 +87,4 @@ Licensed to the Apache Software Foundation (ASF) under one or more contributor l
8787

8888
[http://www.apache.org/licenses/LICENSE-2.0](http://www.apache.org/licenses/LICENSE-2.0)
8989

90-
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License
90+
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License

checkstyle/checkstyle.xml

Lines changed: 38 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -17,58 +17,44 @@
1717
~ See the License for the specific language governing permissions and
1818
~ limitations under the License.
1919
-->
20-
2120
<!DOCTYPE module PUBLIC
22-
"-//Checkstyle//DTD Checkstyle Configuration 1.2//EN"
23-
"https://checkstyle.org/dtds/configuration_1_2.dtd">
21+
"-//Checkstyle//DTD Checkstyle Configuration 1.3//EN"
22+
"https://checkstyle.org/dtds/configuration_1_3.dtd">
23+
2424
<module name="Checker">
25-
<!--
26-
/*
27-
* Licensed to the Apache Software Foundation (ASF) under one or more
28-
* contributor license agreements. See the NOTICE file distributed with
29-
* this work for additional information regarding copyright ownership.
30-
* The ASF licenses this file to You under the Apache License, Version 2.0
31-
* (the "License"); you may not use this file except in compliance with
32-
* the License. You may obtain a copy of the License at
33-
*
34-
* http://www.apache.org/licenses/LICENSE-2.0
35-
*
36-
* Unless required by applicable law or agreed to in writing, software
37-
* distributed under the License is distributed on an "AS IS" BASIS,
38-
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
39-
* See the License for the specific language governing permissions and
40-
* limitations under the License.
41-
*/
42-
-->
4325
<property name="localeLanguage" value="en"/>
26+
<property name="charset" value="UTF-8"/>
4427

28+
<property name="fileExtensions" value="java, properties, xml"/>
29+
<!-- https://checkstyle.org/config_filters.html#SuppressionFilter -->
30+
<module name="SuppressionFilter">
31+
<property name="file" value="${basedir}/checkstyle/suppressions.xml"/>
32+
</module>
4533
<module name="Header">
46-
<property name="headerFile" value="${basedir}/checkstyle/apache-header" />
34+
<property name="headerFile" value="${basedir}/license-header" />
4735
<property name="ignoreLines" value="1, 2"/>
4836
</module>
4937

38+
<module name="LineLength">
39+
<property name="fileExtensions" value="java"/>
40+
<property name="max" value="120"/>
41+
<property name="ignorePattern" value="^package.*|^import.*|a href|href|http://|https://|ftp://"/>
42+
</module>
43+
5044
<module name="TreeWalker">
51-
<!-- Imports -->
5245
<module name="UnusedImports">
5346
<property name="processJavadoc" value="true" />
5447
</module>
5548
<module name="RedundantImport"/>
5649
<module name="IllegalImport" />
5750
<module name="AvoidStarImport"/>
58-
59-
<!-- Code General Quality / Style -->
6051
<module name="OneStatementPerLine"/>
61-
<module name="UnnecessaryParentheses" />
52+
<module name="MultipleVariableDeclarations"/>
6253
<module name="MethodLength"/>
63-
<module name="LineLength">
64-
<property name="max" value="120"/>
65-
</module>
6654
<module name="EqualsHashCode"/>
6755
<module name="ParameterNumber"/>
6856
<module name="SimplifyBooleanExpression"/>
6957
<module name="SimplifyBooleanReturn"/>
70-
71-
<!-- Code Complexity -->
7258
<module name="CyclomaticComplexity">
7359
<!-- default is 10 -->
7460
<property name="max" value="15"/>
@@ -89,9 +75,26 @@
8975
<!-- default is 3 -->
9076
<property name="max" value="4"/>
9177
</module>
92-
</module>
93-
94-
<module name="SuppressionFilter">
95-
<property name="file" value="${basedir}/checkstyle/suppressions.xml"/>
78+
<module name="MemberName">
79+
<property name="format" value="^[a-z][a-z0-9][a-zA-Z0-9]*$"/>
80+
<message key="name.invalidPattern"
81+
value="Member name ''{0}'' must match pattern ''{1}''."/>
82+
</module>
83+
<module name="LocalVariableName">
84+
<property name="format" value="^[a-z]([a-z0-9][a-zA-Z0-9]*)?$"/>
85+
<message key="name.invalidPattern"
86+
value="Local variable name ''{0}'' must match pattern ''{1}''."/>
87+
</module>
88+
<module name="PackageName">
89+
<property name="format" value="^[a-z]+(\.[a-z][a-z0-9]*)*$"/>
90+
<message key="name.invalidPattern"
91+
value="Package name ''{0}'' must match pattern ''{1}''."/>
92+
</module>
93+
<module name="InterfaceTypeParameterName">
94+
<property name="format" value="(^[A-Z][0-9]?)$|([A-Z][a-zA-Z0-9]*[T]$)"/>
95+
<message key="name.invalidPattern"
96+
value="Interface type name ''{0}'' must match pattern ''{1}''."/>
97+
</module>
98+
<module name="NoFinalizer"/>
9699
</module>
97100
</module>

connect-file-pulse-api/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@
5050
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
5151
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
5252
<checkstyle.config.location>${project.parent.basedir}</checkstyle.config.location>
53+
<license.header.file>${project.parent.basedir}/license-header</license.header.file>
5354
</properties>
5455

5556
<build>

connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/clean/BatchFileCleanupPolicy.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919
package io.streamthoughts.kafka.connect.filepulse.clean;
2020

2121
import io.streamthoughts.kafka.connect.filepulse.source.FileObject;
22-
2322
import java.util.List;
2423

2524
/**

connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/clean/DelegateBatchFileCleanupPolicy.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020

2121
import io.streamthoughts.kafka.connect.filepulse.fs.Storage;
2222
import io.streamthoughts.kafka.connect.filepulse.source.FileObject;
23-
2423
import java.util.List;
2524
import java.util.Map;
2625
import java.util.Objects;

connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/clean/FileCleanupPolicy.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020

2121
import io.streamthoughts.kafka.connect.filepulse.source.FileObject;
2222
import io.streamthoughts.kafka.connect.filepulse.source.FileObjectStatus;
23-
2423
import java.util.Map;
2524

2625
/**

connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/clean/FileCleanupPolicyResultSet.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020

2121
import io.streamthoughts.kafka.connect.filepulse.internal.KeyValuePair;
2222
import io.streamthoughts.kafka.connect.filepulse.source.FileObject;
23-
2423
import java.util.Collection;
2524
import java.util.LinkedList;
2625
import java.util.Objects;

connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/clean/GenericFileCleanupPolicy.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,8 @@
1919
package io.streamthoughts.kafka.connect.filepulse.clean;
2020

2121
import io.streamthoughts.kafka.connect.filepulse.fs.StorageAware;
22-
import org.apache.kafka.common.Configurable;
23-
2422
import java.util.Map;
23+
import org.apache.kafka.common.Configurable;
2524

2625
/**
2726
* Top level interface for cleanup policies.

0 commit comments

Comments
 (0)