-
Notifications
You must be signed in to change notification settings - Fork 2
/
docker-compose.test.yml
176 lines (159 loc) · 4.93 KB
/
docker-compose.test.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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
version: '3'
services:
generator:
build: ./generator
environment:
KAFKA_BROKER_URL: broker:9092
RAW_TRANSACTIONS_TOPIC: queueing.raw.transactions
TRANSACTIONS_PER_SECOND: 1000
REQUEST_INTERVAL: 2
SOURCE_URL: wss://ropsten.infura.io/ws
detector:
build: ./detector
environment:
KAFKA_BROKER_URL: broker:9092
RAW_TRANSACTIONS_TOPIC: queueing.raw.transactions
TRANSACTIONS_TOPIC: streaming.transactions
generator_block:
build: ./generator_block
environment:
KAFKA_BROKER_URL: broker:9092
KAFKA_LOG4J_LOGGERS : kafka.controller=WARN, kafka.foo.bar=DEBUG
KAFKA_LOG4J_ROOT_LOGLEVEL : WARN
KAFKA_TOOLS_LOG4J_LOGLEVEL: ERROR
RAW_BLOCKS_TOPIC: queueing.raw.blocks
TRANSACTIONS_PER_SECOND: 1000
REQUEST_INTERVAL: 2
SOURCE_URL: wss://ropsten.infura.io/ws
detector_block:
build: ./detector_block
environment:
KAFKA_BROKER_URL: broker:9092
RAW_BLOCKS_TOPIC: queueing.raw.blocks
TRANSACTIONS_TOPIC: streaming.transactions
# TRANSACTIONS_BLOCKTIME_TOPIC: streaming.blocktime.transactions
TRANSACTIONS_BLOCK_TOPIC: queueing.blocktime.blocks
SOURCE_BLOCKDETAILS_URL: wss://ropsten.infura.io/ws/a699fa2391894c5799607f10f8b89ab3
mongodb:
image: mongo
ports:
- 27017:27017
environment:
MONGO_INITDB_ROOT_USERNAME: root
MONGO_INITDB_ROOT_PASSWORD: root
MONGO_INITDB_DATABASE: test_transactions
# volumes:
# - ./data/test:/data/test
detector_summary:
build: ./detector_summary
environment:
KAFKA_BROKER_URL: broker:9092
TRANSACTIONS_TOPIC: streaming.transactions
TRANSACTIONS_SUMMARY_TOPIC: queuening.summary.transactions
MONGO_INITDB_DATABASE: test_transactions
depends_on:
- mongodb
receiver_summary:
build: ./receiver_summary
environment:
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
TRANSACTIONS_SUMMARY_TOPIC: queuening.summary.transactions
MONGO_INITDB_DATABASE: test_transactions
URL: https://ropsten.etherscan.io/tx/
BATCH_INTERVAL: 2
depends_on:
- mongodb
receiver_summary2:
build: ./receiver_summary_2
environment:
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
TRANSACTIONS_SUMMARY_TOPIC: queueing.summary.transactions
MONGO_INITDB_DATABASE: transactions
URL: https://ropsten.etherscan.io/tx/
BATCH_INTERVAL: 2
depends_on:
- mongodb
# receiver_start_time:
# build: ./receiver_start_time
# environment:
# KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
# TRANSACTIONS_SUMMARY_TOPIC: queuening.summary.transactions
# MONGO_INITDB_DATABASE: transactions
# URL: https://etherscan.io/tx/
# BATCH_INTERVAL: 2
# depends_on:
# - mongodb
# receiver_start_time_2:
# build: ./receiver_start_time_2
# environment:
# KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
# TRANSACTIONS_TOPIC: streaming.transactions
# MONGO_INITDB_DATABASE: transactions
# URL: https://etherscan.io/tx/
# BATCH_INTERVAL: 10
# depends_on:
# - mongodb
# receiver_end_time:
# build: ./receiver_end_time
# environment:
# KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
# TRANSACTIONS_BLOCKTIME_TOPIC: streaming.blocktime.transactions
# MONGO_INITDB_DATABASE: transactions
# URL: https://etherscan.io/tx/
# BATCH_INTERVAL: 2
# depends_on:
# - mongodb
# receiver_end_time_2:26589
# build: ./receiver_e26589nd_time_2
# environment:26589
# KAFKA_ZOOKEEPER_C26589ONNECT: zookeeper:2181
# TRANSACTIONS_BLOC26589KTIME_TOPIC: streaming.blocktime.transactions
# MONGO_INITDB_DATA26589BASE: transactions
# URL: https://etherscan.io/tx/
# BATCH_INTERVAL: 2
# depends_on:
# - mongodb
receiver_block_time:
build: ./receiver_block_time
environment:
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
TRANSACTIONS_BLOCK_TOPIC: queueing.blocktime.blocks
MONGO_INITDB_DATABASE: test_transactions
NUMBER_OF_CONFIRMATIONS: 12
BATCH_INTERVAL: 5
depends_on:
- mongodb
receiver_block_time_2:
build: ./receiver_block_time_2
environment:
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
TRANSACTIONS_BLOCK_TOPIC: queueing.blocktime.blocks
MONGO_INITDB_DATABASE: test_transactions
NUMBER_OF_CONFIRMATIONS: 12
BATCH_INTERVAL: 5
depends_on:
- mongodb
web:
build: ./web
environment:
BATCH_INTERVAL: 10
MONGO_INITDB_DATABASE: test_transactions
ports:
- 5000:5000
depends_on:
- mongodb
# volumes:
# - ./test/:/data/test
# summary:
# build: ./summary
# environment:
# BATCH_INTERVAL: 100
# MONGO_INITDB_DATABASE: transactions
# NUMBER_OF_CONFIRMATIONS : 12
# URL: https://etherscan.io/tx/
# depends_on:
# - mongodb
networks:
default:
external:
name: kafka-network