Ошибка создания топика (Kafka)
При выполнении Get запроса с пагинацией возникает ошибка создания топика в микросервисном приложении.
Код запроса:
@GetMapping
@Operation(summary = "Get all habits", description = "Retrieves a list of all habits.")
@ApiResponse(responseCode = "200", description = "List of habits retrieved successfully",
content = @Content(mediaType = "application/json", schema = @Schema(implementation = HabitDto.class, type = "array")))
public ResponseEntity<List<HabitDto>> getAllHabits(
@RequestParam(required = false, defaultValue = "0") int page,
@RequestParam(required = false, defaultValue = "10")int size,
@RequestParam(required = false, defaultValue = "id") String sort
) {
String[] sortParams = sort.split(",");
Sort sortOrder;
if (sortParams.length > 1 && "desc".equalsIgnoreCase(sortParams[1])) {
sortOrder = Sort.by(sortParams[0]).descending(); // Сортировка по убыванию
} else {
sortOrder = Sort.by(sortParams[0]).ascending(); // Сортировка по возрастанию
}
PageRequest pageRequest = PageRequest.of(page, size, sortOrder);
Page<Habit> habitsPage = habitServiceImpl.getAllHabits(pageRequest);
List<HabitDto> dtos = habitsPage.getContent().stream()
.map(HabitMapper::toDto)
.toList();
return ResponseEntity.ok(dtos);
}
Тут метод getAllHabits
выдаёт список всех "привычек" у пользователя. И они возвращаются с пагинацией.
В ходе запуска микросервиса выпадает такая ошибка:
org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 2 larger than available brokers: 1.
Как это можно исправить?