Во время тестирования я делаю некоторую операцию, например, удаляю тему. Однако я могу видеть тему сразу после ее удаления.
Использование: bin / kafka-topics.sh --list --zookeeper localhost: 2181 Для фактического удаления требуется некоторое время.
Это меня смутило.
Точно так же, когда я создаю данные, я не могу использовать их немедленно, но мне нужно подождать некоторое время и повторно запустить команду потребления для потребления данных.
Это потому, что я использую настроенную kafka с одним узлом, и я слишком тщательно ее тестирую.