Skip to content

KAFKA-20163: Missing MM2 default exclude configs#21443

Open
fvaleri wants to merge 1 commit intoapache:trunkfrom
fvaleri:fix-mm2-msg-ts
Open

KAFKA-20163: Missing MM2 default exclude configs#21443
fvaleri wants to merge 1 commit intoapache:trunkfrom
fvaleri:fix-mm2-msg-ts

Conversation

@fvaleri
Copy link
Contributor

@fvaleri fvaleri commented Feb 10, 2026

This patch adds the following missing configuration in MM2 exclude
defaults that were introduced in KIP-937:

  • log.message.timestamp.before.max.ms
  • log.message.timestamp.after.max.ms

Reviewers: Luke Chen showuon@gmail.com

This patch adds the following missing configuration in MM2 exclude
defaults that were introduced in KIP-937:

- log.message.timestamp.before.max.ms
- log.message.timestamp.after.max.ms

Signed-off-by: Federico Valeri <fedevaleri@gmail.com>
@github-actions github-actions bot added triage PRs from the community connect mirror-maker-2 small Small PRs labels Feb 10, 2026
Comment on lines -38 to +45
public static final String CONFIG_PROPERTIES_EXCLUDE_DEFAULT = "follower\\.replication\\.throttled\\.replicas, "
+ "leader\\.replication\\.throttled\\.replicas, "
+ "message\\.timestamp\\.difference\\.max\\.ms, "
+ "message\\.timestamp\\.type, "
+ "unclean\\.leader\\.election\\.enable, "
+ "min\\.insync\\.replicas";
public static final String CONFIG_PROPERTIES_EXCLUDE_DEFAULT = "follower.replication.throttled.replicas, "
+ "leader.replication.throttled.replicas, "
+ "message.timestamp.difference.max.ms, "
+ "log.message.timestamp.before.max.ms, "
+ "log.message.timestamp.after.max.ms, "
+ "message.timestamp.type, "
+ "unclean.leader.election.enable, "
+ "min.insync.replicas";
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Removing double backslash before full stops is fine in practice. An unescaped full stop would only cause a false match if there were a config property name identical except with a different character where a dot is (e.g. minXinsync.replicas), which doesn't exist in Kafka's config space. The readability improvement outweighs the theoretical imprecision.

@fvaleri
Copy link
Contributor Author

fvaleri commented Feb 10, 2026

@showuon fyi

Copy link
Member

@showuon showuon left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM!

@github-actions github-actions bot removed the triage PRs from the community label Feb 11, 2026
@showuon
Copy link
Member

showuon commented Feb 13, 2026

Let's wait for the CI build results.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants