Bump Version tp 0.12.2

- Enable consul to get multi elasticsearch urls, if urls not available then using environment variable
BaritoLog · Sep 2, 2019 · 28b0862 · 28b0862
1 parent cfd8569
commit 28b0862
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ## [Unreleased]
 ### Changed
 
+## [0.12.2]
+### Changed
+- Enable consul to get multi elasticsearch urls, if urls not available then using environment variable
+
 ## [0.12.1]
 ### Fixed
 - Update instru to the latest version, to avoid race condition

diff --git a/README.md b/README.md
@@ -82,11 +82,11 @@ These environment variables can be modified to customize its behaviour.
 | ConsulUrl | Consul URL | BARITO_CONSUL_URL | |
 | ConsulKafkaName  | Kafka service name in consul | BARITO_CONSUL_KAFKA_NAME | kafka |
 | ConsulElasticsearchName | Elasticsearch service name in consul | BARITO_CONSUL_ELASTICSEARCH_NAME | elasticsearch |
-| KafkaBrokers | Kafka broker addresses (CSV). Get from env is not available in consul | BARITO_KAFKA_BROKERS| localhost:9092 |
+| KafkaBrokers | Kafka broker addresses (CSV). Get from env is not available in consul | BARITO_KAFKA_BROKERS| "127.0.0.1:9092,192.168.10.11:9092" |
 | KafkaGroupID | kafka consumer group id | BARITO_KAFKA_GROUP_ID | barito-group |
 | KafkaMaxRetry | Number of retry to connect to kafka during startup | BARITO_KAFKA_MAX_RETRY | 0 (unlimited) |
 | KafkaRetryInterval | Interval between retry connecting to kafka (in seconds) | BARITO_KAFKA_RETRY_INTERVAL | 10 |
-| ElasticsearchUrl | Elastisearch url | BARITO_ELASTICSEARCH_URL | http://localhost:9200 |
+| ElasticsearchUrls | Elastisearch addresses. Get from env is not available in consul | BARITO_ELASTICSEARCH_URLS | "http://127.0.0.1:9200,http://192.168.10.11:9200" |
 | EsIndexMethod | BulkProcessor / SingleInsert | BARITO_ELASTICSEARCH_INDEX_METHOD | BulkProcessor |
 | EsBulkSize | BulkProcessor bulk size | BARITO_ELASTICSEARCH_BULK_SIZE | 100 |
 | EsFlushIntervalMs | BulkProcessor flush interval (ms) | BARITO_ELASTICSEARCH_FLUSH_INTERVAL_MS | 500 |

diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
@@ -31,7 +31,7 @@ services:
     environment:
       - BARITO_PRODUCER_ADDRESS=producer:8080
       - BARITO_KAFKA_BROKERS=kafka:9092
-      - BARITO_ELASTICSEARCH_URL=http://es:9200
+      - BARITO_ELASTICSEARCH_URLS=http://es:9200
     ports:
       - 9090:8080
     depends_on:

diff --git a/main.go b/main.go
@@ -11,7 +11,7 @@ import (
 
 const (
 	Name    = "barito-flow"
-	Version = "0.12.1"
+	Version = "0.12.2"
 )
 
 var (