You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2019/10/25 07:05:46 UTC
[pulsar] branch master updated (0281e83 -> 13e35f7)

This is an automated email from the ASF dual-hosted git repository.

sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from 0281e83  Documentation for delayed message delivery(#5293)
     add 13e35f7  [PIP-43] Support producer to send msg with different schema (#5165)

No new revisions were added by this update.

Summary of changes:
 .../apache/pulsar/broker/service/ServerCnx.java    |   72 +-
 .../apache/pulsar/client/api/SimpleSchemaTest.java |  220 +-
 .../apache/pulsar/client/api/ProducerBuilder.java  |   15 +
 .../java/org/apache/pulsar/client/api/Schema.java  |   12 +
 .../client/internal/DefaultImplementation.java     |    7 +
 pulsar-client-cpp/lib/Commands.cc                  |    4 +
 .../client/impl/BatchMessageContainerBase.java     |    9 +
 .../client/impl/BatchMessageContainerImpl.java     |   13 +
 .../client/impl/BatchMessageKeyBasedContainer.java |   15 +
 .../org/apache/pulsar/client/impl/ClientCnx.java   |   43 +
 .../apache/pulsar/client/impl/HandlerState.java    |   10 +-
 .../org/apache/pulsar/client/impl/MessageImpl.java |   19 +
 .../apache/pulsar/client/impl/ProducerBase.java    |   20 +
 .../pulsar/client/impl/ProducerBuilderImpl.java    |    8 +-
 .../apache/pulsar/client/impl/ProducerImpl.java    |  270 +-
 .../pulsar/client/impl/PulsarClientImpl.java       |    3 +
 .../impl/conf/ProducerConfigurationData.java       |    2 +
 .../client/impl/schema/AutoProduceBytesSchema.java |   17 +-
 .../pulsar/client/impl/schema/SchemaHash.java      |   39 +-
 .../apache/pulsar/common/api/proto/PulsarApi.java  | 2643 +++++++++++++++-----
 .../apache/pulsar/common/protocol/Commands.java    |   44 +
 .../pulsar/common/protocol/PulsarDecoder.java      |   22 +
 pulsar-common/src/main/proto/PulsarApi.proto       |   21 +
 23 files changed, 2718 insertions(+), 810 deletions(-)
 copy pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/SerDeSchema.java => pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/SchemaHash.java (55%)