inponomarev commented on pull request #9107: URL: https://github.com/apache/kafka/pull/9107#issuecomment-751261181
OK @mjsax concerning https://github.com/apache/kafka/pull/9107#discussion_r547607739 I remembered why it was implemented this way! The problem is that **it is not necessary to invoke `defaultBranch()` / `noDefaultBranch()`** when we use consumers, like in this simple example (I just added a new unit test for this case): ```java source.split() .branch(isCoffee, Branched.withConsumer(issuer::setCoffeePurchases)) .branch(isElectronics, Branched.withConsumer(issuer::setElectronicsPurchases)); ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
