Migrate to Kafka 3.0

Usage

This recipe has no required configuration options. You’ll need the Moderne CLI configured before running the command below.

mod run . --recipe io.moderne.kafka.MigrateToKafka30

If the recipe isn’t available locally, install it with:

mod config recipes jar install io.moderne.recipe:rewrite-kafka:RELEASE

Definition

This recipe runs the following recipes in order.

• Migrate to Kafka 2.8io.moderne.kafka.MigrateToKafka28
• Migrate TaskMetadata and ThreadMetadataio.moderne.kafka.streams.MigrateTaskAndThreadMetadata
• Migrate exactly_once and exactly_once_beta to exactly_once_v2io.moderne.kafka.streams.ProcessingGuaranteeExactlyOnceToV2
• Upgrade Gradle or Maven dependency versionsorg.openrewrite.java.dependencies.UpgradeDependencyVersion
• Add Gradle or Maven dependencyorg.openrewrite.java.dependencies.AddDependency
• Change method name org.apache.kafka.streams.KafkaStreams allMetadata() to metadataForAllStreamsClientsorg.openrewrite.java.ChangeMethodName
• Change method name org.apache.kafka.streams.KafkaStreams allMetadataForStore(java.lang.String) to streamsMetadataForStoreorg.openrewrite.java.ChangeMethodName
• Change method name org.apache.kafka.streams.KafkaStreams localThreadsMetadata() to metadataForLocalThreadsorg.openrewrite.java.ChangeMethodName

Data tables

Structured output this recipe can produce.

• Source files that had resultsSource files that were modified by the recipe run.org.openrewrite.table.SourcesFileResults
• Source files that had search resultsSearch results that were found during the recipe run.org.openrewrite.table.SearchResults
• Source files that errored on a recipeThe details of all errors produced by a recipe run.org.openrewrite.table.SourcesFileErrors
• Recipe performanceStatistics used in analyzing the performance of recipes.org.openrewrite.table.RecipeRunStats