Skip to content

Instantly share code, notes, and snippets.

@NajeebArif
Last active May 16, 2022 21:38
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save NajeebArif/c8871a0a22beb1b90418ee34326eb6dc to your computer and use it in GitHub Desktop.
Save NajeebArif/c8871a0a22beb1b90418ee34326eb6dc to your computer and use it in GitHub Desktop.
spring:
cloud:
stream:
bindings:
orderBranchingProcessor-in-0:
destination: raw-order-topic
orderBranchingProcessor-out-0:
destination: order-topic
orderBranchingProcessor-out-1:
destination: errored-order
upperCaseProcessor-in-0:
destination: src-textMsg-topic
upperCaseProcessor-out-0:
destination: out-textMsg-topic-0
upperCaseProcessor-out-1:
destination: out-textMsg-topic-1
kafka:
streams:
binder:
brokers: localhost:29092
functions:
orderBranchingProcessor:
applicationId: 'OrderBranchingProcessor'
upperCaseProcessor:
applicationId: 'lowerToUpperCaseStreamProcessor'
function:
# definition: orderProcessor;upperCaseProcessor;orderBranchingProcessor
definition: orderBranchingProcessor;upperCaseProcessor
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment