1. 06 1月, 2020 1 次提交
  2. 24 12月, 2019 1 次提交
    • N
      [functions] Added default metrics for Prometheus (#5885) · 602f5183
      Nathan Mills 提交于
      Currently functions do not report the default Prometheus metrics
      like the broker does, or any JMX metrics that normally get
      reported by kafka clients.
      
      This add the default Prometheus exports used by the broker as
      well as JMX exports that are reported by kafka clients when
      using the kafka wrapper.
      
      This change is a trivial rework / code cleanup without any test coverage.
      602f5183
  3. 10 12月, 2019 1 次提交
  4. 04 12月, 2019 1 次提交
  5. 19 11月, 2019 2 次提交
    • L
      [PIP-38] Support batch receive in java client. (#4621) · 56517d5f
      lipenghui 提交于
      Motivation
      Support messages batch receiving, some application scenarios can be made simpler. Users often increase application throughput through batch operations. For example, batch insert or update database.
      
      At present, we provide the ability to receive a single message. If users want to take advantage of batch operating advantages, need to implement a message collector him self. So this proposal aims to provide a universal interface and mechanism for batch receiving messages.
      
      For example:
      ```
      Messages messages = consumer.batchReceive();
      insertToDB(messages);
      consumer.acknowledge(messages);
      Verifying this change
      Added new UT to verify this change.
      ```
      56517d5f
    • H
      [Issue 5474][pulsar-io-debezium] Support CDC Connector for MongoDB (#5590) · 8d1f793b
      huangdx0726 提交于
      * support mongodb connector
      
      * add tester
      
      * add tester
      
      * add tester
      
      * add  license header
      
      * fix by some comments
      
      * add jdbc source sink
      
      * add init data
      
      * fix code style and default port 27017 of mongodb
      8d1f793b
  6. 14 11月, 2019 1 次提交
  7. 08 11月, 2019 1 次提交
  8. 07 11月, 2019 1 次提交
  9. 31 10月, 2019 1 次提交
    • M
      Upgrade dependencies for security fixes (#5232) · 0076a1bc
      Matteo Merli 提交于
      * Upgrade dependencies for security fixes
      
      * Use guava 18 for jclouds-shaded
      
      * Fix the guava version for HDFS tiered storage component
      
      * Rollback guava to 25.1 since there are API breaking changes
      
      * Rollback to Maven 3.0.5 which has the fix for sec issue
      
      * Fixed Jetty SslContextFactory creation
      
      * Roll back to 9.4.20.v20190813
      0076a1bc
  10. 26 10月, 2019 1 次提交
  11. 25 10月, 2019 1 次提交
  12. 26 9月, 2019 1 次提交
  13. 23 8月, 2019 1 次提交
  14. 22 8月, 2019 1 次提交
    • T
      ### Motivation (#4999) · e8b4eddf
      tuteng 提交于
      In the official download address of the connector, the connector of Flume, Solr and Redis was not generated correctly.
      
      ### Modifications
      * Add configuration to io.xml for generate connectors
      e8b4eddf
  15. 13 7月, 2019 1 次提交
  16. 10 7月, 2019 1 次提交
  17. 06 7月, 2019 1 次提交
  18. 03 7月, 2019 1 次提交
    • C
      File system offload (#4403) · 0e807f15
      congbo 提交于
      Fixes #3216 
      Implementation of offload to HDFS
      
      ### Motivation
      Implementation of offload to HDFS
      
      ### Verifying this change
      Add the test for this
      0e807f15
  19. 26 6月, 2019 2 次提交
  20. 25 6月, 2019 1 次提交
  21. 21 6月, 2019 1 次提交
  22. 05 6月, 2019 2 次提交
  23. 30 5月, 2019 1 次提交
    • K
      Use same activation dependency in pulsar-client-admin and pulsar-client (#4256) · 59705a8a
      Kim Christian Gaarder 提交于
      * Use same activation dependency in pulsar-client-admin and pulsar-client
      
      * Broker now resolve to same activation dependency as client
      
      * Remove no-longer used activation entries from distribution license
      
      * exclude conflicting activation dependency and update license
      
      * com.sun.activation as only activation dependency in all pulsar modules
      
      * Removed activation-1.1.1.jar reference from presto LICENSE
      59705a8a
  24. 22 5月, 2019 1 次提交
  25. 18 5月, 2019 1 次提交
    • L
      [schema] Fix joda dependency issue. (#4207) · 364ed5e9
      lipenghui 提交于
      * [schema] Fix joda dependency issue.
      
      * [schema] Add binary license of joda-time.
      
      * [schema] Make joda-time dependency optional.
      
      * [schema] Change log level to debug for logical type init.
      
      * [schema] fix joda-time license in presto distribution
      
      * [schema] fix joda-time license in presto distribution
      364ed5e9
  26. 17 5月, 2019 1 次提交
  27. 30 4月, 2019 1 次提交
  28. 08 4月, 2019 1 次提交
  29. 30 3月, 2019 1 次提交
  30. 19 3月, 2019 1 次提交
  31. 22 2月, 2019 1 次提交
    • S
      [distribution] remove pulsar-io-debezium nar package (#3656) · bd62dab6
      Sijie Guo 提交于
      *Motivation*
      
      Fixes #3651
      
      `pulsar-io-debezium` is a normal module but not a connector package.
      it was added as a connector package by mistake at #3601. This would
      cause failing to load connectors during broker starts up.
      
      *Changes*
      
      - remove nar plugin from `pulsar-io-debezium`
      - remove `pulsar-io-debezium` from distribution
      - add `pulsar-io-kafka-connect-adaptor` in the website
      bd62dab6
  32. 16 2月, 2019 1 次提交
  33. 15 2月, 2019 1 次提交
  34. 10 2月, 2019 1 次提交
  35. 08 2月, 2019 2 次提交
    • S
      [bookie] enable bookie http server (#3062) · b424fad2
      Sijie Guo 提交于
      
      *Motivation*
      
      Currently bookie http server is disabled by default. Setting the http server port
      to 8000 and include a vertx http server implementation to prepare enabling http server
      on bookie.
      
      *Modifications*
      
      Currently bookkeeper only provides two http server bindings, one is vertx, the other one
      is finagle server binding. both are netty based http server. so technically it doesn't
      introduce additional dependencies. However if people prefers a jetty implementation,
      I can add a jetty binding in bookkeeper.
      b424fad2
    • M
      Upgrade AsyncHTTP client to 2.7.0 (#3509) · 7ef26ddd
      Matteo Merli 提交于
      * Upgrade AsyncHTTP client to 2.7.0
      
      * Fixed license files
      7ef26ddd
  36. 01 2月, 2019 1 次提交