Tell about your last project — what it is about, what exactly you do there?

In my last project, I worked on a high-load microservice in Go that processes streaming data in real-time for an analytics platform. My main responsibilities included developing and optimizing message processing algorithms from Kafka, ensuring the reliability and scalability of the service.

I was involved in designing the architecture, writing code for parsing and aggregating data, as well as implementing monitoring and logging. Additionally, I participated in setting up CI/CD, ensuring test coverage, and conducting code reviews with colleagues.

Example code for processing messages from Kafka using Sarama:

consumer, err := sarama.NewConsumer(brokers, nil)
if err != nil {
    log.Fatal(err)
}
partitionConsumer, err := consumer.ConsumePartition(topic, 0, sarama.OffsetNewest)
if err != nil {
    log.Fatal(err)
}

go func() {
    for msg := range partitionConsumer.Messages() {
        processMessage(msg.Value)
    }
}()