Migrate to Kafka 4.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.MigrateToKafka40

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

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

Definition

This recipe runs the following recipes in order.

• Migrate to Kafka 3.3io.moderne.kafka.MigrateToKafka33
• Upgrade Gradle or Maven dependency versionsorg.openrewrite.java.dependencies.UpgradeDependencyVersion
• Upgrade Java to 17+ for Kafka broker/toolsio.moderne.kafka.UpgradeJavaForKafkaBroker
• Upgrade Java to 11+ for Kafka clientsio.moderne.kafka.UpgradeJavaForKafkaClients
• Remove deprecated Kafka propertyio.moderne.kafka.RemoveDeprecatedKafkaProperties
• Remove deprecated Kafka propertyio.moderne.kafka.RemoveDeprecatedKafkaProperties
• Remove deprecated Kafka propertyio.moderne.kafka.RemoveDeprecatedKafkaProperties
• Delete property by keyorg.openrewrite.properties.DeleteProperty
• Delete property by keyorg.openrewrite.properties.DeleteProperty
• Delete property by keyorg.openrewrite.properties.DeleteProperty
• Add comment before property keyorg.openrewrite.properties.AddPropertyComment
• Add comment before property keyorg.openrewrite.properties.AddPropertyComment
• Add comment before property keyorg.openrewrite.properties.AddPropertyComment
• Add comment before property keyorg.openrewrite.properties.AddPropertyComment
• Migrate deprecated sendOffsetsToTransaction to use ConsumerGroupMetadataio.moderne.kafka.MigrateSendOffsetsToTransaction
• Migrate KafkaConsumer.poll(long) to poll(Duration)io.moderne.kafka.MigrateConsumerPollToDuration
• Migrate KafkaConsumer.committed(TopicPartition) to committed(Set<TopicPartition>)io.moderne.kafka.MigrateConsumerCommittedToSet
• Migrate ConsumerGroupState to GroupStateio.moderne.kafka.MigrateConsumerGroupStateToGroupState
• Migrate AdminClient.alterConfigs() to incrementalAlterConfigs()io.moderne.kafka.MigrateAlterConfigsToIncrementalAlterConfigs
• Change method nameorg.openrewrite.java.ChangeMethodName
• Delete method argumentorg.openrewrite.java.DeleteMethodArgument

Data tables

Structured output this recipe can produce.

• Maven metadata failuresAttempts to resolve maven metadata that failed.org.openrewrite.maven.table.MavenMetadataFailures
• 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