Skip to content

KAFKA-9992: EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13#8673

Merged
vvcephei merged 2 commits intoapache:trunkfrom
akatona84:scala-converter-remove
May 19, 2020
Merged

KAFKA-9992: EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13#8673
vvcephei merged 2 commits intoapache:trunkfrom
akatona84:scala-converter-remove

Conversation

@akatona84
Copy link
Copy Markdown
Contributor

Eliminating JavaConverters in EmbeddedKafkaCluster

More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.

Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system tests should be considered for larger changes.

Committer Checklist (excluded from commit message)

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

@akatona84
Copy link
Copy Markdown
Contributor Author

@vvcephei without the scala to java converter it would be compatible.

Copy link
Copy Markdown
Contributor

@vvcephei vvcephei left a comment

Choose a reason for hiding this comment

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

Hey, thanks for this, @akatona84 !

Just one minor comment, otherwise it lgtm (pending tests)

@vvcephei
Copy link
Copy Markdown
Contributor

Test this please

@vvcephei
Copy link
Copy Markdown
Contributor

(That last comment was to trigger the tests)

Copy link
Copy Markdown

@abbccdda abbccdda left a comment

Choose a reason for hiding this comment

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

LGTM as well!

…kafka_2.13

Eliminating JavaConverters in EmbeddedKafkaCluster

Change-Id: I71d3daee20b4717a3eda602e3e310b431b23c55c
@akatona84 akatona84 force-pushed the scala-converter-remove branch from 52087d0 to 7d16b46 Compare May 18, 2020 06:45
@akatona84
Copy link
Copy Markdown
Contributor Author

retest this please

@vvcephei
Copy link
Copy Markdown
Contributor

test this please

1 similar comment
@vvcephei
Copy link
Copy Markdown
Contributor

test this please

Copy link
Copy Markdown
Contributor

@vvcephei vvcephei 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 for the contribution, @akatona84 !

I'll just wait for the tests to pass.

@vvcephei
Copy link
Copy Markdown
Contributor

The tests that failed are known to be flaky and seem unrelated to this change:
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once]

@vvcephei vvcephei merged commit c0fa36d into apache:trunk May 19, 2020
vvcephei pushed a commit that referenced this pull request May 19, 2020
Fixes EmbeddedKafkaCluster.deleteTopicAndWait for use with kafka_2.13

Reviewers: Boyang Chen <boyang@confluent.io>, Chia-Ping Tsai <chia7712@gmail.com>, John Roesler <vvcephei@apache.org>
vvcephei pushed a commit that referenced this pull request May 19, 2020
Fixes EmbeddedKafkaCluster.deleteTopicAndWait for use with kafka_2.13

Reviewers: Boyang Chen <boyang@confluent.io>, Chia-Ping Tsai <chia7712@gmail.com>, John Roesler <vvcephei@apache.org>
@akatona84 akatona84 deleted the scala-converter-remove branch May 20, 2020 06:35
Kvicii pushed a commit to Kvicii/kafka that referenced this pull request May 21, 2020
* 'trunk' of github.com:apache/kafka:
  MINOR: Increase gradle daemon’s heap size to 2g (apache#8700)
  KAFKA-9603: Do not turn on bulk loading for segmented stores on stand-by tasks (apache#8661)
  KAFKA-9859 / kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation (apache#8671)
  MINOR: Fix redundant typos in comments and javadocs (apache#8693)
  KAFKA-10010: Should make state store registration idempotent (apache#8681)
  KAFKA-10011: Remove task id from lockedTaskDirectories during handleLostAll (apache#8682)
  KAFKA-9992: Eliminate JavaConverters in EmbeddedKafkaCluster (apache#8673)
  KAFKA-6145: Add unit tests to verify fix of bug KAFKA-9173 (apache#8689)
  MINOR: Update stream documentation (apache#8622)
  MINOR: Small fixes in the documentation (apache#8623)
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.

4 participants