/
application.yml
42 lines (42 loc) · 1.07 KB
/
application.yml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
spring:
cloud:
stream:
default-binder: kafka2
bindings:
process-in-0:
destination: dataIn
binder: kafka1
# process-out-0:
# destination: dataOut
# binder: kafka2
#Test sink binding (used for testing)
sendTestData-out-0:
destination: dataIn
binder: kafka1
#Test sink binding (used for testing)
receive-in-0:
destination: dataOut
binder: kafka2
function:
definition: sendTestData;process;receive
binders:
kafka1:
type: kafka
environment:
spring:
cloud:
stream:
kafka:
binder:
brokers: ${kafkaBroker1}
zkNodes: ${zk1}
kafka2:
type: kafka
environment:
spring:
cloud:
stream:
kafka:
binder:
brokers: ${kafkaBroker2}
zkNodes: ${zk2}