-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: photowey <[email protected]>
- Loading branch information
Showing
19 changed files
with
550 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,30 @@ | ||
target/ | ||
!.mvn/wrapper/maven-wrapper.jar | ||
!**/src/main/** | ||
!**/src/test/** | ||
|
||
### STS ### | ||
.apt_generated | ||
.classpath | ||
.factorypath | ||
.project | ||
.settings | ||
.springBeans | ||
.sts4-cache | ||
|
||
### IntelliJ IDEA ### | ||
.idea | ||
*.iws | ||
*.iml | ||
*.ipr | ||
|
||
### NetBeans ### | ||
/nbproject/private/ | ||
/nbbuild/ | ||
/dist/ | ||
/nbdist/ | ||
/.nb-gradle/ | ||
build/ | ||
|
||
### VS Code ### | ||
.vscode/ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,2 +1,3 @@ | ||
# kafka-plus | ||
An extender of Apache Kafka (the "Kafka"). | ||
# `kafka-plus` | ||
|
||
An extender of Apache Kafka (the "Kafka"). |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
Copyright © $today.year the original author or authors. | ||
|
||
Licensed under the Apache License, Version 2.0 (the "License"); | ||
you may not use this file except in compliance with the License. | ||
You may obtain a copy of the License at | ||
|
||
http://www.apache.org/licenses/LICENSE-2.0 | ||
|
||
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. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,27 @@ | ||
<?xml version="1.0" encoding="UTF-8"?> | ||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" | ||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> | ||
|
||
<modelVersion>4.0.0</modelVersion> | ||
|
||
<parent> | ||
<groupId>io.github.photowey</groupId> | ||
<artifactId>kafka-plus</artifactId> | ||
<version>3.7.0.1.0-SNAPSHOT</version> | ||
</parent> | ||
|
||
<artifactId>kafka-plus-core</artifactId> | ||
|
||
<name>${project.groupId}:${project.artifactId}</name> | ||
<description>The base core module of project kafka-plus</description> | ||
|
||
<!-- @formatter:off --> | ||
<properties> | ||
</properties> | ||
<!-- @formatter:on --> | ||
|
||
<dependencies> | ||
</dependencies> | ||
|
||
|
||
</project> |
26 changes: 26 additions & 0 deletions
26
...main/java/io/github/photowey/kafka/plus/core/domain/consumer/builder/ConsumerBuilder.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,26 @@ | ||
/* | ||
* Copyright © 2024 the original author or authors. | ||
* | ||
* Licensed under the Apache License, Version 2.0 (the "License"); | ||
* you may not use this file except in compliance with the License. | ||
* You may obtain a copy of the License at | ||
* | ||
* http://www.apache.org/licenses/LICENSE-2.0 | ||
* | ||
* 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. | ||
*/ | ||
package io.github.photowey.kafka.plus.core.domain.consumer.builder; | ||
|
||
/** | ||
* {@code ConsumerBuilder} | ||
* | ||
* @author photowey | ||
* @date 2024/04/05 | ||
* @since 1.0.0 | ||
*/ | ||
public interface ConsumerBuilder { | ||
} |
26 changes: 26 additions & 0 deletions
26
...main/java/io/github/photowey/kafka/plus/core/domain/producer/builder/ProducerBuilder.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,26 @@ | ||
/* | ||
* Copyright © 2024 the original author or authors. | ||
* | ||
* Licensed under the Apache License, Version 2.0 (the "License"); | ||
* you may not use this file except in compliance with the License. | ||
* You may obtain a copy of the License at | ||
* | ||
* http://www.apache.org/licenses/LICENSE-2.0 | ||
* | ||
* 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. | ||
*/ | ||
package io.github.photowey.kafka.plus.core.domain.producer.builder; | ||
|
||
/** | ||
* {@code ProducerBuilder} | ||
* | ||
* @author photowey | ||
* @date 2024/04/05 | ||
* @since 1.0.0 | ||
*/ | ||
public interface ProducerBuilder { | ||
} |
48 changes: 48 additions & 0 deletions
48
kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/enums/Kafka.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,48 @@ | ||
/* | ||
* Copyright © 2024 the original author or authors. | ||
* | ||
* Licensed under the Apache License, Version 2.0 (the "License"); | ||
* you may not use this file except in compliance with the License. | ||
* You may obtain a copy of the License at | ||
* | ||
* http://www.apache.org/licenses/LICENSE-2.0 | ||
* | ||
* 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. | ||
*/ | ||
package io.github.photowey.kafka.plus.core.enums; | ||
|
||
/** | ||
* {@code Kafka} | ||
* | ||
* @author photowey | ||
* @date 2024/04/05 | ||
* @since 1.0.0 | ||
*/ | ||
public enum Kafka { | ||
|
||
; | ||
|
||
public enum Mode { | ||
|
||
STANDALONE, | ||
CLUSTER, | ||
|
||
; | ||
|
||
} | ||
|
||
public enum Consumer { | ||
|
||
; | ||
} | ||
|
||
public enum Producer { | ||
|
||
; | ||
} | ||
|
||
} |
Empty file.
Empty file.
Empty file.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,27 @@ | ||
<?xml version="1.0" encoding="UTF-8"?> | ||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" | ||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> | ||
|
||
<modelVersion>4.0.0</modelVersion> | ||
|
||
<parent> | ||
<groupId>io.github.photowey</groupId> | ||
<artifactId>kafka-plus</artifactId> | ||
<version>3.7.0.1.0-SNAPSHOT</version> | ||
</parent> | ||
|
||
<artifactId>kafka-plus-engine</artifactId> | ||
|
||
<name>${project.groupId}:${project.artifactId}</name> | ||
<description>The engine module of project kafka-plus</description> | ||
|
||
<!-- @formatter:off --> | ||
<properties> | ||
</properties> | ||
<!-- @formatter:on --> | ||
|
||
<dependencies> | ||
</dependencies> | ||
|
||
|
||
</project> |
26 changes: 26 additions & 0 deletions
26
kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/Engine.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,26 @@ | ||
/* | ||
* Copyright © 2024 the original author or authors. | ||
* | ||
* Licensed under the Apache License, Version 2.0 (the "License"); | ||
* you may not use this file except in compliance with the License. | ||
* You may obtain a copy of the License at | ||
* | ||
* http://www.apache.org/licenses/LICENSE-2.0 | ||
* | ||
* 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. | ||
*/ | ||
package io.github.photowey.kafka.plus.engine; | ||
|
||
/** | ||
* {@code Engine} | ||
* | ||
* @author photowey | ||
* @date 2024/04/05 | ||
* @since 1.0.0 | ||
*/ | ||
public interface Engine { | ||
} |
26 changes: 26 additions & 0 deletions
26
kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngine.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,26 @@ | ||
/* | ||
* Copyright © 2024 the original author or authors. | ||
* | ||
* Licensed under the Apache License, Version 2.0 (the "License"); | ||
* you may not use this file except in compliance with the License. | ||
* You may obtain a copy of the License at | ||
* | ||
* http://www.apache.org/licenses/LICENSE-2.0 | ||
* | ||
* 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. | ||
*/ | ||
package io.github.photowey.kafka.plus.engine; | ||
|
||
/** | ||
* {@code KafkaEngine} | ||
* | ||
* @author photowey | ||
* @date 2024/04/05 | ||
* @since 1.0.0 | ||
*/ | ||
public interface KafkaEngine extends Engine { | ||
} |
Empty file.
Empty file.
Empty file.
Oops, something went wrong.