Important

You are viewing documentation for an older version of Confluent Platform. For the latest, click here.

Changelog¶

Version 5.4.0¶

PR-284 - REP-475 - Do not add connect worker configurations if dest.kafka.bootstrap.servers is present.
PR-281 - REP-475 - Fix for bug where producer interceptors were inferred.
PR-270 - REP-450 - Filters default configurations out when applying topic configurations to destination cluster.
PR-262 - REP-379 - Added configuration provider that can infer the dest.kafka.* configuration from the Connect Worker.
PR-266 - REP-47 - Added arity to boolean command line options as they all default true.
PR-260 - REP-436 - Refactor non-timestamp specific class to a new replicator-common module.
PR-246 - REP-322 - REP-323 REST extensions for Replicator monitoring.
PR-250 - REP-231 - Refactor ConsumerTimestampInterceptor out into a separate JAR.
PR-249 - REP-403 - Fixed timestamp committer and translator monitor thread leak.
PR-248 - REP-386 - Changed describeTopics behavior in topic monitor thread.
PR-245 - REP-321 - Implemented JMX Metrics.
PR-244 - REP-26 - Fixed an issue where group.id was not propagated to license manager.
PR-240 - REP-31 - Added code to specify default destination security settings.
PR-238 - REP-186 - Updated replicator to use delivery.timeout.ms instead of retries.
PR-221 - Migrated to new ConsumerPartitionAssignor interface.
PR-216 - Remove dependency on ZKUtils.
PR-211 - Use TopicConfig instead of LogConfig.
PR-203 - CC-4930 - Adjust expected calls in the event schedulePeriodicRefreshMetadata gets scheduled by NewReplicatorAdminClient.

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

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

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

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

No changes