Я пытаюсь удалить записи kafka из темы, выполнив следующие действия:
bin/kafka-delete-records.sh --bootstrap-server myserver:myport --offset-json-file offset.json
мой offset.json выглядит следующим образом:
{"partitions": [{"topic": "mytopic", "partition": 0, "offset": 127}], "version":1}
Когда я запускаю скрипт, яполучите сообщение ниже:
➜ local-kafka_2.12-2.0.0 bin/kafka-delete-records.sh --bootstrap-server myip:myport --offset-json-file offset.json
Executing records delete operation
Records delete operation completed:
[2019-02-02 16:54:24,867] WARN [AdminClient clientId=adminclient-1] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
partition: mytopic-0 error: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
Я замечаю, что записи на самом деле не удаляются, когда я запускаю kafka-consumer-group.sh
Мои настройки следующие:
Вопрос
- Чего мне не хватает?Почему записи кафки из тем не удаляются?