Ваше смещение сообщения не будет увеличено, если вы не будете запрашивать новые сообщения. Поэтому вы должны быть обеспокоены повторной обработкой своего сообщения.
Если вы хотите сохранить результат обработки данных в кластере Kafka, вы можете использовать функцию транзакции Kafka . Таким образом, вы можете поддерживать только один раз доставки. Все ваши изменения будут сохранены или ни одно из них не будет сохранено.
Другой подход - сделать ваш сценарий обработки идемпотентным. Вы будете назначать уникальный идентификатор для каждого сообщения в Kafka. При обработке сообщения вы сохраняете идентификатор в базе данных. После сбоя вы проверяете, что ваш идентификатор сообщения уже обработан, просматривая базу данных.
Большинство IDE генерирует тупики метода тестирования для любого класса. Я знаю, что Eclipse будет.
Новый-> Класс JUnit тогда Вы говорите это, какой класс Вы тестируете и какие методы Вы хотите протестировать.
Я пытался получить выполнение TestGen4j, но похоже, что это не сохранялось :( Возможно, Вы даете этому попытку?
Agitar имел бесплатный сервис, который позволил Вам делать это (Вы должны были быть готовы позволить ему отправить Ваш код на их серверы).
, Если Вы использовали scala, существует "scala проверка" - но я не уверен, как хорошо это работает с источником Java (даже при том, что его весь код байта).