Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

KAFKA-12796: Removal of deprecated classes under streams-scala #10710

Conversation

jlprat
Copy link
Contributor

@jlprat jlprat commented May 17, 2021

Removes previously deprecated methods in older KIPs

Committer Checklist (excluded from commit message)

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

@@ -304,7 +304,7 @@ class KTable[K, V](val inner: KTableJ[K, V]) {
new KStream(inner.toStream[KR](mapper.asKeyValueMapper, named))

/**
* Suppress some updates from this changelog stream, determined by the supplied [[Suppressed]] configuration.
* Suppress some updates from this changelog stream, determined by the supplied [[org.apache.kafka.streams.kstream.Suppressed]] configuration.
Copy link
Contributor Author

Choose a reason for hiding this comment

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

Use the right non-deprecated class

@jlprat
Copy link
Contributor Author

jlprat commented May 17, 2021

cc @cadonna PR is ready for review, if you would like to take a look. Thanks!

Removes previously deprecated methods in older KIPs
@jlprat jlprat force-pushed the KAFKA-12796-removal-deprecated-classes-streams-scala branch from b001d75 to 5dde99d Compare May 17, 2021 17:38
@jlprat
Copy link
Contributor Author

jlprat commented May 17, 2021

As discussed with @ableegoldman only classes deprecated since at least 2.5 can be removed. For this reason, Serdes can't be removed yet.

@mjsax mjsax requested review from bbejeck and vvcephei May 19, 2021 18:40
Copy link
Contributor

@cadonna cadonna left a comment

Choose a reason for hiding this comment

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

Thank you for the PR! @jlprat

LGTM!

@cadonna
Copy link
Contributor

cadonna commented May 27, 2021

Failed test is unrelated and known to be flaky:

kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic()

@cadonna cadonna merged commit a02b19c into apache:trunk May 27, 2021
@jlprat jlprat deleted the KAFKA-12796-removal-deprecated-classes-streams-scala branch May 27, 2021 09:32
@jlprat
Copy link
Contributor Author

jlprat commented May 27, 2021

Thanks for the review @cadonna !

ijuma added a commit to ijuma/kafka that referenced this pull request May 27, 2021
…nups

* apache-github/trunk:
MINOR: Adjust parameter ordering of `waitForCondition` and
`retryOnExceptionWithTimeout` (apache#10759)
KAFKA-12796: Removal of deprecated classes under streams-scala
(apache#10710)
KAFKA-12819: Add assert messages to MirrorMaker tests plus other
quality of life improvements (apache#10762)
  Update implementation.html (apache#10771)
  MINOR: Log constructor: Flip logical NOT for readability (apache#10756)
MINOR: deprecate TaskMetadata constructor and add KIP-740 notes to
upgrade guide (apache#10755)
  MINOR: Log more information when producer snapshot is written (apache#10757)
  KAFKA-12260: Avoid hitting NPE for partitionsFor (apache#10017)
MINOR: add window verification to sliding-window co-group test
(apache#10745)
KAFKA-12800: Configure generator to fail on trailing JSON tokens
(apache#10717)
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.

2 participants