You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2021/01/06 00:43:05 UTC
[pulsar] branch master updated (c2a4e66 -> c12765a)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from c2a4e66 [Authentication] Support chained authentication with same auth method name (#9094)
add c12765a PIP-75: Perform serialization/deserialization with LightProto (#9046)
No new revisions were added by this update.
Summary of changes:
.../apache/bookkeeper/mledger/ManagedLedger.java | 2 +-
.../bookkeeper/mledger/ManagedLedgerConfig.java | 8 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 2 +-
.../mledger/impl/NonDurableCursorImpl.java | 4 +-
.../mledger/impl/ManagedCursorContainerTest.java | 1 -
.../mledger/impl/ManagedCursorPropertiesTest.java | 2 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 37 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 2 +-
pom.xml | 15 +-
protobuf-shaded/pom.xml | 76 -
protobuf/README.md | 72 -
pulsar-broker/pom.xml | 6 -
.../broker/TransactionMetadataStoreService.java | 7 +-
.../apache/pulsar/broker/admin/AdminResource.java | 4 +-
.../broker/admin/impl/PersistentTopicsBase.java | 10 +-
.../apache/pulsar/broker/admin/v1/Namespaces.java | 2 +-
.../apache/pulsar/broker/admin/v2/Namespaces.java | 2 +-
.../pulsar/broker/intercept/BrokerInterceptor.java | 4 +-
.../BrokerInterceptorWithClassLoader.java | 4 +-
.../broker/intercept/BrokerInterceptors.java | 4 +-
.../intercept/ManagedLedgerInterceptorImpl.java | 4 +-
.../pulsar/broker/lookup/TopicLookupBase.java | 4 +-
.../pulsar/broker/namespace/NamespaceService.java | 2 +-
.../broker/service/AbstractBaseDispatcher.java | 145 +-
.../AbstractDispatcherMultipleConsumers.java | 2 +-
.../AbstractDispatcherSingleActiveConsumer.java | 2 +-
.../broker/service/BrokerServiceException.java | 33 +-
.../org/apache/pulsar/broker/service/Consumer.java | 69 +-
.../apache/pulsar/broker/service/Dispatcher.java | 4 +-
...ashRangeExclusiveStickyKeyConsumerSelector.java | 13 +-
.../org/apache/pulsar/broker/service/Producer.java | 7 +-
.../pulsar/broker/service/PulsarCommandSender.java | 21 +-
.../broker/service/PulsarCommandSenderImpl.java | 113 +-
.../apache/pulsar/broker/service/ServerCnx.java | 239 +-
.../pulsar/broker/service/StreamingStats.java | 4 +-
.../apache/pulsar/broker/service/Subscription.java | 6 +-
.../org/apache/pulsar/broker/service/Topic.java | 10 +-
.../nonpersistent/NonPersistentDispatcher.java | 2 +-
.../NonPersistentDispatcherMultipleConsumers.java | 2 +-
...onPersistentDispatcherSingleActiveConsumer.java | 2 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 2 +-
.../nonpersistent/NonPersistentSubscription.java | 9 +-
.../service/nonpersistent/NonPersistentTopic.java | 10 +-
.../service/persistent/CompactorSubscription.java | 2 +-
.../service/persistent/MessageDeduplication.java | 4 +-
.../PersistentDispatcherMultipleConsumers.java | 4 +-
.../PersistentDispatcherSingleActiveConsumer.java | 2 +-
.../persistent/PersistentMessageExpiryMonitor.java | 4 +-
.../service/persistent/PersistentReplicator.java | 4 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 6 +-
.../service/persistent/PersistentSubscription.java | 20 +-
.../broker/service/persistent/PersistentTopic.java | 18 +-
.../ReplicatedSubscriptionSnapshotCache.java | 6 +-
.../ReplicatedSubscriptionsController.java | 28 +-
.../ReplicatedSubscriptionsSnapshotBuilder.java | 6 +-
.../transaction/buffer/TransactionBuffer.java | 2 +-
.../broker/transaction/buffer/TransactionMeta.java | 2 +-
.../exceptions/TransactionStatusException.java | 2 +-
.../exceptions/UnsupportedTxnActionException.java | 4 +-
.../buffer/impl/InMemTransactionBuffer.java | 4 +-
.../buffer/impl/TopicTransactionBuffer.java | 13 +-
.../buffer/impl/TransactionBufferClientImpl.java | 10 +-
.../buffer/impl/TransactionBufferHandlerImpl.java | 24 +-
.../transaction/pendingack/PendingAckHandle.java | 2 +-
.../pendingack/impl/PendingAckHandleImpl.java | 2 +-
.../org/apache/pulsar/client/api/RawMessage.java | 2 +-
.../pulsar/client/impl/RawBatchConverter.java | 63 +-
.../apache/pulsar/client/impl/RawMessageImpl.java | 44 +-
.../apache/pulsar/client/impl/RawReaderImpl.java | 7 +-
.../pulsar/compaction/CompactedTopicImpl.java | 2 +-
.../pulsar/compaction/TwoPhaseCompactor.java | 20 +-
.../broker/intercept/CounterBrokerInterceptor.java | 17 +-
.../intercept/MangedLedgerInterceptorImplTest.java | 6 +-
.../broker/intercept/MockBrokerInterceptor.java | 13 +-
...angeAutoSplitStickyKeyConsumerSelectorTest.java | 1 -
...angeExclusiveStickyKeyConsumerSelectorTest.java | 108 +-
.../PersistentDispatcherFailoverConsumerTest.java | 30 +-
.../broker/service/PersistentFailoverE2ETest.java | 2 +-
.../service/PersistentMessageFinderTest.java | 30 +-
.../broker/service/PersistentQueueE2ETest.java | 2 +-
.../service/PersistentTopicConcurrentTest.java | 48 +-
.../broker/service/PersistentTopicE2ETest.java | 2 +-
.../pulsar/broker/service/PersistentTopicTest.java | 199 +-
.../pulsar/broker/service/ServerCnxTest.java | 91 +-
.../service/TransactionMarkerDeleteTest.java | 9 +-
.../TransactionMetadataStoreServiceTest.java | 2 +-
.../service/persistent/MessageDuplicationTest.java | 9 +-
...ntStickyKeyDispatcherMultipleConsumersTest.java | 31 +-
.../persistent/PersistentSubscriptionTest.java | 12 +-
.../ReplicatedSubscriptionSnapshotCacheTest.java | 76 +-
...ReplicatedSubscriptionsSnapshotBuilderTest.java | 118 +-
.../broker/service/utils/ClientChannelHelper.java | 68 +-
.../broker/transaction/TransactionConsumeTest.java | 29 +-
.../broker/transaction/TransactionProduceTest.java | 17 +-
.../transaction/buffer/TransactionBufferTest.java | 2 +-
.../apache/pulsar/client/api/ClientErrorsTest.java | 4 +-
.../apache/pulsar/client/api/InterceptorsTest.java | 25 +-
.../pulsar/client/api/MockBrokerService.java | 33 +-
.../pulsar/client/api/MockBrokerServiceHooks.java | 36 +-
.../client/api/SimpleProducerConsumerTest.java | 43 +-
.../client/impl/CompactedOutBatchMessageTest.java | 25 +-
.../pulsar/client/impl/MessageChunkingTest.java | 17 +-
.../apache/pulsar/client/impl/MessageIdTest.java | 8 +-
.../pulsar/client/impl/MultiTopicsReaderTest.java | 16 +-
.../pulsar/client/impl/ProducerSemaphoreTest.java | 20 +-
.../pulsar/client/impl/RawMessageSerDeserTest.java | 10 +-
.../apache/pulsar/client/impl/RawReaderTest.java | 4 +-
.../org/apache/pulsar/client/impl/ReaderTest.java | 16 +-
.../pulsar/compaction/CompactedTopicTest.java | 16 +-
.../websocket/proxy/SimpleConsumerSocket.java | 2 +-
.../pulsar/client/impl/MessageBuilderImpl.java | 17 +-
.../pulsar/client/admin/internal/TopicsImpl.java | 17 +-
pulsar-client-cpp/lib/AckGroupingTrackerEnabled.cc | 2 +-
.../pulsar/client/impl/crypto/MessageCryptoBc.java | 47 +-
.../client/impl/AbstractBatchMessageContainer.java | 5 +-
.../impl/AcknowledgmentsGroupingTracker.java | 2 +-
.../client/impl/BatchMessageContainerImpl.java | 21 +-
.../client/impl/BatchMessageKeyBasedContainer.java | 33 +-
.../client/impl/BinaryProtoLookupService.java | 16 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 87 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 4 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 99 +-
.../pulsar/client/impl/HttpLookupService.java | 2 +-
.../apache/pulsar/client/impl/LookupService.java | 2 +-
.../apache/pulsar/client/impl/MessageIdImpl.java | 59 +-
.../org/apache/pulsar/client/impl/MessageImpl.java | 178 +-
.../client/impl/MultiTopicsConsumerImpl.java | 6 +-
...NonPersistentAcknowledgmentGroupingTracker.java | 2 +-
.../impl/PatternMultiTopicsConsumerImpl.java | 2 +-
.../PersistentAcknowledgmentsGroupingTracker.java | 4 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 71 +-
.../pulsar/client/impl/PulsarClientImpl.java | 2 +-
.../client/impl/TransactionMetaStoreHandler.java | 56 +-
.../client/impl/TypedMessageBuilderImpl.java | 69 +-
.../pulsar/client/impl/ZeroQueueConsumerImpl.java | 4 +-
.../impl/transaction/TransactionBufferHandler.java | 12 +-
.../TransactionCoordinatorClientImpl.java | 7 +-
.../impl/AcknowledgementsGroupingTrackerTest.java | 4 +-
.../apache/pulsar/client/impl/ClientCnxTest.java | 16 +-
.../apache/pulsar/client/impl/MessageImplTest.java | 64 +-
.../org/apache/pulsar/client/impl/MessageTest.java | 15 +-
.../client/impl/TypedMessageBuilderImplTest.java | 8 +-
pulsar-common/generate_protobuf.sh | 24 -
pulsar-common/generate_protobuf_docker.sh | 42 -
pulsar-common/pom.xml | 27 +-
.../apache/pulsar/common/api/proto/PulsarApi.java | 45619 -------------------
.../pulsar/common/api/proto/PulsarMarkers.java | 3415 --
.../pulsar/common/api/raw/MessageParser.java | 38 +-
.../pulsar/common/api/raw/RawMessageImpl.java | 53 +-
...t.java => ReferenceCountedMessageMetadata.java} | 37 +-
.../compression/CompressionCodecProvider.java | 33 +-
.../AppendBrokerTimestampMetadataInterceptor.java | 8 +-
.../intercept/AppendIndexMetadataInterceptor.java | 10 +-
.../intercept/BrokerEntryMetadataInterceptor.java | 8 +-
.../common/policies/data/SubscriptionStats.java | 2 +-
.../pulsar/common/protocol/CommandUtils.java | 27 +-
.../apache/pulsar/common/protocol/Commands.java | 2150 +-
.../org/apache/pulsar/common/protocol/Markers.java | 320 +-
.../pulsar/common/protocol/PulsarDecoder.java | 198 +-
.../pulsar/common/protocol/PulsarHandler.java | 10 +-
.../common/protocol/schema/SchemaInfoUtil.java | 9 +-
.../util/protobuf/ByteBufCodedInputStream.java | 377 -
.../util/protobuf/ByteBufCodedOutputStream.java | 249 -
.../pulsar/common/util/protobuf/package-info.java | 22 -
pulsar-common/src/main/proto/PulsarMarkers.proto | 8 +-
.../apache/pulsar/common/api/proto/TestApi.java | 641 -
.../pulsar/common/compression/CommandsTest.java | 15 +-
.../common/compression/CompressorCodecTest.java | 2 +-
.../policies/data/PartitionedTopicStatsTest.java | 4 -
.../pulsar/common/protocol/CommandUtilsTests.java | 83 +-
.../apache/pulsar/common/protocol/MarkersTest.java | 91 +-
.../pulsar/common/protocol/PulsarDecoderTest.java | 6 +-
.../common/protocol/RepeatedLongNonPackedTest.java | 65 -
.../common/protocol/RepeatedLongPackedTest.java | 65 -
.../ConcurrentBitSetRecyclableTest.java | 4 +-
.../util/protobuf/ByteBufCodedInputStreamTest.java | 101 -
pulsar-common/src/test/proto/TestApi.proto | 4 +-
.../pulsar/discovery/service/ServerConnection.java | 13 +-
.../discovery/service/DiscoveryServiceTest.java | 12 +-
pulsar-functions/utils/pom.xml | 6 -
.../worker/FunctionAssignmentTailerTest.java | 20 +-
.../worker/FunctionRuntimeManagerTest.java | 10 +-
.../pulsar/proxy/server/DirectProxyHandler.java | 6 +-
.../pulsar/proxy/server/LookupProxyHandler.java | 14 +-
.../pulsar/proxy/server/ParserProxyHandler.java | 25 +-
.../pulsar/proxy/server/ProxyConnection.java | 22 +-
.../pulsar/proxy/server/ProxyParserTest.java | 4 +-
.../org/apache/pulsar/proxy/server/ProxyTest.java | 4 +-
pulsar-sql/presto-distribution/LICENSE | 1 -
.../pulsar/sql/presto/TestPulsarConnector.java | 10 +-
pulsar-transaction/coordinator/pom.xml | 18 +-
.../transaction/coordinator/TransactionLog.java | 2 +-
.../coordinator/TransactionLogReplayCallback.java | 2 +-
.../coordinator/TransactionMetadataStore.java | 2 +-
.../pulsar/transaction/coordinator/TxnMeta.java | 2 +-
.../exceptions/CoordinatorException.java | 2 +-
.../impl/InMemTransactionMetadataStore.java | 2 +-
.../coordinator/impl/MLTransactionLogImpl.java | 67 +-
.../impl/MLTransactionMetadataStore.java | 46 +-
.../transaction/coordinator/impl/TxnMetaImpl.java | 2 +-
.../proto/PulsarTransactionMetadata.java | 1123 -
.../coordinator/util/TransactionUtil.java | 10 +-
.../MLTransactionMetadataStoreTest.java | 2 +-
.../TransactionMetadataStoreProviderTest.java | 2 +-
.../transaction/coordinator/TxnStatusTest.java | 2 +-
.../apache/pulsar/websocket/WebSocketService.java | 1 -
.../integration/SimpleProducerConsumerTest.java | 58 +-
.../integration/SimpleProducerConsumerTest.java | 61 +-
.../integration/SimpleProducerConsumerTest.java | 60 +-
209 files changed, 3037 insertions(+), 55747 deletions(-)
delete mode 100644 protobuf-shaded/pom.xml
delete mode 100644 protobuf/README.md
delete mode 100755 pulsar-common/generate_protobuf.sh
delete mode 100755 pulsar-common/generate_protobuf_docker.sh
delete mode 100644 pulsar-common/src/main/java/org/apache/pulsar/common/api/proto/PulsarApi.java
delete mode 100644 pulsar-common/src/main/java/org/apache/pulsar/common/api/proto/PulsarMarkers.java
rename pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/{ReferenceCountedObject.java => ReferenceCountedMessageMetadata.java} (51%)
delete mode 100644 pulsar-common/src/main/java/org/apache/pulsar/common/util/protobuf/ByteBufCodedInputStream.java
delete mode 100644 pulsar-common/src/main/java/org/apache/pulsar/common/util/protobuf/ByteBufCodedOutputStream.java
delete mode 100644 pulsar-common/src/main/java/org/apache/pulsar/common/util/protobuf/package-info.java
delete mode 100644 pulsar-common/src/test/java/org/apache/pulsar/common/api/proto/TestApi.java
delete mode 100644 pulsar-common/src/test/java/org/apache/pulsar/common/protocol/RepeatedLongNonPackedTest.java
delete mode 100644 pulsar-common/src/test/java/org/apache/pulsar/common/protocol/RepeatedLongPackedTest.java
delete mode 100644 pulsar-common/src/test/java/org/apache/pulsar/common/util/protobuf/ByteBufCodedInputStreamTest.java
delete mode 100644 pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/proto/PulsarTransactionMetadata.java