Conversation
| private String bootstrapServers; | ||
|
|
||
| @Bean | ||
| public ProducerFactory<String, PostEvent> postKafkaProducerFactory() { |
There was a problem hiding this comment.
Здесь может универсальный ProducerFactory сделать, чтоб не создавать бин под каждое событие?
There was a problem hiding this comment.
Да, ты прав. Павел просил не делать универсальным в Consumer. А в Produser можно сделать и универсальным. Сейчас поменяю.
| } | ||
|
|
||
| @Bean | ||
| public KafkaTemplate<String, PostEvent> postKafkaTemplate( |
There was a problem hiding this comment.
Ну и здесь тоже, отдельный template для эвента
| @Transactional | ||
| public boolean publishPost(long requesterId, long postId) { | ||
| public void publishPost(long requesterId, long postId) { | ||
| Optional<Post> optionalPostToPublish = postRepository.findById(postId); |
There was a problem hiding this comment.
можно заменить:
Post post = postRepository.findById(postId)
.orElseThrow(() -> new EntityNotFoundException(
"Данный пост не существует, его невозможно опубликовать."
));
There was a problem hiding this comment.
Можно ) Это - очень старый код (первая половина октября), когда я увидел его, я всерьез задумался о том, чтобы полностью переписать его под чистую, тут все очень плохо. Я сел, внимательно посчитал примерное время на это и профит, и решил не тратить на это 1-2 дня, поскольку там придется и контроллер переписывать, и маппер, и все тесты.
| postRepository.save(postToPublish); | ||
| log.info("Пост с id: {} успешно опубликован пользователем с id: {}.", postId, requesterId); | ||
| return true; | ||
| List<Long> followerIds = userServiceClient.getFollowers(requesterId).stream() |
There was a problem hiding this comment.
тут вижу только проблему в том что userServiceClient может вернуть ну очень большой список и надо работать с пагинацие, но если там ее нет то ок
3 participants
No description provided.