Как сбросить кафку, чтобы интегрировать ее в процесс тестирования JUnit?

Существуют различные подходы к очистке отдельных тем. Все они могут быть расширены до очистки всех ваших тем. Тем не менее, я думаю, вы задаете более широкий вопрос, связанный с созданием базовой среды для Kafka — что-то, что вам, возможно, понадобится для тестирования. Или, может быть, у вас есть производственный процесс, который каждый раз начинается с нуля. На самом деле это разные сценарии.

Для тестирования

Если бы вы говорили о тестировании, то я бы специально сделал что-то грубое. Во-первых, я бы настроил Kafka так, как мне хотелось бы, чтобы она выглядела при запуске. Затем я бы выключил его и создал резервную копию - либо с помощью tar, либо, возможно, даже создав образ диска, если я использую виртуальную машину.

Я использовал его и злоупотреблял им во время тестирования, а затем выбрасывал все это, когда я был готов. «Сброс kafka» будет просто означать восстановление либо через untar, либо с образа диска, либо как-то еще (даже rsync или просто cp из другого каталога).

Для тестирования мне очень нужно чистое начало, поэтому я предпочитаю грубую силу.

Во время производства

Если это часть ваших производственных процессов — и я сомневаюсь в разумности этого на первый взгляд — тогда я бы постарался сначала не потерять данные. Либо включите резервную копию в свой процесс, либо фактически не сбрасывайте темы.

Переименование темы еще не существует -- но вы можете использовать тот же подход, который будет использоваться. Не работайте напрямую с названиями тем — используйте словарь для сопоставления виртуальных названий тем с реальными названиями тем.

Затем, вместо того, чтобы каждый раз «сбрасывать» Kafka, создайте новые версии всех тем и обновите словарь, чтобы сопоставить имя виртуальной темы с вновь созданными версиями темы.