Merge "Upgrade Apache Kafka to ver. 1.0.1 in devstack"
This commit is contained in:
commit
4d6594c312
@ -21,6 +21,7 @@ After=network.target zookeeper.service
|
|||||||
User=kafka
|
User=kafka
|
||||||
Group=kafka
|
Group=kafka
|
||||||
LimitNOFILE=32768:32768
|
LimitNOFILE=32768:32768
|
||||||
|
Environment="LOG_DIR=/var/log/kafka"
|
||||||
Environment="KAFKA_HEAP_OPTS=-Xmx128m"
|
Environment="KAFKA_HEAP_OPTS=-Xmx128m"
|
||||||
ExecStart=/opt/kafka/bin/kafka-server-start.sh /etc/kafka/server.properties
|
ExecStart=/opt/kafka/bin/kafka-server-start.sh /etc/kafka/server.properties
|
||||||
Restart=on-failure
|
Restart=on-failure
|
||||||
|
@ -63,6 +63,13 @@ auto.create.topics.enable=false
|
|||||||
# for consumption, but also mean more files.
|
# for consumption, but also mean more files.
|
||||||
num.partitions=2
|
num.partitions=2
|
||||||
|
|
||||||
|
# Specify the message format version the broker will use to append messages to
|
||||||
|
# the logs. Once consumers are upgraded, one can change the message format and
|
||||||
|
# enjoy the new message format that includes new timestamp and improved
|
||||||
|
# compression.
|
||||||
|
# (TODO) Use new message format after updating consumers
|
||||||
|
log.message.format.version=0.9.0.0
|
||||||
|
|
||||||
############################# Log Flush Policy #############################
|
############################# Log Flush Policy #############################
|
||||||
|
|
||||||
# Messages are immediately written to the filesystem but by default we only fsync() to sync
|
# Messages are immediately written to the filesystem but by default we only fsync() to sync
|
||||||
@ -119,4 +126,3 @@ zookeeper.connection.timeout.ms=1000000
|
|||||||
|
|
||||||
#kafka delete will have no impact if this is not set true
|
#kafka delete will have no impact if this is not set true
|
||||||
delete.topic.enable=true
|
delete.topic.enable=true
|
||||||
|
|
||||||
|
@ -103,7 +103,7 @@ INFLUXDB_PYTHON_VERSION=${INFLUXDB_PYTHON_VERSION:-1.3.8}
|
|||||||
VERTICA_VERSION=${VERTICA_VERSION:-8.0.0-0}
|
VERTICA_VERSION=${VERTICA_VERSION:-8.0.0-0}
|
||||||
CASSANDRA_VERSION=${CASSANDRA_VERSION:-311x}
|
CASSANDRA_VERSION=${CASSANDRA_VERSION:-311x}
|
||||||
# Kafka deb consists of the version of scala plus the version of kafka
|
# Kafka deb consists of the version of scala plus the version of kafka
|
||||||
BASE_KAFKA_VERSION=${BASE_KAFKA_VERSION:-0.9.0.1}
|
BASE_KAFKA_VERSION=${BASE_KAFKA_VERSION:-1.0.1}
|
||||||
SCALA_VERSION=${SCALA_VERSION:-2.11}
|
SCALA_VERSION=${SCALA_VERSION:-2.11}
|
||||||
KAFKA_VERSION=${KAFKA_VERSION:-${SCALA_VERSION}-${BASE_KAFKA_VERSION}}
|
KAFKA_VERSION=${KAFKA_VERSION:-${SCALA_VERSION}-${BASE_KAFKA_VERSION}}
|
||||||
STORM_VERSION=${STORM_VERSION:-1.1.3}
|
STORM_VERSION=${STORM_VERSION:-1.1.3}
|
||||||
|
@ -0,0 +1,7 @@
|
|||||||
|
---
|
||||||
|
upgrade:
|
||||||
|
- |
|
||||||
|
Apache Kafka has been upgraded to version 1.0.1 in devstack. It is the
|
||||||
|
recommended version for Monasca. Because of existing old consumers, Kafka
|
||||||
|
log message format option `log.message.format.version` should be set to
|
||||||
|
0.9.0.
|
Loading…
Reference in New Issue
Block a user