This is an automated email from the ASF dual-hosted git repository.
xyz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 496afa7 [pulsar-broker] clean up active consumer on already closed
connection (#13196)
add 04aa9e8 Enable CheckStyle plugin in pulsar-client module (#13940)
No new revisions were added by this update.
Summary of changes:
pulsar-client/pom.xml | 14 ++
.../client/impl/AbstractBatchMessageContainer.java | 6 +-
.../impl/AcknowledgmentsGroupingTracker.java | 2 -
.../pulsar/client/impl/AuthenticationUtil.java | 7 +-
.../org/apache/pulsar/client/impl/Backoff.java | 9 +-
.../apache/pulsar/client/impl/BackoffBuilder.java | 30 ++--
.../pulsar/client/impl/BatchMessageAcker.java | 10 +-
.../client/impl/BatchMessageContainerBase.java | 5 +-
.../client/impl/BatchMessageContainerImpl.java | 8 +-
.../pulsar/client/impl/BatchMessageIdImpl.java | 3 +-
.../client/impl/BatchMessageKeyBasedContainer.java | 15 +-
.../client/impl/BinaryProtoLookupService.java | 29 +--
.../pulsar/client/impl/ClientBuilderImpl.java | 19 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 56 +++---
.../pulsar/client/impl/ConnectionHandler.java | 24 ++-
.../apache/pulsar/client/impl/ConsumerBase.java | 75 ++++----
.../pulsar/client/impl/ConsumerBuilderImpl.java | 41 +++--
.../org/apache/pulsar/client/impl/ConsumerId.java | 1 -
.../apache/pulsar/client/impl/ConsumerImpl.java | 200 ++++++++++++---------
.../pulsar/client/impl/ConsumerInterceptors.java | 35 ++--
.../pulsar/client/impl/ConsumerStatsDisabled.java | 4 +-
.../pulsar/client/impl/ConsumerStatsRecorder.java | 4 +-
.../client/impl/ConsumerStatsRecorderImpl.java | 16 +-
.../pulsar/client/impl/DefaultCryptoKeyReader.java | 11 +-
.../client/impl/DefaultCryptoKeyReaderBuilder.java | 4 +-
.../java/org/apache/pulsar/client/impl/Hash.java | 2 +-
.../org/apache/pulsar/client/impl/HttpClient.java | 16 +-
.../pulsar/client/impl/HttpLookupService.java | 21 ++-
.../apache/pulsar/client/impl/LookupService.java | 73 ++++----
.../pulsar/client/impl/MemoryLimitController.java | 4 +-
.../apache/pulsar/client/impl/MessageIdImpl.java | 8 +-
.../org/apache/pulsar/client/impl/MessageImpl.java | 43 +++--
.../client/impl/MessagePayloadContextImpl.java | 2 +-
.../pulsar/client/impl/MessageRouterBase.java | 2 +-
.../apache/pulsar/client/impl/MessagesImpl.java | 13 +-
.../client/impl/MultiTopicsConsumerImpl.java | 142 +++++++++------
.../pulsar/client/impl/MultiTopicsReaderImpl.java | 10 +-
.../{Murmur3_32Hash.java => Murmur3Hash32.java} | 6 +-
.../NegativeAckRedeliveryExponentialBackoff.java | 8 +-
.../pulsar/client/impl/NegativeAcksTracker.java | 4 +-
...NonPersistentAcknowledgmentGroupingTracker.java | 8 +-
.../client/impl/PartitionedProducerImpl.java | 35 ++--
.../impl/PatternMultiTopicsConsumerImpl.java | 18 +-
.../PersistentAcknowledgmentsGroupingTracker.java | 53 +++---
.../apache/pulsar/client/impl/ProducerBase.java | 7 +-
.../pulsar/client/impl/ProducerBuilderImpl.java | 27 ++-
.../apache/pulsar/client/impl/ProducerImpl.java | 140 +++++++++------
.../pulsar/client/impl/ProducerInterceptors.java | 17 +-
.../pulsar/client/impl/ProducerResponse.java | 1 -
.../client/impl/ProducerStatsRecorderImpl.java | 20 +--
.../client/impl/PulsarChannelInitializer.java | 23 ++-
.../pulsar/client/impl/PulsarClientImpl.java | 9 +-
.../PulsarClientImplementationBindingImpl.java | 40 ++++-
.../client/impl/PulsarServiceNameResolver.java | 6 +-
.../pulsar/client/impl/ReaderBuilderImpl.java | 10 +-
.../org/apache/pulsar/client/impl/ReaderImpl.java | 4 +-
.../impl/RoundRobinPartitionMessageRouterImpl.java | 2 -
.../apache/pulsar/client/impl/SendCallback.java | 7 +-
.../pulsar/client/impl/ServiceNameResolver.java | 2 +-
.../impl/SinglePartitionMessageRouterImpl.java | 1 -
.../pulsar/client/impl/TableViewBuilderImpl.java | 10 +-
.../client/impl/TableViewConfigurationData.java | 3 +-
.../apache/pulsar/client/impl/TableViewImpl.java | 19 +-
.../client/impl/TransactionMetaStoreHandler.java | 30 ++--
.../client/impl/TypedMessageBuilderImpl.java | 13 +-
.../pulsar/client/impl/UnAckedMessageTracker.java | 32 ++--
.../client/impl/UnAckedTopicMessageTracker.java | 12 +-
.../pulsar/client/impl/ZeroQueueConsumerImpl.java | 4 -
.../client/impl/auth/AuthenticationBasic.java | 5 +-
.../client/impl/auth/AuthenticationDataBasic.java | 8 +-
.../impl/auth/AuthenticationDataKeyStoreTls.java | 2 +-
.../client/impl/auth/AuthenticationDataTls.java | 7 +-
.../client/impl/auth/AuthenticationDataToken.java | 1 -
.../client/impl/auth/AuthenticationDisabled.java | 1 -
.../impl/auth/AuthenticationKeyStoreTls.java | 3 +-
.../pulsar/client/impl/auth/AuthenticationTls.java | 7 +-
.../client/impl/auth/AuthenticationToken.java | 15 +-
.../impl/auth/oauth2/AuthenticationOAuth2.java | 2 +-
.../impl/auth/oauth2/ClientCredentialsFlow.java | 12 +-
.../pulsar/client/impl/auth/oauth2/Flow.java | 2 +-
.../pulsar/client/impl/auth/oauth2/FlowBase.java | 6 +-
.../impl/auth/oauth2/protocol/TokenClient.java | 1 -
.../pulsar/client/impl/auth/package-info.java | 3 +-
.../client/impl/conf/ClientConfigurationData.java | 23 +--
.../impl/conf/ConsumerConfigurationData.java | 5 +-
.../DefaultCryptoKeyReaderConfigurationData.java | 4 +-
.../impl/conf/ProducerConfigurationData.java | 14 +-
.../client/impl/conf/ReaderConfigurationData.java | 4 +-
.../pulsar/client/impl/conf}/package-info.java | 2 +-
.../PartialRoundRobinMessageRouterImpl.java | 1 -
.../client/impl/customroute}/package-info.java | 4 +-
.../apache/pulsar/client/impl/package-info.java | 3 +-
.../pulsar/client/impl/schema/AbstractSchema.java | 5 +-
.../client/impl/schema/AbstractStructSchema.java | 17 +-
.../client/impl/schema/AutoConsumeSchema.java | 20 +--
.../client/impl/schema/AutoProduceBytesSchema.java | 4 +-
.../client/impl/schema/AvroBaseStructSchema.java | 8 +-
.../pulsar/client/impl/schema/AvroSchema.java | 15 +-
.../pulsar/client/impl/schema/BooleanSchema.java | 2 +-
.../client/impl/schema/ByteBufferSchema.java | 2 -
.../pulsar/client/impl/schema/DateSchema.java | 3 +-
.../pulsar/client/impl/schema/DoubleSchema.java | 2 +-
.../client/impl/schema/FieldSchemaBuilderImpl.java | 1 -
.../client/impl/schema/GenericObjectWrapper.java | 15 +-
.../pulsar/client/impl/schema/InstantSchema.java | 4 +-
.../pulsar/client/impl/schema/JSONSchema.java | 12 +-
.../client/impl/schema/KeyValueSchemaImpl.java | 26 +--
.../pulsar/client/impl/schema/LocalDateSchema.java | 2 +-
.../client/impl/schema/LocalDateTimeSchema.java | 5 +-
.../pulsar/client/impl/schema/LocalTimeSchema.java | 2 +-
.../client/impl/schema/NativeAvroBytesSchema.java | 15 +-
.../client/impl/schema/ProtobufNativeSchema.java | 20 +--
.../impl/schema/ProtobufNativeSchemaUtils.java | 52 +++---
.../pulsar/client/impl/schema/ProtobufSchema.java | 25 ++-
.../impl/schema/RecordSchemaBuilderImpl.java | 1 -
.../impl/schema/SchemaDefinitionBuilderImpl.java | 20 +--
.../client/impl/schema/SchemaDefinitionImpl.java | 22 +--
.../pulsar/client/impl/schema/SchemaInfoUtil.java | 2 -
.../pulsar/client/impl/schema/StringSchema.java | 11 +-
.../pulsar/client/impl/schema/StructSchema.java | 6 +-
.../pulsar/client/impl/schema/TimeSchema.java | 3 +-
.../pulsar/client/impl/schema/TimestampSchema.java | 3 +-
.../impl/schema/generic/AbstractGenericSchema.java | 6 +-
.../impl/schema/generic/AvroRecordBuilderImpl.java | 2 +-
.../impl/schema/generic/GenericAvroReader.java | 18 +-
.../impl/schema/generic/GenericAvroSchema.java | 4 +-
.../impl/schema/generic/GenericAvroWriter.java | 5 +-
.../impl/schema/generic/GenericJsonReader.java | 11 +-
.../impl/schema/generic/GenericJsonSchema.java | 3 +-
.../impl/schema/generic/GenericJsonWriter.java | 2 +-
.../generic/GenericProtobufNativeReader.java | 19 +-
.../generic/GenericProtobufNativeRecord.java | 8 +-
.../generic/GenericProtobufNativeSchema.java | 1 -
.../impl/schema/generic/GenericSchemaImpl.java | 17 +-
.../impl/schema/generic/JsonRecordBuilderImpl.java | 8 +-
.../generic/MultiVersionGenericAvroReader.java | 3 +-
.../generic/MultiVersionGenericJsonReader.java | 8 +-
.../generic/MultiVersionSchemaInfoProvider.java | 7 +-
.../client/impl/schema/generic}/package-info.java | 2 +-
.../pulsar/client/impl/schema/package-info.java | 3 +
.../schema/reader/AbstractMultiVersionReader.java | 9 +-
.../client/impl/schema/reader/AvroReader.java | 8 +-
.../impl/schema/reader/JacksonJsonReader.java | 5 +-
.../client/impl/schema/reader/JsonReader.java | 5 +-
.../impl/schema/reader/MultiVersionAvroReader.java | 6 +-
.../client/impl/schema/reader/ProtobufReader.java | 6 +-
.../client/impl/schema/reader}/package-info.java | 4 +-
.../pulsar/client/impl/schema/util/SchemaUtil.java | 6 +-
.../client/impl/schema/util}/package-info.java | 2 +-
.../client/impl/schema/writer/AvroWriter.java | 3 +-
.../client/impl/schema/writer}/package-info.java | 2 +-
.../impl/transaction/TransactionBufferHandler.java | 8 +-
.../impl/transaction/TransactionBuilderImpl.java | 2 -
.../TransactionCoordinatorClientImpl.java | 35 ++--
.../client/impl/transaction/TransactionImpl.java | 2 +-
.../apache/pulsar/client/util/ConsumerName.java | 1 -
.../pulsar/client/util/ExecutorProvider.java | 18 +-
.../org/apache/pulsar/client/util/MathUtils.java | 2 +-
.../org/apache/pulsar/client/util/ObjectCache.java | 2 +-
.../org/apache/pulsar/client/util/RetryUtil.java | 7 +-
.../pulsar/client/util/SecretsSerializer.java | 5 +-
.../apache/pulsar/client/util/TypeCheckUtil.java | 3 +-
.../apache/pulsar/client/util}/package-info.java | 4 +-
.../org/apache/pulsar/client/impl/HashTest.java | 2 +-
.../client/impl/PartitionedProducerImplTest.java | 2 +-
.../instance/FunctionResultRouterTest.java | 4 +-
166 files changed, 1192 insertions(+), 1083 deletions(-)
rename
pulsar-client/src/main/java/org/apache/pulsar/client/impl/{Murmur3_32Hash.java
=> Murmur3Hash32.java} (91%)
copy {pulsar-client-auth-athenz =>
pulsar-client}/src/main/java/org/apache/pulsar/client/impl/auth/package-info.java
(92%)
copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl =>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf}/package-info.java
(94%)
copy
{pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness =>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/customroute}/package-info.java
(89%)
copy {pulsar-client-1x-base/pulsar-client-1x =>
pulsar-client}/src/main/java/org/apache/pulsar/client/impl/package-info.java
(96%)
copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl =>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic}/package-info.java
(93%)
copy {pulsar-common =>
pulsar-client}/src/main/java/org/apache/pulsar/client/impl/schema/package-info.java
(96%)
copy
{pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness =>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader}/package-info.java
(90%)
copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl =>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/util}/package-info.java
(94%)
copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl =>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/writer}/package-info.java
(93%)
copy {pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web =>
pulsar-client/src/main/java/org/apache/pulsar/client/util}/package-info.java
(92%)
