Version 5.3.0

  • REP-22: Handle uncaught exception during offset commit
  • CC-3405: Close admin client if constructed locally
  • CC-4257: Allow consumer offset to be preferred over connect offset
  • CC-4347: Start REST server when using Replicator app
  • CC-4474: Use committed offsets even if dest topic doesn’t exist
  • CC-4536: Adapt ReplicatorApp to upstream changes in AK
  • CC-4576: De-duplicate in timestamp interceptors; add configs for batching in Replicator
  • CC-4928: During translation retries, save newer timestamps for retry
  • CC-4930: Adjust expected calls in case schedulePeriodicRefreshMetadata gets scheduled by NewReplicatorAdminClient
  • CC-5364: Fixed java.lang.NoSuchMethodError in cp-demo
  • MINOR: Use TopicConfig instead of LogConfig
  • MINOR: Add connect plugin to CLASSPATH
  • MINOR: Include CE versions of transitive dependencies
  • MINOR: Fix checkstyle issues with long lines
  • MINOR: Log messages when metadata is refreshed
  • MINOR: Exclude old guava version
  • MINOR: Fix for ConnectorClientConfigPolicy changes in AK
  • MINOR: remove extraneous and incorrect logging msg
  • MINOR: Build with Json package for Replicator Executable

Version 5.2.0

  • CC-4047: commit offset timestamp since it will not be invoked by the framework
  • CC-3931: Remove default for “schema.registry.topic”
  • CC-3866: Add thread to wakeup consumer in case a translator is not-ready
  • CC-2669: Add support for schema translation

Version 5.1.0

  • CC-3048: Corrected how Replicator instantiates and configures source converters and header converters
  • MINOR: Adding debug log messages to ReplicatorSourceTask.poll()
  • CC-2437 Remove “$” from Quick Start docs

Version 5.0.0

  • MINOR: check if topic exists before creating
  • MINOR: Fix to KafkaConfigBackingStore constructor signature that changed in AK 2.0
  • CC-1571: Replicator changes for offset translation for DR
  • Replicator switchback
  • CC-1348: Header Support in Replicator

Version 4.1.2

  • MINOR: Explain log message when exception is ignored during topic creation
  • DOCS-514 : Add config for destination Apache Kafka® cluster
  • DOCS-547: Make replicator linux commands explicit
  • CC-2099: Extend replicator binary to run from source repo and system tests
  • CC-2106 Don’t prefix interceptors with src.kafka and dest.kafka
  • MINOR: Fix configs for ZK-free deployment
  • CC-1263: refresh Replicator quickstart configuration
  • CC-2061: Handle NotLeaderException gracefully.

Version 4.1.1

  • CC-1850. Updated replicator to be packaged as ConfluentHub component.
  • CC-1458: Update configuration options

Version 4.1.0

  • Introduce for replicator exec
  • CC-1344: Make command topic configurable
  • CC-1455a: Add bin for ReplicatorX
  • CC-1348: Header Support in Replicator (#82)
  • CC-1348: Header Support in Replicator
  • CC-1452: API/CLI Implementation of Replicator X
  • CC-1451: Core implementation of Replicator executable with embedded connect
  • CC-1320: Create templates for Replicator and Connect worker config
  • CC-1375: New admin client wrapper needs to shutdown executor.
  • CC-1342: Update Replicator configs under the version that makes ZK optional
  • CC-1359: Fix regression in addPartitions in ZK-based adminclient.
  • Remove dependency on ZK and use AdminClient instead.
  • CC-1130: Add a validator for topic.regex
  • move to using io.confluent:common as parent instead of rest-utils

Version 4.0.1

  • CC-1320: Create templates for Replicator and Connect worker config
  • CC-1359: Fix regression in addPartitions in ZK-based adminclient.

Version 4.0.0

  • Fix SecurityProtocol import after upstream move
  • MINOR: Adapt to AdminUtils.addPartitions() change
  • Fix compile error due to upstream changes to SecurityProtocol
  • HOTFIX: Update ReplicatorAdminClient to use ZkUtils.getPartitionsForTopics since AdminUtils.fetchTopicMetadataFromZk has been removed

Version 3.3.1

  • Remove unused imports
  • Add upstream project so build are triggered automatically

Version 3.3.0

  • Handle consumer wakeups during task startup.
  • Fix breakage for EoS message format patch.
  • Move to common pom and checkstyle fixes.
  • Update usage of internal Topic class.

Version 3.2.2

  • Fix concurrent modification of source topic creation/expansion collection
  • Validate record timestamp value intead of record timestamp type

Version 3.2.1

No changes

Version 3.2.0

  • CC-331: Config options RST updates
  • CC-333: Replicator should support disabling partition preservation
  • CC-330: Replicator tasks hang on poll
  • CC-257: Add a producer interceptor to measure end-to-end performance.
  • HOTFIX: update RECORD_OVERHEAD variable after change in kafka