Skip to content

KAFKA-13750: Client Compatability KafkaTest uses invalid idempotency configs#11909

Merged
dajac merged 2 commits intoapache:trunkfrom
jolshan:KAFKA-13750
Mar 17, 2022
Merged

KAFKA-13750: Client Compatability KafkaTest uses invalid idempotency configs#11909
dajac merged 2 commits intoapache:trunkfrom
jolshan:KAFKA-13750

Conversation

@jolshan
Copy link
Copy Markdown
Member

@jolshan jolshan commented Mar 16, 2022

With the switch to idempotency as a default, ClientCompatibilityFeaturesTest.run_compatibility_test broke for versions prior to 0.11 where EOS was enabled. This PR disables idempotency for kafka versions prior to 0.11.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

Copy link
Copy Markdown
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.

@jolshan , thanks for the fix. LGTM. Left a minor comment.

Comment on lines +178 to +183
.action(store())
.required(true)
.type(Boolean.class)
.dest("idempotentProducerSupported")
.metavar("IDEMPOTENT_PRODUCER_SUPPORTED")
.help("Whether the producer supports idempotency.");
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

indent is not aligned with above lines.

@dajac
Copy link
Copy Markdown
Member

dajac commented Mar 17, 2022

@jolshan Would you have a link to a successful run of the tests with your change?

@jolshan
Copy link
Copy Markdown
Member Author

jolshan commented Mar 17, 2022

@dajac
Copy link
Copy Markdown
Member

dajac commented Mar 17, 2022

@jolshan Thanks. Do we need to backport it to older branches? I guess that we need it in 3.1 and 3.0, right?

Copy link
Copy Markdown
Member

@dajac dajac left a comment

Choose a reason for hiding this comment

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

LGTM, thanks.

@dajac
Copy link
Copy Markdown
Member

dajac commented Mar 17, 2022

We don't need to wait for the build as this is a python change. Merging to trunk, 3.1 and 3.0.

@dajac dajac merged commit 7afdb06 into apache:trunk Mar 17, 2022
dajac pushed a commit that referenced this pull request Mar 17, 2022
… configs (#11909)

Reviewers: Luke Chen <showuon@gmail.com>, David Jacot <djacot@confluent.io>
dajac pushed a commit that referenced this pull request Mar 17, 2022
… configs (#11909)

Reviewers: Luke Chen <showuon@gmail.com>, David Jacot <djacot@confluent.io>
jeffkbkim pushed a commit to confluentinc/kafka that referenced this pull request May 12, 2022
… configs (apache#11909)

Reviewers: Luke Chen <showuon@gmail.com>, David Jacot <djacot@confluent.io>
jeffkbkim added a commit to confluentinc/kafka that referenced this pull request May 12, 2022
…cs-12-may-2022

* apache-kafka/3.0: (14 commits)
  fix: make sliding window works without grace period (#kafka-13739) (apache#11980)
  KAFKA-13794: Follow up to fix producer batch comparator (apache#12006)
  KAFKA-13794; Fix comparator of `inflightBatchesBySequence` in `TransactionManager` (apache#11991)
  KAFKA-13748: Do not include file stream connectors in Connect's CLASSPATH and plugin.path by default (apache#11908)
  KAFKA-13418: Support key updates with TLS 1.3 (apache#11966)
  KAFKA-13770: Restore compatibility with KafkaBasedLog using older Kafka brokers (apache#11946)
  KAFKA-13761: KafkaLog4jAppender deadlocks when idempotence is enabled (apache#11939)
  KAFKA-13759: Disable idempotence by default in producers instantiated by Connect (apache#11933)
  MINOR: Fix `ConsumerConfig.ISOLATION_LEVEL_DOC` (apache#11915)
  KAFKA-13750; Client Compatability KafkaTest uses invalid idempotency configs (apache#11909)
  ...
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants