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 52ddc8d..bd5409c 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 @@ -33,7 +33,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.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 214ce53..85ffd96 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 @@ -25,7 +25,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.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 56f4e4e..fb04896 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,7 +27,7 @@ * {@code KafkaPlusProperties} * * @author photowey - * @version 1.0.0 + * @version 3.7.0.1.0 * @since 2024/04/06 */ public class KafkaPlusProperties implements Serializable { 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 f8f8c54..1fa217a 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 @@ -32,7 +32,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.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 30e112f..c9a5a64 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 @@ -25,7 +25,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.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 2a9baee..6e54340 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 @@ -23,6 +23,6 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.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 7177404..f0e673f 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 @@ -23,6 +23,6 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.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 064af87..7a6eb9a 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 @@ -23,7 +23,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.0 */ public class KafkaEngineSpringAwareBeanPostProcessor extends AbstractEngineAwareBeanPostProcessor { diff --git a/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/checker/ConfigChecker.java b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/checker/ConfigChecker.java new file mode 100644 index 0000000..0e73f94 --- /dev/null +++ b/kafka-plus-core/src/main/java/io/github/photowey/kafka/plus/core/checker/ConfigChecker.java @@ -0,0 +1,50 @@ +/* + * 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.checker; + +import io.github.photowey.kafka.plus.core.exception.KafkaPlusRuntimeException; + +import java.util.Objects; + +/** + * {@code ConfigChecker} + * + * @author photowey + * @version 3.7.0.1.4 + * @since 2024/04/14 + */ +public final class ConfigChecker { + + private ConfigChecker() {} + + /** + * check not blank + * + * @param key the key + * @param object the object + */ + public static void checkNotBlank(String key, String object) { + if (Objects.isNull(object) || object.isEmpty()) { + throw new KafkaPlusRuntimeException("%s can't be null/empty", key); + } + } + + public static void checkNotNull(String key, T object) { + if (Objects.isNull(object)) { + throw new KafkaPlusRuntimeException("%s can't be null/empty", key); + } + } +} \ No newline at end of file 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 5fcc320..c872d53 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 @@ -26,7 +26,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 bb3ab19..31a1ccb 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,15 +25,15 @@ * {@code AdminBuilder} * * @author photowey + * @version 3.7.0.1.0 * @since 2024/04/05 - * @version 1.0.0 */ public interface AdminBuilder { /** * The {@code bootstrap.servers}. * - * @param bootstrapServers the bootstrap.servers + * @param bootstrapServers the {@code bootstrap.servers}. * @return {@link AdminBuilder} */ AdminBuilder boostrapServers(String bootstrapServers); 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 32239b8..f0bbc72 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 @@ -23,6 +23,9 @@ import java.util.Properties; import java.util.function.Consumer; +import static io.github.photowey.kafka.plus.core.checker.ConfigChecker.checkNotBlank; +import static io.github.photowey.kafka.plus.core.checker.ConfigChecker.checkNotNull; + /** * {@code AdminBuilderImpl} *

@@ -51,13 +54,14 @@ * * * @author photowey + * @version 3.7.0.1.0 * @since 2024/04/05 - * @version 1.0.0 */ public class AdminBuilderImpl extends AbstractBuilder implements AdminBuilder { @Override public AdminBuilder boostrapServers(String bootstrapServers) { + checkNotBlank("bootstrap.servers", bootstrapServers); super.initConfigsIfNecessary(); super.configs.put(Kafka.Bootstrap.Server.ADDRESS.value(), bootstrapServers); @@ -68,6 +72,7 @@ public AdminBuilder boostrapServers(String bootstrapServers) { @Override public AdminBuilder props(Properties props) { + checkNotNull("props", props); super.props = props; return this; @@ -75,6 +80,7 @@ public AdminBuilder props(Properties props) { @Override public AdminBuilder configs(Map configs) { + checkNotNull("configs", configs); super.configs = configs; return this; @@ -84,6 +90,7 @@ public AdminBuilder configs(Map configs) { @Override public AdminBuilder checkProps(Consumer fx) { + checkNotNull("checkProps.fx", fx); fx.accept(super.props); return this; @@ -91,6 +98,7 @@ public AdminBuilder checkProps(Consumer fx) { @Override public AdminBuilder checkConfigs(Consumer> fx) { + checkNotNull("checkConfigs.fx", fx); fx.accept(super.configs); return this; 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 725d6a0..43e7c26 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 @@ -25,7 +25,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 91e82e0..4383877 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 @@ -27,7 +27,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 62b294b..855321b 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 @@ -27,7 +27,7 @@ * {@code ConsumerBuilder} * * @author photowey - * @version 1.0.0 + * @version 3.7.0.1.0 * @since 2024/04/05 */ public interface ConsumerBuilder { @@ -35,7 +35,7 @@ public interface ConsumerBuilder { /** * The {@code bootstrap.servers}. * - * @param bootstrapServers the bootstrap.servers + * @param bootstrapServers the {@code bootstrap.servers}. * @return {@link ConsumerBuilder} */ ConsumerBuilder boostrapServers(String bootstrapServers); 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 394946b..e8d7b3b 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 @@ -25,11 +25,14 @@ import java.util.Properties; import java.util.function.Consumer; +import static io.github.photowey.kafka.plus.core.checker.ConfigChecker.checkNotBlank; +import static io.github.photowey.kafka.plus.core.checker.ConfigChecker.checkNotNull; + /** * {@code ConsumerBuilderImpl} * * @author photowey - * @version 1.0.0 + * @version 3.7.0.1.0 * @since 2024/04/05 */ public class ConsumerBuilderImpl extends AbstractBuilder implements ConsumerBuilder { @@ -41,6 +44,7 @@ public class ConsumerBuilderImpl extends AbstractBuilder implements ConsumerBuil @Override public ConsumerBuilder boostrapServers(String bootstrapServers) { + checkNotBlank("bootstrap.servers", bootstrapServers); super.initConfigsIfNecessary(); super.configs.put(Kafka.Bootstrap.Server.ADDRESS.value(), bootstrapServers); @@ -49,6 +53,7 @@ public ConsumerBuilder boostrapServers(String bootstrapServers) { @Override public ConsumerBuilder keyDeserializer(String keyDeserializer) { + checkNotBlank("keyDeserializer", keyDeserializer); super.initConfigsIfNecessary(); super.configs.put(Kafka.Consumer.KEY_DESERIALIZER.key(), keyDeserializer); @@ -57,6 +62,7 @@ public ConsumerBuilder keyDeserializer(String keyDeserializer) { @Override public ConsumerBuilder valueDeserializer(String valueDeserializer) { + checkNotBlank("valueDeserializer", valueDeserializer); super.initConfigsIfNecessary(); super.configs.put(Kafka.Consumer.VALUE_DESERIALIZER.key(), valueDeserializer); @@ -65,6 +71,7 @@ public ConsumerBuilder valueDeserializer(String valueDeserializer) { @Override public ConsumerBuilder autoOffsetReset(Kafka.Consumer.AutoOffsetReset offsetReset) { + checkNotNull("offsetReset", offsetReset); super.initConfigsIfNecessary(); super.configs.put(Kafka.Consumer.AUTO_OFFSET_RESET.key(), offsetReset.value()); @@ -73,6 +80,7 @@ public ConsumerBuilder autoOffsetReset(Kafka.Consumer.AutoOffsetReset offsetRese @Override public ConsumerBuilder groupId(String groupId) { + checkNotBlank("groupId", groupId); super.initConfigsIfNecessary(); super.configs.put(Kafka.Consumer.GROUP_ID.key(), groupId); @@ -83,6 +91,7 @@ public ConsumerBuilder groupId(String groupId) { @Override public ConsumerBuilder isolation(Kafka.Consumer.Isolation isolation) { + checkNotNull("isolation.level", isolation); super.initConfigsIfNecessary(); super.configs.put(Kafka.Consumer.ISOLATION_LEVEL.key(), isolation.value()); @@ -91,6 +100,7 @@ public ConsumerBuilder isolation(Kafka.Consumer.Isolation isolation) { @Override public ConsumerBuilder instanceId(String instanceId) { + checkNotBlank("instanceId", instanceId); super.initConfigsIfNecessary(); super.configs.put(Kafka.Consumer.GROUP_INSTANCE_ID.key(), instanceId); @@ -99,6 +109,7 @@ public ConsumerBuilder instanceId(String instanceId) { @Override public ConsumerBuilder strategy(String strategy) { + checkNotBlank("partition.assignment.strategy", strategy); super.initConfigsIfNecessary(); super.configs.put(Kafka.Consumer.PARTITION_ASSIGNMENT_STRATEGY.key(), strategy); @@ -119,6 +130,7 @@ public ConsumerBuilder autoCommit(boolean enabled) { @Override public ConsumerBuilder keyDeserializer(Deserializer keyDeserializer) { + checkNotNull("keyDeserializer", keyDeserializer); this.keyDeserializer = keyDeserializer; return this; @@ -126,6 +138,7 @@ public ConsumerBuilder keyDeserializer(Deserializer keyDeserializer) { @Override public ConsumerBuilder valueDeserializer(Deserializer valueDeserializer) { + checkNotNull("valueDeserializer", valueDeserializer); this.valueDeserializer = valueDeserializer; return this; @@ -135,6 +148,7 @@ public ConsumerBuilder valueDeserializer(Deserializer valueDeserializer) @Override public ConsumerBuilder props(Properties props) { + checkNotNull("props", props); super.props = props; return this; @@ -142,6 +156,7 @@ public ConsumerBuilder props(Properties props) { @Override public ConsumerBuilder configs(Map configs) { + checkNotNull("configs", configs); super.configs = configs; return this; @@ -151,6 +166,7 @@ public ConsumerBuilder configs(Map configs) { @Override public ConsumerBuilder checkProps(Consumer fx) { + checkNotNull("checkProps.fx", fx); fx.accept(super.props); return this; @@ -158,6 +174,7 @@ public ConsumerBuilder checkProps(Consumer fx) { @Override public ConsumerBuilder checkConfigs(Consumer> fx) { + checkNotNull("checkConfigs.fx", fx); fx.accept(super.configs); return this; @@ -167,6 +184,7 @@ public ConsumerBuilder checkConfigs(Consumer> fx) { @Override public ConsumerBuilder subscribe(Collection topics) { + checkNotNull("subscribe.topics", topics); this.topics = topics; return this; 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 a0d4335..3c4f27d 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,15 +31,15 @@ * {@code ProducerBuilder} * * @author photowey + * @version 3.7.0.1.0 * @since 2024/04/05 - * @version 1.0.0 */ public interface ProducerBuilder { /** * The {@code bootstrap.servers}. * - * @param bootstrapServers the bootstrap.servers + * @param bootstrapServers the {@code bootstrap.servers}. * @return {@link ProducerBuilder} */ ProducerBuilder boostrapServers(String bootstrapServers); 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 b272b5f..8c6d500 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 @@ -24,12 +24,15 @@ import java.util.Properties; import java.util.function.Consumer; +import static io.github.photowey.kafka.plus.core.checker.ConfigChecker.checkNotBlank; +import static io.github.photowey.kafka.plus.core.checker.ConfigChecker.checkNotNull; + /** * {@code ProducerBuilderImpl} * * @author photowey + * @version 3.7.0.1.0 * @since 2024/04/05 - * @version 1.0.0 */ public class ProducerBuilderImpl extends AbstractBuilder implements ProducerBuilder { @@ -38,6 +41,7 @@ public class ProducerBuilderImpl extends AbstractBuilder implements ProducerBuil @Override public ProducerBuilder boostrapServers(String bootstrapServers) { + checkNotBlank("bootstrap.servers", bootstrapServers); super.initConfigsIfNecessary(); super.configs.put(Kafka.Bootstrap.Server.ADDRESS.value(), bootstrapServers); @@ -48,6 +52,7 @@ public ProducerBuilder boostrapServers(String bootstrapServers) { @Override public ProducerBuilder keySerializer(Serializer keySerializer) { + checkNotNull("keySerializer", keySerializer); this.keySerializer = keySerializer; return this; @@ -55,6 +60,7 @@ public ProducerBuilder keySerializer(Serializer keySerializer) { @Override public ProducerBuilder valueSerializer(Serializer valueSerializer) { + checkNotNull("valueSerializer", valueSerializer); this.valueSerializer = valueSerializer; return this; @@ -62,6 +68,7 @@ public ProducerBuilder valueSerializer(Serializer valueSerializer) { @Override public ProducerBuilder keySerializer(String keySerializer) { + checkNotBlank("keySerializer", keySerializer); super.initConfigsIfNecessary(); super.configs.put(Kafka.Producer.KEY_SERIALIZER.key(), keySerializer); @@ -70,6 +77,7 @@ public ProducerBuilder keySerializer(String keySerializer) { @Override public ProducerBuilder valueSerializer(String valueSerializer) { + checkNotBlank("valueSerializer", valueSerializer); super.initConfigsIfNecessary(); super.configs.put(Kafka.Producer.VALUE_DESERIALIZER.key(), valueSerializer); @@ -80,6 +88,7 @@ public ProducerBuilder valueSerializer(String valueSerializer) { @Override public ProducerBuilder props(Properties props) { + checkNotNull("props", props); super.props = props; return this; @@ -87,6 +96,7 @@ public ProducerBuilder props(Properties props) { @Override public ProducerBuilder configs(Map configs) { + checkNotNull("configs", configs); super.configs = configs; return this; @@ -96,6 +106,7 @@ public ProducerBuilder configs(Map configs) { @Override public ProducerBuilder enhanceProps(Consumer fx) { + checkNotNull("enhanceProps.fx", fx); if (null != super.props) { fx.accept(super.props); } @@ -105,6 +116,7 @@ public ProducerBuilder enhanceProps(Consumer fx) { @Override public ProducerBuilder enhanceConfigs(Consumer> fx) { + checkNotNull("enhanceConfigs.fx", fx); if (null != super.configs) { fx.accept(super.configs); } @@ -116,6 +128,7 @@ public ProducerBuilder enhanceConfigs(Consumer> fx) { @Override public ProducerBuilder interceptor(String interceptor) { + checkNotBlank("interceptor", interceptor); super.initConfigsIfNecessary(); super.configs.put(Kafka.Producer.INTERCEPTOR.key(), interceptor); @@ -124,6 +137,7 @@ public ProducerBuilder interceptor(String interceptor) { @Override public ProducerBuilder partitioner(String partitioner) { + checkNotBlank("partitioner", partitioner); super.initConfigsIfNecessary(); super.configs.put(Kafka.Producer.PARTITIONER.key(), partitioner); @@ -134,6 +148,7 @@ public ProducerBuilder partitioner(String partitioner) { @Override public ProducerBuilder acks(Kafka.Producer.Acks acks) { + checkNotNull("acks", acks); super.initConfigsIfNecessary(); super.configs.put(Kafka.Producer.ACKS.key(), acks.value()); @@ -214,6 +229,7 @@ public ProducerBuilder idempotence(boolean enabled) { @Override public ProducerBuilder checkProps(Consumer fx) { + checkNotNull("checkProps.fx", fx); fx.accept(super.props); return this; @@ -221,6 +237,7 @@ public ProducerBuilder checkProps(Consumer fx) { @Override public ProducerBuilder checkConfigs(Consumer> fx) { + checkNotNull("checkConfigs.fx", fx); fx.accept(super.configs); return this; 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 9622811..f6d9acb 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 @@ -23,7 +23,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.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 07b38b9..c2b9fdb 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 @@ -25,7 +25,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.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 62b144f..b9e54c1 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 @@ -26,7 +26,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.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 aafce3a..50ff33a 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 @@ -25,7 +25,7 @@ * {@code Kafka} * * @author photowey - * @version 1.0.0 + * @version 3.7.0.1.0 * @since 2024/04/05 */ 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 131ea17..ad09318 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 @@ -20,7 +20,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.0 */ public class KafkaPlusRuntimeException extends RuntimeException { 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 c5e4573..fd8cdbc 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 @@ -25,7 +25,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 e18b1c0..fa6fd4d 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 @@ -20,7 +20,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 93c0282..3bdd9b0 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 @@ -24,7 +24,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 280a812..9139c57 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 @@ -20,7 +20,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 209a5a9..909243a 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 @@ -20,7 +20,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 f8503db..02bcf32 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 @@ -27,7 +27,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 66d38fc..753e65e 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 @@ -28,7 +28,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.0 */ public enum KafkaEngineHolder { diff --git a/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/core/checker/ConfigCheckerTest.java b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/core/checker/ConfigCheckerTest.java new file mode 100644 index 0000000..d18e408 --- /dev/null +++ b/kafka-plus-engine/src/test/java/io/github/photowey/kafka/plus/core/checker/ConfigCheckerTest.java @@ -0,0 +1,56 @@ +/* + * 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.checker; + +import io.github.photowey.kafka.plus.core.exception.KafkaPlusRuntimeException; +import io.github.photowey.kafka.plus.engine.model.Person; +import org.junit.jupiter.api.Assertions; +import org.junit.jupiter.api.Test; + +import java.util.ArrayList; + +/** + * {@code ConfigCheckerTest} + * + * @author photowey + * @version 1.0.0 + * @since 2024/04/14 + */ +class ConfigCheckerTest { + + @Test + void testCheckNotBlank() { + ConfigChecker.checkNotBlank("x", "x"); + Assertions.assertThrows(KafkaPlusRuntimeException.class, () -> { + ConfigChecker.checkNotBlank("x", null); + }); + + Assertions.assertThrows(KafkaPlusRuntimeException.class, () -> { + ConfigChecker.checkNotBlank("x", ""); + }); + } + + @Test + void testCheckNotNull() { + ConfigChecker.checkNotNull("x", "x"); + ConfigChecker.checkNotNull("x", new Person()); + ConfigChecker.checkNotNull("x", new ArrayList<>()); + + Assertions.assertThrows(KafkaPlusRuntimeException.class, () -> { + ConfigChecker.checkNotNull("x", null); + }); + } +} \ No newline at end of file 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 a128c21..61e35b8 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 @@ -29,7 +29,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 619c317..dfc77e9 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 @@ -24,7 +24,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.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 080d833..a3e1fc0 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 @@ -32,7 +32,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 42767fe..5672880 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 @@ -35,7 +35,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 0939800..de513b6 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 @@ -30,7 +30,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.0 */ class ProducerServiceTest extends LocalTest { 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 6450056..c5c3d83 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,7 +25,7 @@ * {@code ApplyObjectMapper} * * @author photowey - * @version 1.0.0 + * @version 3.7.0.1.0 * @since 2024/04/06 */ public interface ApplyObjectMapper { 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 f42cabb..8a7d5db 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,7 +31,7 @@ * {@code JacksonDeserializer} * * @author photowey - * @version 1.0.0 + * @version 3.7.0.1.0 * @since 2024/04/06 */ public class JacksonDeserializer implements Deserializer, ApplyObjectMapper { 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 c37b769..b858522 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,7 +25,7 @@ * {@code JacksonSerializer} * * @author photowey - * @version 1.0.0 + * @version 3.7.0.1.0 * @since 2024/04/06 */ public class JacksonSerializer implements Serializer, ApplyObjectMapper { 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 260dbf3..5816ee2 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 @@ -23,7 +23,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 408de55..8fbb40b 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 @@ -22,7 +22,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 eb926ec..06d4317 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 @@ -23,7 +23,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 6564ec7..30dedce 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 @@ -26,7 +26,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 272ba79..8021400 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 @@ -24,7 +24,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.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 9f0758b..2b0c2db 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 @@ -26,7 +26,7 @@ * * @author photowey * @since 2024/04/05 - * @version 1.0.0 + * @version 3.7.0.1.0 */ public class ProducerServiceImpl implements ProducerService { 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 8714650..fa237cc 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 @@ -28,7 +28,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.0 */ @Import(value = { KafkaPlusConfigure.class, 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 ea836ac..43c0e5b 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 @@ -28,7 +28,7 @@ * * @author photowey * @since 2024/04/06 - * @version 1.0.0 + * @version 3.7.0.1.0 */ @Import(value = { KafkaPlusConfigure.class,