--- Class[Confluent::Kafka::Broker].orig
+++ Class[Confluent::Kafka::Broker]
@@
- inter_broker_protocol_version => 1.1.0
+ inter_broker_protocol_version => 3.7
File[/etc/kafka/server.properties]
- Content differences:
--- /etc/kafka/server.properties.orig
+++ /etc/kafka/server.properties
@@ -13,7 +13,7 @@
listeners=PLAINTEXT://:9092,SSL://:9093
# Specify which version of the inter-broker protocol will be used. This is
# typically bumped after all brokers were upgraded to a new version.
-inter.broker.protocol.version=1.1.0
+inter.broker.protocol.version=3.7
# The time, in milliseconds, that the `GroupCoordinator` will delay the initial consumer rebalance.
# The rebalance will be further delayed by the value of group.initial.rebalance.delay.ms
Class[Profile::Kafka::Broker]
- Parameters differences:
--- Class[Profile::Kafka::Broker].orig
+++ Class[Profile::Kafka::Broker]
@@
- inter_broker_protocol_version => 1.1.0
+ inter_broker_protocol_version => 3.7