Назад | Перейти на главную страницу

Ошибка миграции kafka при попытке обновить поток данных

Я унаследовал устаревшую систему 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

Спасибо за любую помощь.