@@ -60,9 +60,9 @@ Config for tests are at `config/test.js`, it overrides some default config.
60
60
- Optionally, use another terminal, go to same directory, start a consumer to view the messages:
61
61
` bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic project.notification.create --from-beginning `
62
62
- If the kafka don't allow to input long message you can use this script to write message from file:
63
- ` path_to_kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.notification.create < our_project_root_directory/test/test_topic /project/project.notification.create.json `
63
+ ` path_to_kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.notification.create < our_project_root_directory/test/data /project/project.notification.create.json `
64
64
- Writing/reading messages to/from other topics are similar. All example for messages are in:
65
- ` our_project_root_directory/test/test_topic `
65
+ ` our_project_root_directory/test/data `
66
66
67
67
## Local Elasticsearch setup
68
68
@@ -125,7 +125,7 @@ npm run test:cov
125
125
- Call our project root directory : ` our_project_root_directory `
126
126
- Start kafka server, start elasticsearch, initialize Elasticsearch, start processor app
127
127
- Send message:
128
- ` path_to_kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.notification.create < our_project_root_directory/test/test_topic /project/project.notification.create.json `
128
+ ` path_to_kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.notification.create < our_project_root_directory/test/data /project/project.notification.create.json `
129
129
- run command ` npm run view-data projects 1 ` to view the created data, you will see the data are properly created:
130
130
131
131
``` bash
@@ -188,7 +188,7 @@ info: {
188
188
- Then in the app console, you will see error messages
189
189
190
190
- Sent message to update data:
191
- ` path_to_kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.notification.update < our_project_root_directory/test/test_topic /project/project.notification.update.json `
191
+ ` path_to_kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic project.notification.update < our_project_root_directory/test/data /project/project.notification.update.json `
192
192
- Run command ` npm run view-data projects 1 ` to view the updated data, you will see the data are properly updated:
193
193
194
194
``` bash
0 commit comments