@@ -53,12 +53,12 @@ event.subscribe = {
53
53
* ** topic** : the value is the kafka topic to receive events. Make sure it has been created and Kafka process is running
54
54
55
55
##### Install Kafka
56
- * * * On Mac** :
56
+ ** On Mac** :
57
57
```
58
58
brew install kafka
59
59
```
60
60
61
- * * * On Linux** :
61
+ ** On Linux** :
62
62
```
63
63
cd /usr/local
64
64
wget http://archive.apache.org/dist/kafka/0.10.2.2/kafka_2.10-0.10.2.2.tgz
@@ -75,30 +75,29 @@ kafka-server-start.sh /usr/local/kafka/config/server.properties &
75
75
** Note** : make sure the version of Kafka is the same as the version set in build.gradle of eventplugin project.(kafka_2.10-0.10.2.2 kafka)
76
76
77
77
##### Run Kafka
78
- On Mac:
78
+ ** On Mac** :
79
79
```
80
80
zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties & kafka-server-start /usr/local/etc/kafka/server.properties
81
81
```
82
82
83
- On Linux:
83
+ ** On Linux** :
84
+ ```
84
85
zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties &
85
-
86
86
Sleep about 3 seconds
87
-
88
87
kafka-server-start.sh /usr/local/kafka/config/server.properties &
89
-
88
+ ```
90
89
91
90
#### Create topics to receive events, the topic is defined in config.conf
92
91
93
- On Mac:
92
+ ** On Mac** :
94
93
```
95
94
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic block
96
95
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic transaction
97
96
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic contractlog
98
97
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic contractevent
99
98
```
100
99
101
- On Linux:
100
+ ** On Linux** :
102
101
```
103
102
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic block
104
103
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic transaction
@@ -108,15 +107,15 @@ kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --par
108
107
109
108
#### Kafka consumer
110
109
111
- On Mac:
110
+ ** On Mac** :
112
111
```
113
112
kafka-console-consumer --bootstrap-server localhost:9092 --topic block --from-beginning
114
113
kafka-console-consumer --bootstrap-server localhost:9092 --topic transaction --from-beginning
115
114
kafka-console-consumer --bootstrap-server localhost:9092 --topic contractlog --from-beginning
116
115
kafka-console-consumer --bootstrap-server localhost:9092 --topic contractevent --from-beginning
117
116
```
118
117
119
- On Linux:
118
+ ** On Linux** :
120
119
```
121
120
kafka-console-consumer.sh --zookeeper localhost:2181 --topic block --from-beginning
122
121
kafka-console-consumer.sh --zookeeper localhost:2181 --topic transaction --from-beginning
0 commit comments