You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2022/12/02 05:26:52 UTC
[pulsar-client-reactive] branch main updated: Stop require author tag (#77)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git
The following commit(s) were added to refs/heads/main by this push:
new 554ab61 Stop require author tag (#77)
554ab61 is described below
commit 554ab61d06bb7e2972c212744ddb1413b1587ce5
Author: tison <wa...@gmail.com>
AuthorDate: Fri Dec 2 13:26:47 2022 +0800
Stop require author tag (#77)
* Overwrite JavadocTypeCheck config
Signed-off-by: tison <wa...@gmail.com>
* Remove @author tags
Signed-off-by: tison <wa...@gmail.com>
* Add root module
Signed-off-by: tison <wa...@gmail.com>
* Exclude JavadocTypeCheck for overwrite
Signed-off-by: tison <wa...@gmail.com>
* ban MissingJavadocType
Signed-off-by: tison <wa...@gmail.com>
* Remove @author tags
Signed-off-by: tison <wa...@gmail.com>
* ban @author tag
Signed-off-by: tison <wa...@gmail.com>
* test classes should not be public, so not required javadoc
Signed-off-by: tison <wa...@gmail.com>
Signed-off-by: tison <wa...@gmail.com>
---
CONTRIBUTING.adoc | 3 +--
.../pulsar-client-reactive.codestyle-conventions.gradle | 2 +-
checkstyle/checkstyle.xml | 11 +++++++++--
gradle/libs.versions.toml | 2 +-
.../client/adapter/ReactiveMessageConsumerE2ETest.java | 2 +-
.../client/adapter/ReactiveMessagePipelineE2ETest.java | 2 +-
.../reactive/client/adapter/ReactiveMessageReaderE2ETest.java | 2 +-
.../reactive/client/adapter/ReactiveMessageSenderE2ETest.java | 2 +-
.../reactive/client/adapter/SingletonPulsarContainer.java | 6 +++---
.../client/adapter/AdaptedReactivePulsarClientFactory.java | 3 ---
.../client/adapter/DefaultMessageGroupingFunction.java | 2 --
.../pulsar/reactive/client/adapter/ProducerCacheProvider.java | 2 --
.../reactive/client/adapter/ProducerCacheProviderFactory.java | 2 --
.../client/internal/adapter/AdapterImplementationFactory.java | 3 ---
.../adapter/ConcurrentHashMapProducerCacheProvider.java | 2 --
.../reactive/client/internal/adapter/PulsarFutureAdapter.java | 2 --
.../apache/pulsar/reactive/client/api/EndOfStreamAction.java | 2 --
.../client/api/ImmutableReactiveMessageConsumerSpec.java | 2 --
.../client/api/ImmutableReactiveMessageReaderSpec.java | 2 --
.../client/api/ImmutableReactiveMessageSenderSpec.java | 2 --
.../apache/pulsar/reactive/client/api/InstantStartAtSpec.java | 2 --
.../pulsar/reactive/client/api/MessageGroupingFunction.java | 2 --
.../pulsar/reactive/client/api/MessageIdStartAtSpec.java | 2 --
.../org/apache/pulsar/reactive/client/api/MessageResult.java | 2 --
.../org/apache/pulsar/reactive/client/api/MessageSpec.java | 2 --
.../apache/pulsar/reactive/client/api/MessageSpecBuilder.java | 1 -
.../client/api/MutableReactiveMessageConsumerSpec.java | 3 ---
.../reactive/client/api/MutableReactiveMessageReaderSpec.java | 3 ---
.../reactive/client/api/MutableReactiveMessageSenderSpec.java | 3 ---
.../pulsar/reactive/client/api/ReactiveMessageConsumer.java | 2 --
.../reactive/client/api/ReactiveMessageConsumerBuilder.java | 2 --
.../reactive/client/api/ReactiveMessageConsumerSpec.java | 3 ---
.../pulsar/reactive/client/api/ReactiveMessagePipeline.java | 3 ---
.../reactive/client/api/ReactiveMessagePipelineBuilder.java | 2 --
.../pulsar/reactive/client/api/ReactiveMessageReader.java | 2 --
.../reactive/client/api/ReactiveMessageReaderBuilder.java | 2 --
.../pulsar/reactive/client/api/ReactiveMessageReaderSpec.java | 3 ---
.../pulsar/reactive/client/api/ReactiveMessageSender.java | 2 --
.../reactive/client/api/ReactiveMessageSenderBuilder.java | 2 --
.../reactive/client/api/ReactiveMessageSenderCache.java | 2 --
.../pulsar/reactive/client/api/ReactiveMessageSenderSpec.java | 3 ---
.../pulsar/reactive/client/api/ReactivePulsarClient.java | 2 --
.../org/apache/pulsar/reactive/client/api/StartAtSpec.java | 2 --
.../client/internal/api/ApiImplementationFactory.java | 3 ---
.../reactive/client/internal/api/DefaultMessageResult.java | 1 -
.../reactive/client/internal/api/DefaultMessageSpec.java | 1 -
.../client/internal/api/DefaultMessageSpecBuilder.java | 1 -
.../reactive/client/internal/api/EmptyMessageResult.java | 2 --
.../client/internal/api/GroupOrderedMessageProcessors.java | 2 --
.../pulsar/reactive/client/internal/api/InflightLimiter.java | 2 --
.../reactive/client/internal/api/InternalMessageSpec.java | 2 --
.../reactive/client/internal/api/PublisherTransformer.java | 2 --
.../reactive/client/internal/api/ValueOnlyMessageSpec.java | 1 -
.../apache/pulsar/reactive/client/api/MessageResultTest.java | 2 --
.../apache/pulsar/reactive/client/api/MessageSpecTest.java | 2 --
.../client/api/ReactiveMessageConsumerBuilderTest.java | 2 --
.../reactive/client/api/ReactiveMessageReaderBuilderTest.java | 2 --
.../reactive/client/api/ReactiveMessageSenderBuilderTest.java | 2 --
.../reactive/client/jackson/PulsarReactiveClientModule.java | 2 --
.../client/producercache/CaffeineProducerCacheProvider.java | 2 --
.../producercache/CaffeineProducerCacheProviderFactory.java | 2 --
61 files changed, 19 insertions(+), 122 deletions(-)
diff --git a/CONTRIBUTING.adoc b/CONTRIBUTING.adoc
index 3d6fb8a..c525663 100755
--- a/CONTRIBUTING.adoc
+++ b/CONTRIBUTING.adoc
@@ -25,9 +25,8 @@ added after the original pull request but before a merge.
You can also install the https://github.com/spring-io/spring-javaformat/#intellij-idea[Spring JavaFormat IntelliJ Plugin] or format the code from the Gradle build by running `./gradlew format`.
// NYI: Note that if you have format violations in `buildSrc`, you can fix them by running `./gradlew -p buildSrc format` from the project root directory.
* The build includes Checkstyle rules for many of our code conventions. Run `./gradlew checkstyleMain checkstyleTest` if you want to check your changes are compliant.
-* Make sure all new `.java` files have a Javadoc class comment with at least an `@author` tag identifying you, and preferably at least a paragraph on what the class is for.
+* Make sure all new `.java` files have a Javadoc class comment, and preferably at least a paragraph on what the class is for.
* Add the ASF license header comment to all new `.java` files (copy from existing files in the project).
-* Add yourself as an `@author` to the `.java` files that you modify substantially (more than cosmetic changes).
* Add some Javadocs.
* A few unit tests would help a lot as well -- someone has to do it.
* Verification tasks, including tests and Checkstyle, can be executed by running `./gradlew check` from the project root.
diff --git a/buildSrc/src/main/groovy/pulsar-client-reactive.codestyle-conventions.gradle b/buildSrc/src/main/groovy/pulsar-client-reactive.codestyle-conventions.gradle
index fee209b..f82ac06 100644
--- a/buildSrc/src/main/groovy/pulsar-client-reactive.codestyle-conventions.gradle
+++ b/buildSrc/src/main/groovy/pulsar-client-reactive.codestyle-conventions.gradle
@@ -35,4 +35,4 @@ license {
ext {
year = Year.now().getValue().toString()
}
-}
\ No newline at end of file
+}
diff --git a/checkstyle/checkstyle.xml b/checkstyle/checkstyle.xml
index 7534cfd..dcbb317 100644
--- a/checkstyle/checkstyle.xml
+++ b/checkstyle/checkstyle.xml
@@ -2,9 +2,16 @@
<!DOCTYPE module PUBLIC
"-//Checkstyle//DTD Checkstyle Configuration 1.3//EN"
"https://checkstyle.org/dtds/configuration_1_3.dtd">
-<module name="com.puppycrawl.tools.checkstyle.Checker">
+<module name="Checker">
<module name="SuppressWithPlainTextCommentFilter"/>
<module name="io.spring.javaformat.checkstyle.SpringChecks">
<property name="excludes" value="com.puppycrawl.tools.checkstyle.checks.javadoc.JavadocPackageCheck" />
+ <property name="excludes" value="com.puppycrawl.tools.checkstyle.checks.javadoc.JavadocTypeCheck" />
</module>
-</module>
\ No newline at end of file
+ <module name="TreeWalker">
+ <module name="MissingJavadocType" />
+ <module name="TodoComment">
+ <property name="format" value="(FIXME)|(XXX)|(@author)" />
+ </module>
+ </module>
+</module>
diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
index dd0a6f8..57f4137 100644
--- a/gradle/libs.versions.toml
+++ b/gradle/libs.versions.toml
@@ -38,4 +38,4 @@ licenser = { module = "gradle.plugin.org.cadixdev.gradle:licenser", version.ref
log4j = ["log4j-api", "log4j-core", "log4j-slf4j-impl", "slf4j-api"]
[plugins]
-versions = "com.github.ben-manes.versions:0.42.0"
\ No newline at end of file
+versions = "com.github.ben-manes.versions:0.42.0"
diff --git a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageConsumerE2ETest.java b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageConsumerE2ETest.java
index ed617de..42a4c26 100644
--- a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageConsumerE2ETest.java
+++ b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageConsumerE2ETest.java
@@ -34,7 +34,7 @@ import reactor.core.publisher.Flux;
import static org.assertj.core.api.Assertions.assertThat;
-public class ReactiveMessageConsumerE2ETest {
+class ReactiveMessageConsumerE2ETest {
@Test
void shouldConsumeMessages() throws Exception {
diff --git a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessagePipelineE2ETest.java b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessagePipelineE2ETest.java
index 5ea6d7b..25dd1f1 100644
--- a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessagePipelineE2ETest.java
+++ b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessagePipelineE2ETest.java
@@ -51,7 +51,7 @@ import reactor.util.function.Tuples;
import static org.assertj.core.api.Assertions.assertThat;
-public class ReactiveMessagePipelineE2ETest {
+class ReactiveMessagePipelineE2ETest {
static final int KEYS_COUNT = 100;
diff --git a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageReaderE2ETest.java b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageReaderE2ETest.java
index f6dafe7..a76e8a0 100644
--- a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageReaderE2ETest.java
+++ b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageReaderE2ETest.java
@@ -32,7 +32,7 @@ import reactor.core.publisher.Flux;
import static org.assertj.core.api.Assertions.assertThat;
-public class ReactiveMessageReaderE2ETest {
+class ReactiveMessageReaderE2ETest {
@Test
void shouldReadMessages() throws Exception {
diff --git a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageSenderE2ETest.java b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageSenderE2ETest.java
index c55379a..9a43150 100644
--- a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageSenderE2ETest.java
+++ b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageSenderE2ETest.java
@@ -40,7 +40,7 @@ import org.junit.jupiter.params.provider.MethodSource;
import static org.assertj.core.api.Assertions.assertThat;
-public class ReactiveMessageSenderE2ETest {
+class ReactiveMessageSenderE2ETest {
private static Stream<Arguments> shouldSendMessageToTopicWithCachedProducer() {
return Arrays
diff --git a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
index e54860c..cc679cb 100644
--- a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
+++ b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
@@ -21,14 +21,14 @@ import org.apache.pulsar.client.api.PulsarClientException;
import org.testcontainers.containers.PulsarContainer;
import org.testcontainers.utility.DockerImageName;
-public final class SingletonPulsarContainer {
+final class SingletonPulsarContainer {
private SingletonPulsarContainer() {
}
/** The singleton instance for Pulsar container. */
- public static PulsarContainer PULSAR_CONTAINER = new PulsarContainer(
+ static PulsarContainer PULSAR_CONTAINER = new PulsarContainer(
DockerImageName.parse("apachepulsar/pulsar").withTag("2.10.1"))
.withEnv("PULSAR_PREFIX_acknowledgmentAtBatchIndexLevelEnabled", "true");
@@ -36,7 +36,7 @@ public final class SingletonPulsarContainer {
PULSAR_CONTAINER.start();
}
- public static PulsarClient createPulsarClient() throws PulsarClientException {
+ static PulsarClient createPulsarClient() throws PulsarClientException {
return PulsarClient.builder().serviceUrl(SingletonPulsarContainer.PULSAR_CONTAINER.getPulsarBrokerUrl())
.build();
}
diff --git a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/AdaptedReactivePulsarClientFactory.java b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/AdaptedReactivePulsarClientFactory.java
index 761d888..c58ee52 100644
--- a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/AdaptedReactivePulsarClientFactory.java
+++ b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/AdaptedReactivePulsarClientFactory.java
@@ -28,9 +28,6 @@ import org.apache.pulsar.reactive.client.internal.adapter.ConcurrentHashMapProdu
/**
* Class to create {@link ReactivePulsarClient} and {@link ReactiveMessageSenderCache}.
* instances.
- *
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public final class AdaptedReactivePulsarClientFactory {
diff --git a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/DefaultMessageGroupingFunction.java b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/DefaultMessageGroupingFunction.java
index b44d475..c6e405b 100644
--- a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/DefaultMessageGroupingFunction.java
+++ b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/DefaultMessageGroupingFunction.java
@@ -24,8 +24,6 @@ import org.apache.pulsar.reactive.client.api.MessageGroupingFunction;
* Default message grouping function. It uses a {@link Murmur3Hash32} hashing function to
* compute a hash of the message key. All messages with the same key hash will be
* processed in order by the same message handler instance.
- *
- * @author Lari Hotari
*/
public class DefaultMessageGroupingFunction implements MessageGroupingFunction {
diff --git a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProvider.java b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProvider.java
index c5f44cf..afdc0ec 100644
--- a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProvider.java
+++ b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProvider.java
@@ -25,8 +25,6 @@ import org.apache.pulsar.reactive.client.api.ReactiveMessageSender;
/**
* Cache provider interface used by the {@link ReactiveMessageSender} to cache the
* underlying {@link Producer}s it uses.
- *
- * @author Lari Hotari
*/
public interface ProducerCacheProvider extends AutoCloseable {
diff --git a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProviderFactory.java b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProviderFactory.java
index b9c7c17..6ad1af1 100644
--- a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProviderFactory.java
+++ b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProviderFactory.java
@@ -20,8 +20,6 @@ import java.util.function.Supplier;
/**
* Interface to supply instances of {@link ProducerCacheProvider}.
- *
- * @author Lari Hotari
*/
public interface ProducerCacheProviderFactory extends Supplier<ProducerCacheProvider> {
diff --git a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdapterImplementationFactory.java b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdapterImplementationFactory.java
index 9f43a9f..fe75382 100644
--- a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdapterImplementationFactory.java
+++ b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdapterImplementationFactory.java
@@ -30,9 +30,6 @@ import reactor.core.publisher.Mono;
/**
* Adapter implementation for {@link ReactivePulsarClient} based on {@link PulsarClient}.
- *
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public final class AdapterImplementationFactory {
diff --git a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ConcurrentHashMapProducerCacheProvider.java b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ConcurrentHashMapProducerCacheProvider.java
index 97a21b5..9b04dbc 100644
--- a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ConcurrentHashMapProducerCacheProvider.java
+++ b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ConcurrentHashMapProducerCacheProvider.java
@@ -24,8 +24,6 @@ import org.apache.pulsar.reactive.client.adapter.ProducerCacheProvider;
/**
* Producer cache provider that uses a {@link ConcurrentHashMap} to cache entries.
- *
- * @author Lari Hotari
*/
public class ConcurrentHashMapProducerCacheProvider implements ProducerCacheProvider {
diff --git a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/PulsarFutureAdapter.java b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/PulsarFutureAdapter.java
index f6d89d8..3dfb87c 100644
--- a/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/PulsarFutureAdapter.java
+++ b/pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/PulsarFutureAdapter.java
@@ -31,8 +31,6 @@ import reactor.core.publisher.Mono;
* There's additional logic to ignore Pulsar client's
* {@link org.apache.pulsar.client.api.PulsarClientException.AlreadyClosedException} when
* the Mono has been cancelled. This is to reduce unnecessary exceptions in logs.
- *
- * @author Lari Hotari
*/
final class PulsarFutureAdapter {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/EndOfStreamAction.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/EndOfStreamAction.java
index d9c4989..619bede 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/EndOfStreamAction.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/EndOfStreamAction.java
@@ -18,8 +18,6 @@ package org.apache.pulsar.reactive.client.api;
/**
* Action to perform once the end of the stream is reached.
- *
- * @author Lari Hotari
*/
public enum EndOfStreamAction {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java
index cd49950..7e0cbc7 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java
@@ -36,8 +36,6 @@ import reactor.core.scheduler.Scheduler;
/**
* Immutable spec for a {@link ReactiveMessageConsumer}.
- *
- * @author Lari Hotari
*/
public class ImmutableReactiveMessageConsumerSpec implements ReactiveMessageConsumerSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageReaderSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageReaderSpec.java
index 2719afd..3bad2e0 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageReaderSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageReaderSpec.java
@@ -26,8 +26,6 @@ import org.apache.pulsar.client.api.Range;
/**
* Immutable spec for a {@link ReactiveMessageReader}.
- *
- * @author Lari Hotari
*/
public class ImmutableReactiveMessageReaderSpec implements ReactiveMessageReaderSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageSenderSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageSenderSpec.java
index 2693961..95baad8 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageSenderSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageSenderSpec.java
@@ -34,8 +34,6 @@ import org.apache.pulsar.client.api.ProducerCryptoFailureAction;
/**
* Immutable spec for a {@link ReactiveMessageSender}.
- *
- * @author Lari Hotari
*/
public class ImmutableReactiveMessageSenderSpec implements ReactiveMessageSenderSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/InstantStartAtSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/InstantStartAtSpec.java
index c72f5bc..576106a 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/InstantStartAtSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/InstantStartAtSpec.java
@@ -21,8 +21,6 @@ import java.util.Objects;
/**
* Spec for a {@link ReactiveMessageReader} to start reading from a given instant in time.
- *
- * @author Lari Hotari
*/
public final class InstantStartAtSpec extends StartAtSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageGroupingFunction.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageGroupingFunction.java
index 21b8b08..121def0 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageGroupingFunction.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageGroupingFunction.java
@@ -21,8 +21,6 @@ import org.apache.pulsar.client.api.Message;
/**
* Function to group messages that will be processed by the same instance of concurrent
* message handler.
- *
- * @author Lari Hotari
*/
public interface MessageGroupingFunction {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageIdStartAtSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageIdStartAtSpec.java
index dd1ae89..14cd653 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageIdStartAtSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageIdStartAtSpec.java
@@ -22,8 +22,6 @@ import org.apache.pulsar.client.api.MessageId;
/**
* Spec for a {@link ReactiveMessageReader} to start reading from a given message id.
- *
- * @author Lari Hotari
*/
public final class MessageIdStartAtSpec extends StartAtSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java
index 46a44da..f6c7276 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java
@@ -24,8 +24,6 @@ import org.apache.pulsar.reactive.client.internal.api.ApiImplementationFactory;
* Result of a message processing.
*
* @param <T> the message payload type
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface MessageResult<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpec.java
index 07f0d91..2cda965 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpec.java
@@ -22,8 +22,6 @@ import org.apache.pulsar.reactive.client.internal.api.ApiImplementationFactory;
* Interface for the spec of a message to be sent.
*
* @param <T> the message payload type
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface MessageSpec<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpecBuilder.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpecBuilder.java
index 01c38b1..d49fb11 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpecBuilder.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpecBuilder.java
@@ -27,7 +27,6 @@ import org.apache.pulsar.client.api.SubscriptionType;
* Builder interface for {@link MessageSpec}.
*
* @param <T> the message payload type
- * @author Lari Hotari
*/
public interface MessageSpecBuilder<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java
index 2ad8768..52a530c 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java
@@ -35,9 +35,6 @@ import reactor.core.scheduler.Scheduler;
/**
* Mutable spec for a {@link ReactiveMessageConsumer}.
- *
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public class MutableReactiveMessageConsumerSpec implements ReactiveMessageConsumerSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java
index d82e726..f4fe5cb 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java
@@ -25,9 +25,6 @@ import org.apache.pulsar.client.api.Range;
/**
* Mutable spec for a {@link ReactiveMessageReader}.
- *
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public class MutableReactiveMessageReaderSpec implements ReactiveMessageReaderSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java
index 0952971..31a1778 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java
@@ -34,9 +34,6 @@ import org.apache.pulsar.client.api.ProducerCryptoFailureAction;
/**
* Mutable spec for a {@link ReactiveMessageSender}.
- *
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public class MutableReactiveMessageSenderSpec implements ReactiveMessageSenderSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumer.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumer.java
index 6d0dd87..880a62b 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumer.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumer.java
@@ -28,8 +28,6 @@ import reactor.core.publisher.Mono;
* Reactive message consumer interface.
*
* @param <T> the message payload type.
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessageConsumer<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java
index cc6f151..7e9f960 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java
@@ -39,8 +39,6 @@ import reactor.core.scheduler.Scheduler;
* Builder interface for {@link ReactiveMessageConsumer}.
*
* @param <T> the message payload type
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessageConsumerBuilder<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerSpec.java
index 11fc799..48b67f8 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerSpec.java
@@ -34,9 +34,6 @@ import reactor.core.scheduler.Scheduler;
/**
* Spec for a {@link ReactiveMessageConsumer}.
- *
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessageConsumerSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipeline.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipeline.java
index 8f499df..b98ff3f 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipeline.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipeline.java
@@ -18,9 +18,6 @@ package org.apache.pulsar.reactive.client.api;
/**
* Reactive message pipeline interface.
- *
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessagePipeline extends AutoCloseable {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipelineBuilder.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipelineBuilder.java
index f4a6d55..6380660 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipelineBuilder.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipelineBuilder.java
@@ -30,8 +30,6 @@ import reactor.util.retry.Retry;
* Builder interface for {@link ReactiveMessagePipeline}.
*
* @param <T> the message payload type
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessagePipelineBuilder<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReader.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReader.java
index 7ef84e8..33d227b 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReader.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReader.java
@@ -24,8 +24,6 @@ import reactor.core.publisher.Mono;
* Reactive message reader interface.
*
* @param <T> the message payload type.
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessageReader<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java
index 804ea7b..4a05bd4 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java
@@ -31,8 +31,6 @@ import org.apache.pulsar.client.api.ReaderBuilder;
* Builder interface for {@link ReactiveMessageReader}.
*
* @param <T> the message payload type
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessageReaderBuilder<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderSpec.java
index 5b12a29..b517a79 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderSpec.java
@@ -25,9 +25,6 @@ import org.apache.pulsar.client.api.ReaderBuilder;
/**
* Spec for a {@link ReactiveMessageReader}.
- *
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessageReaderSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSender.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSender.java
index 890fe0f..9291cc2 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSender.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSender.java
@@ -25,8 +25,6 @@ import reactor.core.publisher.Mono;
* Reactive message sender interface.
*
* @param <T> the message payload type.
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessageSender<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilder.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilder.java
index 67c0f38..52e9f32 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilder.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilder.java
@@ -37,8 +37,6 @@ import org.reactivestreams.Publisher;
* Builder interface for {@link ReactiveMessageSender}.
*
* @param <T> the message payload type
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessageSenderBuilder<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderCache.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderCache.java
index 99f8bce..cb9848a 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderCache.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderCache.java
@@ -19,8 +19,6 @@ package org.apache.pulsar.reactive.client.api;
/**
* Marker interface for a cache that combines multiple sent messages to share the same
* Pulsar producer in the Pulsar client implementation level.
- *
- * @author Lari Hotari
*/
public interface ReactiveMessageSenderCache extends AutoCloseable {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderSpec.java
index 41dcd1b..9557604 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderSpec.java
@@ -32,9 +32,6 @@ import org.apache.pulsar.client.api.ProducerCryptoFailureAction;
/**
* Spec for {@link ReactiveMessageSender} configuration.
- *
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface ReactiveMessageSenderSpec {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactivePulsarClient.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactivePulsarClient.java
index 8bad89c..9a9d248 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactivePulsarClient.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactivePulsarClient.java
@@ -23,8 +23,6 @@ import org.apache.pulsar.client.api.Schema;
*
* Contains methods to create builders for {@link ReactiveMessageSender},
* {@link ReactiveMessageReader} and {@link ReactiveMessageConsumer} instances.
- *
- * @author Lari Hotari
*/
public interface ReactivePulsarClient {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/StartAtSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/StartAtSpec.java
index 9750cd7..aa72a9b 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/StartAtSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/StartAtSpec.java
@@ -25,8 +25,6 @@ import org.apache.pulsar.client.api.ReaderBuilder;
/**
* Spec to specify to a {@link ReactiveMessageReader} from where to start reading.
*
- * @author Lari Hotari
- * @author Christophe Bornet
* @see ReaderBuilder#startMessageId(MessageId)
* @see ReaderBuilder#startMessageFromRollbackDuration(long, TimeUnit)
*/
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ApiImplementationFactory.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ApiImplementationFactory.java
index 3390920..95285b2 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ApiImplementationFactory.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ApiImplementationFactory.java
@@ -26,9 +26,6 @@ import org.apache.pulsar.reactive.client.api.ReactiveMessagePipelineBuilder;
/**
* Internal API implementation.
- *
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public final class ApiImplementationFactory {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageResult.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageResult.java
index d95b123..2f78f63 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageResult.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageResult.java
@@ -24,7 +24,6 @@ import org.apache.pulsar.reactive.client.api.MessageResult;
* the message to acknowledge or negatively acknowledge.
*
* @param <T> the message payload type
- * @author Lari Hotari
*/
class DefaultMessageResult<T> implements MessageResult<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java
index 4d580f2..5bc2222 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java
@@ -27,7 +27,6 @@ import org.apache.pulsar.client.api.TypedMessageBuilder;
* {@link TypedMessageBuilder}.
*
* @param <T> the message payload type
- * @author Lari Hotari
* @see DefaultMessageSpecBuilder
* @see TypedMessageBuilder
*/
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpecBuilder.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpecBuilder.java
index 02849a1..7910116 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpecBuilder.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpecBuilder.java
@@ -29,7 +29,6 @@ import org.apache.pulsar.reactive.client.api.MessageSpecBuilder;
* Default class to build a message spec.
*
* @param <T> the message payload type
- * @author Lari Hotari
* @see ApiImplementationFactory#createMessageSpecBuilder(Object)
* @see DefaultMessageSpec
*/
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/EmptyMessageResult.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/EmptyMessageResult.java
index f45e011..6d3616e 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/EmptyMessageResult.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/EmptyMessageResult.java
@@ -22,8 +22,6 @@ import org.apache.pulsar.reactive.client.api.MessageResult;
/**
* Message result holding only the id of the message to acknowledge or negatively
* acknowledge.
- *
- * @author Lari Hotari
*/
class EmptyMessageResult implements MessageResult<Void> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/GroupOrderedMessageProcessors.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/GroupOrderedMessageProcessors.java
index b0aeff1..5e30171 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/GroupOrderedMessageProcessors.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/GroupOrderedMessageProcessors.java
@@ -34,8 +34,6 @@ import reactor.util.concurrent.Queues;
* flux is split into group fluxes based on the processing group. Each group flux is
* processes messages in order (one-by-one). Multiple group fluxes are processed in
* parallel.
- *
- * @author Lari Hotari
*/
public final class GroupOrderedMessageProcessors {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InflightLimiter.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InflightLimiter.java
index 6ea418f..82a6fc2 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InflightLimiter.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InflightLimiter.java
@@ -36,8 +36,6 @@ import reactor.util.context.Context;
/**
* Transformer class that limits the number of reactive streams subscription requests to
* keep the number of pending messages under a defined limit.
- *
- * @author Lari Hotari
*/
public class InflightLimiter implements PublisherTransformer {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InternalMessageSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InternalMessageSpec.java
index 557e1af..ee25262 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InternalMessageSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InternalMessageSpec.java
@@ -23,8 +23,6 @@ import org.apache.pulsar.reactive.client.api.MessageSpec;
* Internal interface for the spec of a message to be sent.
*
* @param <T> the message payload type
- * @author Lari Hotari
- * @author Christophe Bornet
*/
public interface InternalMessageSpec<T> extends MessageSpec<T> {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/PublisherTransformer.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/PublisherTransformer.java
index 33e9a27..f3b64a3 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/PublisherTransformer.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/PublisherTransformer.java
@@ -21,8 +21,6 @@ import reactor.core.Disposable;
/**
* Class to transform a {@link Publisher} to another {@link Publisher}.
- *
- * @author Lari Hotari
*/
public interface PublisherTransformer extends Disposable {
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java
index c49f1f6..8baf43b 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java
@@ -22,7 +22,6 @@ import org.apache.pulsar.client.api.TypedMessageBuilder;
* Spec for a message that configures only the value of the message.
*
* @param <T> the message payload type
- * @author Lari Hotari
*/
class ValueOnlyMessageSpec<T> implements InternalMessageSpec<T> {
diff --git a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageResultTest.java b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageResultTest.java
index 018955f..f4875f6 100644
--- a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageResultTest.java
+++ b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageResultTest.java
@@ -28,8 +28,6 @@ import static org.assertj.core.api.Assertions.assertThat;
/**
* Tests for {@link MessageResult}.
- *
- * @author Christophe Bornet
*/
class MessageResultTest {
diff --git a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageSpecTest.java b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageSpecTest.java
index f977490..206a6f3 100644
--- a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageSpecTest.java
+++ b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageSpecTest.java
@@ -33,8 +33,6 @@ import static org.assertj.core.api.Assertions.assertThat;
/**
* Tests for {@link MessageSpec}.
- *
- * @author Christophe Bornet
*/
class MessageSpecTest {
diff --git a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilderTest.java b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilderTest.java
index d5220db..8c45bc0 100644
--- a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilderTest.java
+++ b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilderTest.java
@@ -41,8 +41,6 @@ import static org.assertj.core.api.Assertions.assertThat;
* Tests for {@link ReactiveMessageConsumerBuilder},
* {@link MutableReactiveMessageConsumerSpec} and
* {@link ImmutableReactiveMessageConsumerSpec}.
- *
- * @author Christophe Bornet
*/
class ReactiveMessageConsumerBuilderTest {
diff --git a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilderTest.java b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilderTest.java
index 1435c9b..7a8530d 100644
--- a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilderTest.java
+++ b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilderTest.java
@@ -32,8 +32,6 @@ import static org.assertj.core.api.Assertions.assertThat;
* Tests for {@link ReactiveMessageReaderBuilder},
* {@link MutableReactiveMessageReaderSpec} and
* {@link ImmutableReactiveMessageReaderSpec}.
- *
- * @author Christophe Bornet
*/
class ReactiveMessageReaderBuilderTest {
diff --git a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilderTest.java b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilderTest.java
index 4a26414..55b0365 100644
--- a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilderTest.java
+++ b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilderTest.java
@@ -38,8 +38,6 @@ import static org.assertj.core.api.Assertions.assertThat;
* Tests for {@link ReactiveMessageSenderBuilder},
* {@link MutableReactiveMessageSenderSpec} and
* {@link ImmutableReactiveMessageSenderSpec}.
- *
- * @author Christophe Bornet
*/
class ReactiveMessageSenderBuilderTest {
diff --git a/pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/PulsarReactiveClientModule.java b/pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/PulsarReactiveClientModule.java
index f4c55a7..659b189 100644
--- a/pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/PulsarReactiveClientModule.java
+++ b/pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/PulsarReactiveClientModule.java
@@ -47,8 +47,6 @@ import reactor.core.scheduler.Scheduler;
/**
* Jackson module to handle the reactive client spec classes.
- *
- * @author Christophe Bornet
*/
public class PulsarReactiveClientModule extends SimpleModule {
diff --git a/pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProvider.java b/pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProvider.java
index eaa6522..ee14f78 100644
--- a/pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProvider.java
+++ b/pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProvider.java
@@ -30,8 +30,6 @@ import reactor.core.scheduler.Schedulers;
/**
* Producer cache provider that uses a Caffeine {@link AsyncCache} to cache entries.
- *
- * @author Lari Hotari
*/
public class CaffeineProducerCacheProvider implements ProducerCacheProvider {
diff --git a/pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProviderFactory.java b/pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProviderFactory.java
index afd517c..35ea705 100644
--- a/pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProviderFactory.java
+++ b/pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProviderFactory.java
@@ -22,8 +22,6 @@ import org.apache.pulsar.reactive.client.adapter.ProducerCacheProviderFactory;
/**
* {@link ProducerCacheProviderFactory} that creates instances of
* {@link CaffeineProducerCacheProvider}.
- *
- * @author Lari Hotari
*/
public class CaffeineProducerCacheProviderFactory implements ProducerCacheProviderFactory {