Merge "Upgrade Apache Kafka to ver. 1.0.1 in devstack"

This commit is contained in:
Zuul 2018-08-08 10:49:27 +00:00 committed by Gerrit Code Review
commit 4d6594c312
4 changed files with 16 additions and 2 deletions

View File

@ -21,6 +21,7 @@ After=network.target zookeeper.service
User=kafka
Group=kafka
LimitNOFILE=32768:32768
Environment="LOG_DIR=/var/log/kafka"
Environment="KAFKA_HEAP_OPTS=-Xmx128m"
ExecStart=/opt/kafka/bin/kafka-server-start.sh /etc/kafka/server.properties
Restart=on-failure

View File

@ -63,6 +63,13 @@ auto.create.topics.enable=false
# for consumption, but also mean more files.
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 #############################
# 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
delete.topic.enable=true

View File

@ -103,7 +103,7 @@ INFLUXDB_PYTHON_VERSION=${INFLUXDB_PYTHON_VERSION:-1.3.8}
VERTICA_VERSION=${VERTICA_VERSION:-8.0.0-0}
CASSANDRA_VERSION=${CASSANDRA_VERSION:-311x}
# 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}
KAFKA_VERSION=${KAFKA_VERSION:-${SCALA_VERSION}-${BASE_KAFKA_VERSION}}
STORM_VERSION=${STORM_VERSION:-1.1.3}

View File

@ -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.