You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Oct 7, 2022. It is now read-only.
Copy file name to clipboardExpand all lines: README.md
+3-2Lines changed: 3 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -39,7 +39,7 @@ To create new injectors for your topics, you should create a new kubernetes depl
39
39
-`ES_TIME_SUFFIX` Indicates what time unit to append to index names on Elasticsearch. Supported values are `day` and `hour`. Default value is `day`**OPTIONAL**
40
40
-`KAFKA_CONSUMER_RECORD_TYPE` Kafka record type. Should be set to "avro" or "json". Defaults to avro. **OPTIONAL**
41
41
-`KAFKA_CONSUMER_METRICS_UPDATE_INTERVAL` The interval which the app updates the exported metrics in the format of golang's `time.ParseDuration`. Defaults to 30s. **OPTIONAL**
42
-
-`KAFKA_CONSUMER_WITH_KEY_AND_VALUE` If you would to combine the result message with the value present in the key. Defaults to false. **OPTIONAL**
42
+
-`KAFKA_CONSUMER_INCLUDE_KEY` Determines whether to include the Kafka key in the Elasticsearch message(as the "key" field). Defaults to false. **OPTIONAL**
43
43
44
44
### Important note about Elasticsearch mappings and types
45
45
@@ -160,7 +160,8 @@ To build the project from source, run from project root:
160
160
go build cmd/injector.go
161
161
```
162
162
163
-
To run tests, run `docker-compose up -d zookeeper kafka schema-registry elasticsearch` and run `make test`.
163
+
To run tests, first add kafka to your /etc/hosts file `echo "127.0.0.1 kafka" | sudo tee -a /etc/hosts`
164
+
and then run `docker-compose up -d zookeeper kafka schema-registry elasticsearch` and run `make test`.
0 commit comments