serdarmumcu

package com.yazilimmimari.hackerrank;

import java.util.LinkedHashMap;
import java.util.Map;

public class LRUCache<S,T> {
    LinkedHashMap<S,T> cache;
    int capacity;
    LRUCache(int capacity) {
        cache = new LinkedHashMap<>(capacity);

serdarmumcu

package com.yazilimmimari.hackerrank;


import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Objects;

public class LFUCache<S,T> {

    public class Node<S,T>

serdarmumcu

package com.yazilimmimari.hackerrank;

import java.util.LinkedHashMap;
import java.util.Map;

public class FIFOCache<S,T> {
    LinkedHashMap<S,T> cache;
    int capacity;
    FIFOCache(int capacity) {
        cache = new LinkedHashMap<>(capacity);

serdarmumcu

package com.yazilimmimari.hackerrank;

import java.util.*;

public class RandomCache<S,T> {
    HashMap<S,T> cache;
    int capacity;
    RandomCache(int capacity) {
        cache = new HashMap<>(capacity);
        this.capacity = capacity;

serdarmumcu

@Service
public class DataService {

    @Autowired
    private DatabaseRepository databaseRepository;

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    @Transactional

serdarmumcu

@RestController
public class MessageController {
    @Autowired
    private MessageRepository messageRepository;
    @Autowired
    private OutboxRepository outboxRepository;

    private final ObjectMapper objectMapper = new ObjectMapper();

    @PostMapping("/messages")

serdarmumcu

@Service
public class EventPublisherService {
    @Autowired
    private OutboxRepository outboxRepository;

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    @Scheduled(fixedRate = 10000) // Every 10 seconds
    public void publishEvents() {

serdarmumcu

@Service
public class EventPublisherService {

    @Autowired
    private OutboxRepository outboxRepository;

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    @Autowired

serdarmumcu

@Service
public class EventProcessingService {

    @Autowired
    private OutboxRepository outboxRepository;

    @Transactional
    public void deleteProcessedEvents(List<Long> eventIds) {
        if (!eventIds.isEmpty()) {
            outboxRepository.deleteAllByIdIn(eventIds);

serdarmumcu

@Configuration
public class KafkaProducerConfig {

    @Bean
    public ProducerFactory<String, String> producerFactory() {
        Map<String, Object> configProps = new HashMap<>();
        ...
        configProps.put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, true);
        ...