kafka: add protocol version fields to kafka server config (Bug 1434339) r?gps draft
authorConnor Sheehan <sheehan@mozilla.com>
Mon, 19 Mar 2018 11:43:19 -0400
changeset 12183 3537dba223d6ffde1ec180fca53ae17c13ed799f
parent 12182 e7dada846ef3a945f27c9d2e16099b6e93e83b8b
child 12184 eb09e12d6d61fc4f89441860c5fb73d29fb2f058
push id1911
push userbmo:sheehan@mozilla.com
push dateWed, 21 Mar 2018 17:13:14 +0000
reviewersgps
bugs1434339
kafka: add protocol version fields to kafka server config (Bug 1434339) r?gps Before upgrading the Kafka brokers to new versions of the code, make sure they are all still speaking the old protocol. MozReview-Commit-ID: 69i8ca7gjDi
ansible/roles/kafka-broker/templates/kafka-server.properties.j2
--- a/ansible/roles/kafka-broker/templates/kafka-server.properties.j2
+++ b/ansible/roles/kafka-broker/templates/kafka-server.properties.j2
@@ -34,8 +34,11 @@ unclean.leader.election.enable=false
 
 zookeeper.session.timeout.ms={{ kafka_zookeeper_session_timeout | default(3000) }}
 zookeeper.connection.timeout.ms={{ kafka_zookeeper_connection_timeout | default(3000) }}
 
 broker.id={{ kafka_broker_id | mandatory }}
 advertised.host.name={{ kafka_host_name | mandatory }}
 advertised.port={{ kafka_advertised_port | default(9092) }}
 zookeeper.connect={{ kafka_zookeeper_connect | mandatory }}
+
+inter.broker.protocol.version=0.8.2.2
+log.message.format.version=0.8.2.2