All pull requests

Pull requests

• Refresh assigned task's datastream list when a new dedup datastream is created

  #1049·mittalprince opened Aug 18, 2026Collaborator·

  ·
  3

• Add CDC+BST catch-up dedup hook in SourceBasedDeduper

  #1023·mittalprince opened May 26, 2026Collaborator·

  ·

• Upgrade GitHub Actions for Node 24 compatibility

  #992·salmanmkc opened Dec 16, 2025·

  ·

• Create ant.yml

  #989·psanogo opened Oct 15, 2025·

  ·

• Version Bump to 5.4.2

  #959·shrinandthakkar opened Sep 21, 2023Collaborator·

  ·

• Refactor datastream update checks

  #958·surajkn opened Sep 18, 2023Collaborator·

  ·
  3

• Added a timeout on the producer flush call in KafkaMirrorMakerConnectorTask

  #957·jzakaryan opened Aug 28, 2023Collaborator·

  ·
  5

• Replaced deprecated Kafka client poll with the recommended one

  #934·jzakaryan opened Apr 25, 2023Collaborator·

  ·

• Remove bintray as it's been shutdown

  #916·hshukla opened Nov 9, 2022Collaborator·

  ·
  1

• Updating the version number to point to the correct recent release ve…

  #880·surajkn opened Jan 21, 2022Collaborator·

  ·
  1

• Replace 101tec ZkClient with Helix ZkClient

  #870·surajkn opened Nov 17, 2021Collaborator·

  ·
  17

• Bmm diag reduce logs

  #780·jzakaryan opened Nov 10, 2020Collaborator·

  ·
  2

• Optimize flush in ZookeeperCheckpointProvider.

  #718·vmaheshw opened Jun 1, 2020Collaborator·

  ·

• Added timeouts on send and flush calls in KafkaProducerWrapper

  #696·jzakaryan opened Mar 24, 2020Collaborator·

  ·
  31

• Delay deletion of KAC

  #693·jzakaryan opened Mar 11, 2020Collaborator·

  ·

• Add support for preserving source message timestamp

  #687·sanjay24 opened Feb 27, 2020·

  ·
  20

• fix zk session leak

  #678·sdomalap opened Jan 28, 2020Contributor·

  ·
  5

• Option to set max tasks per instance per datastream

  #677·sdomalap opened Jan 28, 2020Contributor·

  ·

• Add kafka header

  #666·hgword opened Oct 16, 2019·

  ·