diff --git a/kafka-plus-autoconfigure/pom.xml b/kafka-plus-autoconfigure/pom.xml index c845881..4219842 100644 --- a/kafka-plus-autoconfigure/pom.xml +++ b/kafka-plus-autoconfigure/pom.xml @@ -7,7 +7,7 @@ io.github.photowey kafka-plus - 3.7.0.1.2 + 3.7.0.1.3 kafka-plus-autoconfigure diff --git a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/KafkaPlusConfigure.java b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/KafkaPlusConfigure.java index 965af60..52ddc8d 100644 --- a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/KafkaPlusConfigure.java +++ b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/KafkaPlusConfigure.java @@ -32,8 +32,8 @@ * {@code KafkaPlusConfigure} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ @Import(value = { KafkaEngineSpringAwareBeanPostProcessor.class, diff --git a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/core/getter/BeanFactoryGetter.java b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/core/getter/BeanFactoryGetter.java index bfbf3a1..214ce53 100644 --- a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/core/getter/BeanFactoryGetter.java +++ b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/core/getter/BeanFactoryGetter.java @@ -24,8 +24,8 @@ * {@code BeanFactoryGetter} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ public interface BeanFactoryGetter { diff --git a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/core/property/KafkaPlusProperties.java b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/core/property/KafkaPlusProperties.java index a2739cc..56f4e4e 100644 --- a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/core/property/KafkaPlusProperties.java +++ b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/core/property/KafkaPlusProperties.java @@ -27,14 +27,14 @@ * {@code KafkaPlusProperties} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @version 1.0.0 + * @since 2024/04/06 */ public class KafkaPlusProperties implements Serializable { public static final String SPRING_KAFKA_PLUS_PROPERTY_PREFIX = "spring.kafkaplus"; - private static final long serialVersionUID = 8550578442514111961L; + private static final long serialVersionUID = 3337360099086676508L; // ---------------------------------------------------------------- @@ -44,10 +44,25 @@ public static String getPrefix() { // ---------------------------------------------------------------- + /** + * The mode of the Kafka cluster. + */ private Mode mode = new Mode(); + /** + * The bootstrap properties. + */ private Bootstrap bootstrap = new Bootstrap(); + /** + * The admin properties. + */ private Admin admin = new Admin(); + /** + * The consumer properties. + */ private Consumer consumer = new Consumer(); + /** + * The producer properties. + */ private Producer producer = new Producer(); // ---------------------------------------------------------------- @@ -81,6 +96,9 @@ public static class Bootstrap implements Serializable { private static final long serialVersionUID = 1400298527365044251L; + /** + * The {@code bootstrap.servers}. + */ private String servers = "localhost:9092"; // ---------------------------------------------------------------- @@ -104,16 +122,30 @@ public void setServers(String servers) { public static class Admin implements Serializable { - private static final long serialVersionUID = -1451532170849716654L; + private static final long serialVersionUID = -1008246731350725859L; + private List topics = new ArrayList<>(); public static class Topic implements Serializable { + private static final long serialVersionUID = -4411325091525328608L; + + /** + * The topic name. + */ private String topic; + /** + * The number of partitions. + */ private int numPartitions = 1; + /** + * The replication factor. + */ private int replicationFactor = 1; - + /** + * The replicas assignments. + */ private Map> replicasAssignments; // ---------------------------------------------------------------- @@ -194,14 +226,26 @@ public static class Consumer implements Serializable { private static final long serialVersionUID = 6473628614295963537L; + /** + * The key deserializer. + */ private String keyDeserializer = StringSerializer.class.getName(); + /** + * The value deserializer. + */ private String valueDeserializer = StringSerializer.class.getName(); - + /** + * The {@code auto.offset.reset}. + */ private Kafka.Consumer.AutoOffsetReset autoOffsetReset; - + /** + * The {@code group.id}. + */ private String groupId; + /** + * The {@code enable.auto.commit}. + */ private Boolean autoCommit; - /** * Subscribes * |- A,B,C,...,Z @@ -291,23 +335,57 @@ public static class Producer implements Serializable { private static final long serialVersionUID = 8700675817188492332L; + /** + * The key serializer. + */ private String keySerializer = StringSerializer.class.getName(); + /** + * The value serializer. + */ private String valueSerializer = StringSerializer.class.getName(); + /** + * The interceptor. + */ private String interceptor; + /** + * The partitioner. + */ private String partitioner; - + /** + * The {@code acks}. + */ private Kafka.Producer.Acks acks; - + /** + * The {@code retries}. + */ private Long retries; - + /** + * The {@code batch.size}. + */ private Long batchSize; + /** + * The {@code buffer.memory}. + */ private Long bufferMemorySize; - + /** + * The {@code linger.ms}. + */ private Long lingerMs; + /** + * The {@code max.block.ms}. + */ private Long maxBlockMs; + /** + * The {@code request.timeout.ms}. + */ private Long requestTimeoutMs; + /** + * The {@code delivery.timeout.ms}. + */ private Long deliveryTimeoutMs; - + /** + * The {@code enable.idempotence}. + */ private Boolean idempotence; // ---------------------------------------------------------------- diff --git a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/SpringKafkaEngineImpl.java b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/SpringKafkaEngineImpl.java index b27ec17..f8f8c54 100644 --- a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/SpringKafkaEngineImpl.java +++ b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/SpringKafkaEngineImpl.java @@ -31,8 +31,8 @@ * {@code SpringKafkaEngineImpl} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ public class SpringKafkaEngineImpl implements KafkaEngine, BeanFactoryAware, BeanFactoryGetter, SmartInitializingSingleton { diff --git a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/AbstractEngineAwareBeanPostProcessor.java b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/AbstractEngineAwareBeanPostProcessor.java index 28581c9..30e112f 100644 --- a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/AbstractEngineAwareBeanPostProcessor.java +++ b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/AbstractEngineAwareBeanPostProcessor.java @@ -24,8 +24,8 @@ * {@code AbstractEngineAwareBeanPostProcessor} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ public abstract class AbstractEngineAwareBeanPostProcessor implements EngineBeanPostProcessor { diff --git a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/EngineBeanPostProcessor.java b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/EngineBeanPostProcessor.java index ce42a9a..2a9baee 100644 --- a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/EngineBeanPostProcessor.java +++ b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/EngineBeanPostProcessor.java @@ -22,7 +22,7 @@ * {@code EngineBeanPostProcessor} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ public interface EngineBeanPostProcessor extends BeanPostProcessor, BeanFactoryPostProcessor {} diff --git a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/KafkaEngineSpringAware.java b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/KafkaEngineSpringAware.java index 4ef3b2a..7177404 100644 --- a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/KafkaEngineSpringAware.java +++ b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/KafkaEngineSpringAware.java @@ -22,7 +22,7 @@ * {@code KafkaEngineSpringAware} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ public interface KafkaEngineSpringAware extends KafkaEngineAware, Aware {} diff --git a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/KafkaEngineSpringAwareBeanPostProcessor.java b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/KafkaEngineSpringAwareBeanPostProcessor.java index 7557cba..064af87 100644 --- a/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/KafkaEngineSpringAwareBeanPostProcessor.java +++ b/kafka-plus-autoconfigure/src/main/java/io/github/photowey/kafka/plus/autoconfigure/engine/processor/KafkaEngineSpringAwareBeanPostProcessor.java @@ -22,8 +22,8 @@ * {@code KafkaEngineSpringAwareBeanPostProcessor} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ public class KafkaEngineSpringAwareBeanPostProcessor extends AbstractEngineAwareBeanPostProcessor { diff --git a/kafka-plus-core/pom.xml b/kafka-plus-core/pom.xml index fc1f6c9..7982613 100644 --- a/kafka-plus-core/pom.xml +++ b/kafka-plus-core/pom.xml @@ -7,7 +7,7 @@ io.github.photowey kafka-plus - 3.7.0.1.2 + 3.7.0.1.3 kafka-plus-core diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/AbstractBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/AbstractBuilder.java index b7a583b..5fcc320 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/AbstractBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/AbstractBuilder.java @@ -25,8 +25,8 @@ * {@code AbstractService} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public abstract class AbstractBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilder.java index e22a7f0..bb3ab19 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilder.java @@ -25,8 +25,8 @@ * {@code AdminBuilder} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface AdminBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilderImpl.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilderImpl.java index 2df5729..32239b8 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilderImpl.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/AdminBuilderImpl.java @@ -51,8 +51,8 @@ * * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public class AdminBuilderImpl extends AbstractBuilder implements AdminBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilder.java index d8eebbe..725d6a0 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilder.java @@ -24,8 +24,8 @@ * {@code NewTopicBuilder} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface NewTopicBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilderImpl.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilderImpl.java index f7844b3..91e82e0 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilderImpl.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/admin/topic/NewTopicBuilderImpl.java @@ -26,8 +26,8 @@ * {@code NewTopicBuilderImpl} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public class NewTopicBuilderImpl implements NewTopicBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilder.java index 93e7357..baaa9ca 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilder.java @@ -26,8 +26,8 @@ * {@code ConsumerBuilder} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface ConsumerBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilderImpl.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilderImpl.java index 4b25483..550f438 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilderImpl.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/consumer/ConsumerBuilderImpl.java @@ -29,8 +29,8 @@ * {@code ConsumerBuilderImpl} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public class ConsumerBuilderImpl extends AbstractBuilder implements ConsumerBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilder.java index ab88217..a0d4335 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilder.java @@ -31,8 +31,8 @@ * {@code ProducerBuilder} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface ProducerBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilderImpl.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilderImpl.java index 5741610..b272b5f 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilderImpl.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/producer/ProducerBuilderImpl.java @@ -28,8 +28,8 @@ * {@code ProducerBuilderImpl} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public class ProducerBuilderImpl extends AbstractBuilder implements ProducerBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilder.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilder.java index b31b0ff..9622811 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilder.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilder.java @@ -22,8 +22,8 @@ * {@code ProducerRecordBuilder} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ public interface ProducerRecordBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilderImpl.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilderImpl.java index 5dd3411..07b38b9 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilderImpl.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/builder/record/ProducerRecordBuilderImpl.java @@ -24,8 +24,8 @@ * {@code ProducerRecordBuilderImpl} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ public class ProducerRecordBuilderImpl extends AbstractBuilder implements ProducerRecordBuilder { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/producer/interceptor/AbstractProducerInterceptorAdaptor.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/producer/interceptor/AbstractProducerInterceptorAdaptor.java index 11ed817..62b144f 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/producer/interceptor/AbstractProducerInterceptorAdaptor.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/clients/producer/interceptor/AbstractProducerInterceptorAdaptor.java @@ -25,8 +25,8 @@ * {@code AbstractProducerInterceptorAdaptor} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ public abstract class AbstractProducerInterceptorAdaptor implements ProducerInterceptor { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/enums/Kafka.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/enums/Kafka.java index ac11e38..43bfd9f 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/enums/Kafka.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/enums/Kafka.java @@ -24,8 +24,8 @@ * {@code Kafka} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public enum Kafka { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/exception/KafkaPlusRuntimeException.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/exception/KafkaPlusRuntimeException.java index 224db1d..131ea17 100644 --- a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/exception/KafkaPlusRuntimeException.java +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/exception/KafkaPlusRuntimeException.java @@ -19,8 +19,8 @@ * {@code KafkaPlusRuntimeException} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public class KafkaPlusRuntimeException extends RuntimeException { diff --git a/kafka-plus-engine/pom.xml b/kafka-plus-engine/pom.xml index 7f347e9..e8f6500 100644 --- a/kafka-plus-engine/pom.xml +++ b/kafka-plus-engine/pom.xml @@ -7,7 +7,7 @@ io.github.photowey kafka-plus - 3.7.0.1.2 + 3.7.0.1.3 kafka-plus-engine diff --git a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/AbstractEngine.java b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/AbstractEngine.java index f655fab..c5e4573 100644 --- a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/AbstractEngine.java +++ b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/AbstractEngine.java @@ -24,8 +24,8 @@ * {@code AbstractEngine} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public abstract class AbstractEngine implements KafkaEngine { diff --git a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/Engine.java b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/Engine.java index 74e2b22..e18b1c0 100644 --- a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/Engine.java +++ b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/Engine.java @@ -19,8 +19,8 @@ * {@code Engine} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface Engine { } diff --git a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngine.java b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngine.java index 6192536..93c0282 100644 --- a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngine.java +++ b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngine.java @@ -23,8 +23,8 @@ * {@code KafkaEngine} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface KafkaEngine extends Engine { diff --git a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineAware.java b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineAware.java index 073291c..280a812 100644 --- a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineAware.java +++ b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineAware.java @@ -19,8 +19,8 @@ * {@code KafkaEngineAware} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface KafkaEngineAware { diff --git a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineGetter.java b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineGetter.java index cdeb4e0..209a5a9 100644 --- a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineGetter.java +++ b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineGetter.java @@ -19,8 +19,8 @@ * {@code KafkaEngineGetter} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface KafkaEngineGetter { diff --git a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineImpl.java b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineImpl.java index b2b57ee..f8503db 100644 --- a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineImpl.java +++ b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/KafkaEngineImpl.java @@ -26,8 +26,8 @@ * {@code KafkaEngineImpl} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public class KafkaEngineImpl extends AbstractEngine { diff --git a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/holder/KafkaEngineHolder.java b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/holder/KafkaEngineHolder.java index 9e6ed77..66d38fc 100644 --- a/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/holder/KafkaEngineHolder.java +++ b/kafka-plus-engine/src/main/java/io/github/photowey/kafka/plus/engine/holder/KafkaEngineHolder.java @@ -27,8 +27,8 @@ * {@code KafkaEngineHolder} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public enum KafkaEngineHolder { diff --git a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/LocalTest.java b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/LocalTest.java index 20edc69..a128c21 100644 --- a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/LocalTest.java +++ b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/LocalTest.java @@ -28,8 +28,8 @@ * {@code LocalTest} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public abstract class LocalTest { diff --git a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/model/Person.java b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/model/Person.java index e67d38c..619c317 100644 --- a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/model/Person.java +++ b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/model/Person.java @@ -23,8 +23,8 @@ * {@code Person} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ public class Person implements Serializable { diff --git a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/AdminServiceTest.java b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/AdminServiceTest.java index 8560276..080d833 100644 --- a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/AdminServiceTest.java +++ b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/AdminServiceTest.java @@ -31,8 +31,8 @@ * {@code AdminServiceTest} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ class AdminServiceTest extends LocalTest { diff --git a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/ConsumerServiceTest.java b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/ConsumerServiceTest.java index c824d94..42767fe 100644 --- a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/ConsumerServiceTest.java +++ b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/ConsumerServiceTest.java @@ -34,8 +34,8 @@ * {@code ConsumerServiceTest} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ class ConsumerServiceTest extends LocalTest { diff --git a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/ProducerServiceTest.java b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/ProducerServiceTest.java index aa5d623..0939800 100644 --- a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/ProducerServiceTest.java +++ b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/engine/runtime/service/ProducerServiceTest.java @@ -29,8 +29,8 @@ * {@code ProducerServiceTest} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ class ProducerServiceTest extends LocalTest { diff --git a/kafka-plus-jackson/pom.xml b/kafka-plus-jackson/pom.xml index 3fc5a7f..06a4678 100644 --- a/kafka-plus-jackson/pom.xml +++ b/kafka-plus-jackson/pom.xml @@ -7,7 +7,7 @@ io.github.photowey kafka-plus - 3.7.0.1.2 + 3.7.0.1.3 kafka-plus-jackson diff --git a/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/ApplyObjectMapper.java b/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/ApplyObjectMapper.java index ebd60b7..6450056 100644 --- a/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/ApplyObjectMapper.java +++ b/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/ApplyObjectMapper.java @@ -25,11 +25,16 @@ * {@code ApplyObjectMapper} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @version 1.0.0 + * @since 2024/04/06 */ public interface ApplyObjectMapper { + /** + * Init {@link ObjectMapper} instance. + * + * @return {@link ObjectMapper} + */ default ObjectMapper initObjectMapper() { ObjectMapper objectMapper = new ObjectMapper(); this.applyObjectMapper(objectMapper); @@ -37,6 +42,11 @@ default ObjectMapper initObjectMapper() { return objectMapper; } + /** + * Apply {@link ObjectMapper} + * + * @param objectMapper {@link ObjectMapper} + */ default void applyObjectMapper(ObjectMapper objectMapper) { objectMapper .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false) diff --git a/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/deserializer/JacksonDeserializer.java b/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/deserializer/JacksonDeserializer.java index 2d9d515..f42cabb 100644 --- a/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/deserializer/JacksonDeserializer.java +++ b/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/deserializer/JacksonDeserializer.java @@ -31,12 +31,18 @@ * {@code JacksonDeserializer} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @version 1.0.0 + * @since 2024/04/06 */ -public class JacksonDeserializer implements Deserializer, ApplyObjectMapper { +public class JacksonDeserializer implements Deserializer, ApplyObjectMapper { + /** + * {@link ObjectMapper} + */ private final ObjectMapper objectMapper; + /** + * The charsets. + */ private String encoding = StandardCharsets.UTF_8.name(); public JacksonDeserializer() { diff --git a/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/serializer/JacksonSerializer.java b/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/serializer/JacksonSerializer.java index bd81e54..c37b769 100644 --- a/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/serializer/JacksonSerializer.java +++ b/kafka-plus-jackson/src/main/java/io/github/photowey/kafka/plus/core/jackson/serialization/serializer/JacksonSerializer.java @@ -25,11 +25,14 @@ * {@code JacksonSerializer} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @version 1.0.0 + * @since 2024/04/06 */ public class JacksonSerializer implements Serializer, ApplyObjectMapper { + /** + * {@link ObjectMapper} + */ private final ObjectMapper objectMapper; public JacksonSerializer() { diff --git a/kafka-plus-runtime/pom.xml b/kafka-plus-runtime/pom.xml index 49420d6..ec95f4a 100644 --- a/kafka-plus-runtime/pom.xml +++ b/kafka-plus-runtime/pom.xml @@ -7,7 +7,7 @@ io.github.photowey kafka-plus - 3.7.0.1.2 + 3.7.0.1.3 kafka-plus-runtime diff --git a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/AdminService.java b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/AdminService.java index 7769090..260dbf3 100644 --- a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/AdminService.java +++ b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/AdminService.java @@ -22,8 +22,8 @@ * {@code AdminService} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface AdminService { diff --git a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/ConsumerService.java b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/ConsumerService.java index 96275e9..408de55 100644 --- a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/ConsumerService.java +++ b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/ConsumerService.java @@ -21,8 +21,8 @@ * {@code ConsumerService} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface ConsumerService { diff --git a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/ProducerService.java b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/ProducerService.java index e576dc8..eb926ec 100644 --- a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/ProducerService.java +++ b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/ProducerService.java @@ -22,8 +22,8 @@ * {@code ProducerService} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public interface ProducerService { diff --git a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/AdminServiceImpl.java b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/AdminServiceImpl.java index 7db4a8e..6564ec7 100644 --- a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/AdminServiceImpl.java +++ b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/AdminServiceImpl.java @@ -25,8 +25,8 @@ * {@code AdminServiceImpl} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public class AdminServiceImpl implements AdminService { diff --git a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/ConsumerServiceImpl.java b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/ConsumerServiceImpl.java index ebaf6db..272ba79 100644 --- a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/ConsumerServiceImpl.java +++ b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/ConsumerServiceImpl.java @@ -23,8 +23,8 @@ * {@code ConsumerServiceImpl} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public class ConsumerServiceImpl implements ConsumerService { diff --git a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/ProducerServiceImpl.java b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/ProducerServiceImpl.java index 64aceb9..9f0758b 100644 --- a/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/ProducerServiceImpl.java +++ b/kafka-plus-runtime/src/main/java/io/github/photowey/kafka/plus/runtime/service/impl/ProducerServiceImpl.java @@ -25,8 +25,8 @@ * {@code ProducerServiceImpl} * * @author photowey - * @date 2024/04/05 - * @since 1.0.0 + * @since 2024/04/05 + * @version 1.0.0 */ public class ProducerServiceImpl implements ProducerService { diff --git a/kafkaplus-spring-boot-starter/pom.xml b/kafkaplus-spring-boot-starter/pom.xml index 8744d2e..df3a7ae 100644 --- a/kafkaplus-spring-boot-starter/pom.xml +++ b/kafkaplus-spring-boot-starter/pom.xml @@ -7,7 +7,7 @@ io.github.photowey kafka-plus - 3.7.0.1.2 + 3.7.0.1.3 kafkaplus-spring-boot-starter diff --git a/kafkaplus-spring-boot-starter/src/main/java/io/github/photowey/kafka/plus/spring/boot/starter/config/KafkaPlusAutoConfigure.java b/kafkaplus-spring-boot-starter/src/main/java/io/github/photowey/kafka/plus/spring/boot/starter/config/KafkaPlusAutoConfigure.java index bf04ec8..8714650 100644 --- a/kafkaplus-spring-boot-starter/src/main/java/io/github/photowey/kafka/plus/spring/boot/starter/config/KafkaPlusAutoConfigure.java +++ b/kafkaplus-spring-boot-starter/src/main/java/io/github/photowey/kafka/plus/spring/boot/starter/config/KafkaPlusAutoConfigure.java @@ -27,8 +27,8 @@ * {@code KafkaPlusAutoConfigure} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ @Import(value = { KafkaPlusConfigure.class, diff --git a/kafkaplus-spring-boot3-starter/pom.xml b/kafkaplus-spring-boot3-starter/pom.xml index b3c34eb..9985a6e 100644 --- a/kafkaplus-spring-boot3-starter/pom.xml +++ b/kafkaplus-spring-boot3-starter/pom.xml @@ -7,7 +7,7 @@ io.github.photowey kafka-plus - 3.7.0.1.2 + 3.7.0.1.3 kafkaplus-spring-boot3-starter diff --git a/kafkaplus-spring-boot3-starter/src/main/java/io/github/photowey/kafka/plus/spring/boot3/starter/config/KafkaPlusAutoConfigure.java b/kafkaplus-spring-boot3-starter/src/main/java/io/github/photowey/kafka/plus/spring/boot3/starter/config/KafkaPlusAutoConfigure.java index f4cb4fd..ea836ac 100644 --- a/kafkaplus-spring-boot3-starter/src/main/java/io/github/photowey/kafka/plus/spring/boot3/starter/config/KafkaPlusAutoConfigure.java +++ b/kafkaplus-spring-boot3-starter/src/main/java/io/github/photowey/kafka/plus/spring/boot3/starter/config/KafkaPlusAutoConfigure.java @@ -27,8 +27,8 @@ * {@code KafkaPlusAutoConfigure} * * @author photowey - * @date 2024/04/06 - * @since 1.0.0 + * @since 2024/04/06 + * @version 1.0.0 */ @Import(value = { KafkaPlusConfigure.class, diff --git a/pom.xml b/pom.xml index a96de4f..d3bbfde 100644 --- a/pom.xml +++ b/pom.xml @@ -7,11 +7,11 @@ io.github.photowey kafka-plus - 3.7.0.1.2 + 3.7.0.1.3 pom ${project.groupId}:${project.artifactId} - An extender of Apache Kafka (the "Kafka"). + An extender of Apache Kafka (the "Kafka"), named `kafka-plus` (the "KP"). ${io.github.photowey.project.url} 2024 @@ -194,15 +194,6 @@ org.apache.maven.plugins maven-javadoc-plugin ${maven-javadoc-plugin.version} - - - - date - a - Create time - - - attach-javadocs