Utilizing Redis Streams for Event Logging in Java Using Lettuce

import io.lettuce.core.RedisClient;
import io.lettuce.core.api.StatefulRedisConnection;
import io.lettuce.core.api.sync.RedisStreamCommands;
import io.lettuce.core.StreamMessage;
import io.lettuce.core.XReadArgs.StreamOffset;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class Main {

    public static void main(String[] args) {
        // Connect to Redis
        RedisClient redisClient = RedisClient.create("redis://localhost:6379/");
        StatefulRedisConnection<String, String> connection = redisClient.connect();
        RedisStreamCommands<String, String> syncCommands = connection.sync();

        // Example usage
        String streamName = "user_activity_stream";

        // Add entries to the stream
        Map<String, String> messageBody1 = new HashMap<>();
        messageBody1.put("event", "login");
        messageBody1.put("username", "alice");
        syncCommands.xadd(streamName, messageBody1);

        Map<String, String> messageBody2 = new HashMap<>();
        messageBody2.put("event", "login");
        messageBody2.put("username", "bob");
        syncCommands.xadd(streamName, messageBody2);

        // Read entries from the stream
        List<StreamMessage<String, String>> messages = syncCommands.xread(
        StreamOffset.from(streamName, "0"));

        for (StreamMessage<String, String> message : messages) {
            System.out.println("Stream entry: " + message.getBody());
        }

        // Close the connection
        connection.close();
        redisClient.shutdown();
    }
}