Enable CheckStyle Plugin in Pulsar client api (#13638)
diff --git a/pulsar-client-api/pom.xml b/pulsar-client-api/pom.xml
index 54000c2d..fee2b31 100644
--- a/pulsar-client-api/pom.xml
+++ b/pulsar-client-api/pom.xml
@@ -77,6 +77,20 @@
<excludeFilterFile>${basedir}/src/main/resources/findbugsExclude.xml</excludeFilterFile>
</configuration>
</plugin>
+
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-checkstyle-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>checkstyle</id>
+ <phase>verify</phase>
+ <goals>
+ <goal>check</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
</plugins>
</build>
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/AuthenticationFactory.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/AuthenticationFactory.java
index 4de12b2..cddb265 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/AuthenticationFactory.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/AuthenticationFactory.java
@@ -86,7 +86,8 @@
public static Authentication create(String authPluginClassName, String authParamsString)
throws UnsupportedAuthenticationException {
try {
- return DefaultImplementation.getDefaultImplementation().createAuthentication(authPluginClassName, authParamsString);
+ return DefaultImplementation.getDefaultImplementation()
+ .createAuthentication(authPluginClassName, authParamsString);
} catch (Throwable t) {
throw new UnsupportedAuthenticationException(t);
}
@@ -103,7 +104,8 @@
public static Authentication create(String authPluginClassName, Map<String, String> authParams)
throws UnsupportedAuthenticationException {
try {
- return DefaultImplementation.getDefaultImplementation().createAuthentication(authPluginClassName, authParams);
+ return DefaultImplementation.getDefaultImplementation()
+ .createAuthentication(authPluginClassName, authParams);
} catch (Throwable t) {
throw new UnsupportedAuthenticationException(t);
}
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/BatcherBuilder.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/BatcherBuilder.java
index 34d8375..ba69206 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/BatcherBuilder.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/BatcherBuilder.java
@@ -19,7 +19,6 @@
package org.apache.pulsar.client.api;
import java.io.Serializable;
-
import org.apache.pulsar.client.internal.DefaultImplementation;
import org.apache.pulsar.common.classification.InterfaceAudience;
import org.apache.pulsar.common.classification.InterfaceStability;
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Consumer.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Consumer.java
index 5f4cc73..6d4b29b 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Consumer.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Consumer.java
@@ -338,7 +338,9 @@
* @throws PulsarClientException.AlreadyClosedException
* if the consumer was already closed
*/
- void reconsumeLater(Message<?> message, Map<String, String> customProperties, long delayTime, TimeUnit unit) throws PulsarClientException;
+ void reconsumeLater(Message<?> message,
+ Map<String, String> customProperties,
+ long delayTime, TimeUnit unit) throws PulsarClientException;
/**
* reconsumeLater the consumption of {@link Messages}.
@@ -522,7 +524,9 @@
* the time unit for the delay
* @return a future that can be used to track the completion of the operation
*/
- CompletableFuture<Void> reconsumeLaterAsync(Message<?> message, Map<String, String> customProperties, long delayTime, TimeUnit unit);
+ CompletableFuture<Void> reconsumeLaterAsync(Message<?> message,
+ Map<String, String> customProperties,
+ long delayTime, TimeUnit unit);
/**
* Asynchronously reconsumeLater the consumption of {@link Messages}.
@@ -593,7 +597,9 @@
* the time unit for the delay
* @return a future that can be used to track the completion of the operation
*/
- CompletableFuture<Void> reconsumeLaterCumulativeAsync(Message<?> message, Map<String, String> customProperties, long delayTime, TimeUnit unit);
+ CompletableFuture<Void> reconsumeLaterCumulativeAsync(Message<?> message,
+ Map<String, String> customProperties,
+ long delayTime, TimeUnit unit);
/**
* Get statistics for the consumer.
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/EncryptionKeyInfo.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/EncryptionKeyInfo.java
index eb34e3b..256de38 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/EncryptionKeyInfo.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/EncryptionKeyInfo.java
@@ -30,8 +30,8 @@
@InterfaceStability.Stable
public class EncryptionKeyInfo {
- private Map<String, String> metadata = null;
- private byte[] key = null;
+ private Map<String, String> metadata;
+ private byte[] key;
public EncryptionKeyInfo() {
this.key = null;
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedPolicy.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedPolicy.java
index 92ff3d2..67528c1 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedPolicy.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedPolicy.java
@@ -83,7 +83,7 @@
*/
public static class KeySharedPolicySticky extends KeySharedPolicy {
- protected List<Range> ranges;
+ protected final List<Range> ranges;
KeySharedPolicySticky() {
this.keySharedMode = KeySharedMode.STICKY;
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java
index c033e46..b465d5a 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java
@@ -68,8 +68,8 @@
/**
* Get the uncompressed message payload size in bytes.
- *
- * @return size in bytes.
+ *
+ * @return size in bytes.
*/
int size();
@@ -241,13 +241,13 @@
/**
* Release a message back to the pool. This is required only if the consumer was created with the option to pool
* messages, otherwise it will have no effect.
- *
+ *
* @since 2.8.0
*/
void release();
/**
- * Check whether the message has a broker publish time
+ * Check whether the message has a broker publish time.
*
* @since 2.9.0
* @return true if the message has a broker publish time, otherwise false.
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/MessageId.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/MessageId.java
index bf8defe..a8783dc 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/MessageId.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/MessageId.java
@@ -20,7 +20,6 @@
import java.io.IOException;
import java.io.Serializable;
-
import org.apache.pulsar.client.internal.DefaultImplementation;
import org.apache.pulsar.common.classification.InterfaceAudience;
import org.apache.pulsar.common.classification.InterfaceStability;
@@ -84,7 +83,8 @@
/**
* MessageId that represents the next message published in the topic.
*/
- MessageId latest = DefaultImplementation.getDefaultImplementation().newMessageId(Long.MAX_VALUE, Long.MAX_VALUE, -1);
+ MessageId latest = DefaultImplementation.getDefaultImplementation()
+ .newMessageId(Long.MAX_VALUE, Long.MAX_VALUE, -1);
// CHECKSTYLE.ON: ConstantName
}
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java
index 5c0211f..b207387 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java
@@ -1003,7 +1003,7 @@
// site
Throwable cause = t.getCause();
String msg = cause.getMessage();
- PulsarClientException newException = null;
+ PulsarClientException newException;
if (cause instanceof TimeoutException) {
newException = new TimeoutException(msg);
} else if (cause instanceof InvalidConfigurationException) {
@@ -1085,7 +1085,7 @@
Throwable e = t;
for (int maxDepth = 20; maxDepth > 0 && e != null; maxDepth--) {
if (e instanceof PulsarClientException) {
- Collection<Throwable> previous = ((PulsarClientException)e).getPreviousExceptions();
+ Collection<Throwable> previous = ((PulsarClientException) e).getPreviousExceptions();
if (previous != null) {
return previous;
}
@@ -1099,7 +1099,7 @@
Throwable e = t;
for (int maxDepth = 20; maxDepth > 0 && e != null; maxDepth--) {
if (e instanceof PulsarClientException) {
- ((PulsarClientException)e).setPreviousExceptions(previous);
+ ((PulsarClientException) e).setPreviousExceptions(previous);
return;
}
e = t.getCause();
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Range.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Range.java
index 75b1cbc..96eaee7 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Range.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Range.java
@@ -18,11 +18,10 @@
*/
package org.apache.pulsar.client.api;
+import java.util.Objects;
import org.apache.pulsar.common.classification.InterfaceAudience;
import org.apache.pulsar.common.classification.InterfaceStability;
-import java.util.Objects;
-
/**
* Int range.
*/
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Reader.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Reader.java
index 6f66cb9..d972e58 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Reader.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Reader.java
@@ -22,7 +22,6 @@
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
import java.util.function.Function;
-
import org.apache.pulsar.common.classification.InterfaceAudience;
import org.apache.pulsar.common.classification.InterfaceStability;
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ReaderBuilder.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ReaderBuilder.java
index 4186df7..75ca3fc 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ReaderBuilder.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ReaderBuilder.java
@@ -286,8 +286,8 @@
* <p/>
* When pooling is enabled, the application is responsible for calling Message.release() after the handling of every
* received message. If “release()” is not called on a received message, there will be a memory leak. If an
- * application attempts to use and already “released” message, it might experience undefined behavior (for example, memory
- * corruption, deserialization error, etc.).
+ * application attempts to use and already “released” message, it might experience undefined behavior (for example,
+ * memory corruption, deserialization error, etc.).
*/
ReaderBuilder<T> poolMessages(boolean poolMessages);
}
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Schema.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Schema.java
index 6803187..0692c48 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Schema.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Schema.java
@@ -28,10 +28,9 @@
import java.time.LocalTime;
import java.util.Date;
import java.util.Optional;
-
+import org.apache.pulsar.client.api.schema.GenericObject;
import org.apache.pulsar.client.api.schema.GenericRecord;
import org.apache.pulsar.client.api.schema.GenericSchema;
-import org.apache.pulsar.client.api.schema.GenericObject;
import org.apache.pulsar.client.api.schema.SchemaDefinition;
import org.apache.pulsar.client.api.schema.SchemaInfoProvider;
import org.apache.pulsar.client.internal.DefaultImplementation;
@@ -271,7 +270,8 @@
* @return a Schema instance
*/
static <T extends com.google.protobuf.GeneratedMessageV3> Schema<T> PROTOBUF(Class<T> clazz) {
- return DefaultImplementation.getDefaultImplementation().newProtobufSchema(SchemaDefinition.builder().withPojo(clazz).build());
+ return DefaultImplementation.getDefaultImplementation()
+ .newProtobufSchema(SchemaDefinition.builder().withPojo(clazz).build());
}
/**
@@ -291,7 +291,8 @@
* @return a Schema instance
*/
static <T extends com.google.protobuf.GeneratedMessageV3> Schema<T> PROTOBUF_NATIVE(Class<T> clazz) {
- return DefaultImplementation.getDefaultImplementation().newProtobufNativeSchema(SchemaDefinition.builder().withPojo(clazz).build());
+ return DefaultImplementation.getDefaultImplementation()
+ .newProtobufNativeSchema(SchemaDefinition.builder().withPojo(clazz).build());
}
/**
@@ -312,7 +313,8 @@
* @return a Schema instance
*/
static <T> Schema<T> AVRO(Class<T> pojo) {
- return DefaultImplementation.getDefaultImplementation().newAvroSchema(SchemaDefinition.builder().withPojo(pojo).build());
+ return DefaultImplementation.getDefaultImplementation()
+ .newAvroSchema(SchemaDefinition.builder().withPojo(pojo).build());
}
/**
@@ -332,7 +334,8 @@
* @return a Schema instance
*/
static <T> Schema<T> JSON(Class<T> pojo) {
- return DefaultImplementation.getDefaultImplementation().newJSONSchema(SchemaDefinition.builder().withPojo(pojo).build());
+ return DefaultImplementation.getDefaultImplementation()
+ .newJSONSchema(SchemaDefinition.builder().withPojo(pojo).build());
}
/**
@@ -428,7 +431,7 @@
/**
* Create a schema instance that accepts a serialized Avro payload
- * without validating it against the schema specified.
+ * without validating it against the schema specified.
* It can be useful when migrating data from existing event or message stores.
*
* @return the auto schema instance
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SizeUnit.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SizeUnit.java
index c49e0d4..cc49ecf 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SizeUnit.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SizeUnit.java
@@ -26,7 +26,7 @@
private final long bytes;
- private SizeUnit(long bytes) {
+ SizeUnit(long bytes) {
this.bytes = bytes;
}
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/KeyValueSchema.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/KeyValueSchema.java
index 64da4af..f21ecf4 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/KeyValueSchema.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/KeyValueSchema.java
@@ -28,7 +28,7 @@
* @param <K> the type of the Key
* @param <V> the type of the Value.
*/
-public interface KeyValueSchema<K,V> extends Schema<KeyValue<K,V>> {
+public interface KeyValueSchema<K, V> extends Schema<KeyValue<K, V>> {
/**
* Get the Schema of the Key.
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaDefinition.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaDefinition.java
index dffa5e4..a6777c5 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaDefinition.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaDefinition.java
@@ -20,7 +20,6 @@
import java.util.Map;
import java.util.Optional;
-
import org.apache.pulsar.client.internal.DefaultImplementation;
import org.apache.pulsar.common.classification.InterfaceAudience;
import org.apache.pulsar.common.classification.InterfaceStability;
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaReader.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaReader.java
index c5561bf..7afafde 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaReader.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/SchemaReader.java
@@ -20,7 +20,6 @@
import java.io.InputStream;
import java.util.Optional;
-
import org.apache.pulsar.common.classification.InterfaceAudience;
import org.apache.pulsar.common.classification.InterfaceStability;
@@ -90,7 +89,7 @@
}
/**
- * Returns the underling Schema if possible
+ * Returns the underling Schema if possible.
* @return the schema, or an empty Optional if it is not possible to access it
*/
default Optional<Object> getNativeSchema() {
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionCoordinatorClientException.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionCoordinatorClientException.java
index d7df4e3..6643519 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionCoordinatorClientException.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionCoordinatorClientException.java
@@ -70,7 +70,7 @@
}
public InvalidTxnStatusException(String txnId, String actualState, String expectState) {
- super("["+ txnId +"] with unexpected state : "
+ super("[" + txnId + "] with unexpected state : "
+ actualState + ", expect " + expectState + " state!");
}
}
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/DefaultImplementation.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/DefaultImplementation.java
index 6fe1799..76e4367 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/DefaultImplementation.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/DefaultImplementation.java
@@ -27,18 +27,19 @@
public class DefaultImplementation {
private static final PulsarClientImplementationBinding IMPLEMENTATION;
static {
- PulsarClientImplementationBinding impl = null;
+ PulsarClientImplementationBinding impl;
try {
- impl = (PulsarClientImplementationBinding) ReflectionUtils.newClassInstance("org.apache.pulsar.client.impl.PulsarClientImplementationBindingImpl")
+ impl = (PulsarClientImplementationBinding) ReflectionUtils
+ .newClassInstance("org.apache.pulsar.client.impl.PulsarClientImplementationBindingImpl")
.getConstructor().newInstance();
} catch (Throwable error) {
- throw new RuntimeException("Cannot load Pulsar Client Implementation: "+error, error);
+ throw new RuntimeException("Cannot load Pulsar Client Implementation: " + error, error);
}
IMPLEMENTATION = impl;
}
/**
- * Access the actual implementation of the Pulsar Client API
+ * Access the actual implementation of the Pulsar Client API.
* @return the loaded implementation.
*/
public static PulsarClientImplementationBinding getDefaultImplementation() {
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/PulsarClientImplementationBinding.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/PulsarClientImplementationBinding.java
index c8c300c..7351343 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/PulsarClientImplementationBinding.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/PulsarClientImplementationBinding.java
@@ -17,6 +17,19 @@
* under the License.
*/
package org.apache.pulsar.client.internal;
+
+import java.io.IOException;
+import java.nio.ByteBuffer;
+import java.nio.charset.Charset;
+import java.sql.Time;
+import java.sql.Timestamp;
+import java.time.Instant;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.util.Date;
+import java.util.Map;
+import java.util.function.Supplier;
import org.apache.pulsar.client.api.Authentication;
import org.apache.pulsar.client.api.BatcherBuilder;
import org.apache.pulsar.client.api.ClientBuilder;
@@ -35,26 +48,12 @@
import org.apache.pulsar.common.schema.SchemaInfoWithVersion;
import org.apache.pulsar.common.schema.SchemaType;
-import java.io.IOException;
-import java.nio.ByteBuffer;
-import java.nio.charset.Charset;
-import java.sql.Time;
-import java.sql.Timestamp;
-import java.time.Instant;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.LocalTime;
-import java.util.Date;
-import java.util.Map;
-import java.util.function.Supplier;
-
/**
* Helper class for class instantiations and it also contains methods to work with schemas.
* This interface allows you to not depend on the Implementation classes directly.
* The actual implementation of this class is loaded from {@link DefaultImplementation}.
*/
public interface PulsarClientImplementationBinding {
-
<T> SchemaDefinitionBuilder<T> newSchemaDefinitionBuilder();
ClientBuilder newClientBuilder();
@@ -117,7 +116,8 @@
<T extends com.google.protobuf.GeneratedMessageV3> Schema<T> newProtobufSchema(SchemaDefinition schemaDefinition);
- <T extends com.google.protobuf.GeneratedMessageV3> Schema<T> newProtobufNativeSchema(SchemaDefinition schemaDefinition);
+ <T extends com.google.protobuf.GeneratedMessageV3> Schema<T> newProtobufNativeSchema(
+ SchemaDefinition schemaDefinition);
<T> Schema<T> newJSONSchema(SchemaDefinition schemaDefinition);
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaInfo.java b/pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaInfo.java
index e05b0d2..a71513a 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaInfo.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaInfo.java
@@ -20,7 +20,6 @@
import java.util.Collections;
import java.util.Map;
-
import org.apache.pulsar.client.internal.DefaultImplementation;
import org.apache.pulsar.common.classification.InterfaceAudience;
import org.apache.pulsar.common.classification.InterfaceStability;
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaType.java b/pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaType.java
index d9650a1..188f40f 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaType.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaType.java
@@ -169,7 +169,7 @@
*/
AUTO_PUBLISH(-4);
- int value;
+ final int value;
SchemaType(int value) {
this.value = value;
