You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by pe...@apache.org on 2020/05/19 08:43:51 UTC

[pulsar] branch master updated (097108a -> 4becb69)

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

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


    from 097108a  Support multiple Avro schema version in Pulsar SQL (#4847)
     add 4becb69  [Pulsar IO] Allow routing key per message to RabbitMQ sink connector (#5890)

No new revisions were added by this update.

Summary of changes:
 .../pulsar/io/rabbitmq/RabbitMQAbstractConfig.java       |  7 -------
 .../java/org/apache/pulsar/io/rabbitmq/RabbitMQSink.java | 11 +++--------
 .../apache/pulsar/io/rabbitmq/RabbitMQSinkConfig.java    |  9 ++++-----
 .../apache/pulsar/io/rabbitmq/RabbitMQSourceConfig.java  |  7 +++++++
 .../pulsar/io/rabbitmq/sink/RabbitMQSinkConfigTest.java  | 15 +++++----------
 .../apache/pulsar/io/rabbitmq/sink/RabbitMQSinkTest.java | 16 ++++++++++++----
 pulsar-io/rabbitmq/src/test/resources/sinkConfig.yaml    |  4 +---
 7 files changed, 32 insertions(+), 37 deletions(-)