Streams

Composite Recipes

Recipes that include further recipes, often including the individual recipes below.

• Migrate Joined.named() to Joined.as()
• Migrate TaskMetadata and ThreadMetadata
• Migrate exactly_once and exactly_once_beta to exactly_once_v2
• Migrate exactly_once to exactly_once_beta

Recipes

• Migrate KStream to KTable conversion to use toTable() method
• Migrate TaskMetadata.taskId() to return TaskId
• Migrate WindowStore.put() to include timestamp
• Migrate deprecated KafkaStreams#store method
• Migrate deprecated retry configuration to task timeout
• Migrate to StreamsUncaughtExceptionHandler API
• Remove PartitionGrouper configuration