spring-cloud / spring-cloud/spring-cloud-stream

Failure if using multi output function with partitioning support

Open
#2,068 3 comments 1 reaction 1 assignee View on GitHub

@olegz is already working on this.

Since May 4, 2021.

Dominant language
Java
Stars
1.1k
Forks
646
Avg merge
2d 3h
Merged PRs (30d)
8

Description

Describe the issue
If a PartitionAwareFunctionWrapper is registered for a multi output function it will be invoked with the output publisher Tuple instead of the actual message. This leads to a java.lang.IllegalArgumentException: Partition key cannot be null error.

To Reproduce
Please see this example project for a repro case.
https://github.com/chringwer/spring-cloud-stream-bug/tree/partition-key

Version of the framework
Spring Cloud Stream 3.1.0-RC1
Spring Cloud Function 3.1.0-RC1

Contributor guide

No contributing guide indexed for this repository

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.