Skip to content

Instantly share code, notes, and snippets.

@NajeebArif
Created May 16, 2022 20:52
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/05ae866da5e1b700ee205284c11ba416 to your computer and use it in GitHub Desktop.
Save NajeebArif/05ae866da5e1b700ee205284c11ba416 to your computer and use it in GitHub Desktop.
spring:
cloud:
stream:
bindings:
orderProcessor-in-0:
destination: raw-order-topic
orderProcessor-out-0:
destination: sane-order-topic
upperCaseProcessor-in-0:
destination: src-textMsg-topic
upperCaseProcessor-out-0:
destination: out-textMsg-topic
kafka:
streams:
binder:
brokers: localhost:29092
functions:
orderProcessor:
applicationId: 'OrderProcessorStream'
upperCaseProcessor:
applicationId: 'lowerToUpperCaseStreamProcessor'
function:
definition: orderProcessor;upperCaseProcessor
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment