Я унаследовал устаревшую систему kafka версии 0.8.2. Сейчас я пытаюсь обновить систему до чего-то более современного. Я знаю, что не могу сразу перейти с 0.8.2 на что-то более старое, но я надеялся постепенно переносить систему.
Проблема в том, что когда я пытаюсь сделать что-то простое, например, перейти с 0.8.2 на 0.9.0, выдается ошибка.
java.lang.IllegalArgumentException: требование не выполнено: log.message.format.version 0.9.0 не может использоваться, если для inter.broker.protocol.version установлено значение 0.8.2
Я надеюсь, что кто-нибудь скажет мне, что я неправильно сконфигурировал или чего не хватает в конфигурации моего сервера.
Мой файл server.properties в версии 0.10.0 содержит:
############################# Server Basics #############################
broker.id=0
auto.create.topics.enable=true
inter.broker.protocol.version=0.8.2
log.message.format.version=0.9.0
############################# Socket Server Settings #############################
#advertised.listeners=PLAINTEXT://your.host.name:9092
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
############################# Log Basics #############################
num.partitions=1
num.recovery.threads.per.data.dir=1
############################# Log Flush Policy #############################
#log.flush.interval.messages=10000
#log.flush.interval.ms=1000
############################# Log Retention Policy #############################
log.retention.hours=168
log segment will be created.
log.segment.bytes=1073741824
deleted according
log.retention.check.interval.ms=300000
############################# Zookeeper #############################
zookeeper.connect=localhost:2181
# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000
Спасибо за любую помощь.