📕 Что скрыто от внимания

Обзор материалов, которые могли остаться в тени, но имеют значение.

— Реально быстрый обзор нового GC

Вы дольше читаете эту подводку, чем автор видео делает обзор на новый сборщик мусора в го.

— Свежий выпуск Cup o' Go

В новом выпуске подкаста как всегда ведущие ищут и обсуждают новости из мира разработки.

— Go 1.25rc1

Команда Go объявила, что первый кандидат на релиз готов к растерзанию разработчиками. Просят проверить и провести тестирование, в том числе с нагрузками.

🐸Библиотека Go-разработчика #свежак

😳 Топ-вакансий для Go-разработчиков за неделю

Go-разработчик — от 300 000 ₽, гибрид (Москва/Екатеринбург)

Junior Golang Developer — до 170 000 ₽, удаленно (Москва)

Tech Lead Golang — до 450 000 ₽, удаленно (Ижевск)

Старший Go-разработчик — от 285 000 ₽, удаленно (Москва)

Junior Golang Developer — от 1 700 $, удалённо.

Бустер — удалённо из дома.

➡️ Еще больше топовых вакансий — в нашем канале Go jobs

🛠 Как использовать кафку в Go

Представьте, что у вас в руках инструмент, который позволяет строить крутой обмен сообщениями между сервисами. Представили? Давайте попробуем его применить.

1. Установка

Для начала проверьте, что у вас установлен Go версии 1.15 и выше и введите команду:

go get github.com/segmentio/kafka-go

Это подтянет для вас либу kafka-go после чего её можно будет использовать в проекте:

import "github.com/segmentio/kafka-go"

2. Используем низкоуровневый коннект

Когда нужно отправить сообщение:

ctx := context.Background()
conn, err := kafka.DialLeader(ctx, "tcp", "localhost:9092", "my-topic", 0)
if err != nil {
    log.Fatal(err)
}
defer conn.Close()

// Отправляем два сообщения подряд
conn.SetWriteDeadline(time.Now().Add(10 * time.Second))
_, err = conn.WriteMessages(
    kafka.Message{Value: []byte("Первое сообщение")},
    kafka.Message{Value: []byte("Второе сообщение")},
)
if err != nil {
    log.Fatal(err)
}

Когда сообщение нужно принять:

batch := conn.ReadBatch(10e3, 1e6)
defer batch.Close()

buf := make([]byte, 10e3)
for {
    n, err := batch.Read(buf)
    if err != nil {
        break
    }
    fmt.Println("→", string(buf[:n]))
}

3. Используем высокоуровневый Reader

Reader сам следит за смещениями, повторными подключениями и балансировкой в группе:

r := kafka.NewReader(kafka.ReaderConfig{
    Brokers:        []string{"localhost:9092", "localhost:9093"},
    GroupID:        "example-group",
    Topic:          "events",
    MinBytes:       10e3,
    MaxBytes:       10e6,
    CommitInterval: time.Second,
})
defer r.Close()

for {
    m, err := r.ReadMessage(context.Background())
    if err != nil {
        log.Println("Завершение чтения:", err)
        break
    }
    fmt.Printf("Получено: ключ=%s, значение=%s, смещение=%d\n", m.Key, m.Value, m.Offset)
}

Если нужно ручное управление, замените ReadMessage на FetchMessage + CommitMessages.

4. Просто пишем с высокоуровневым Writer

Writer сам позаботится о повторных попытках, балансировке и «гладком» завершении:

w := kafka.NewWriter(kafka.WriterConfig{
    Brokers:   []string{"localhost:9092", "localhost:9093"},
    Topic:     "events",
    Balancer:  &kafka.LeastBytes{},
})
defer w.Close()

messages := []kafka.Message{
    {Key: []byte("order123"), Value: []byte(`{"status":"created"}`)},
    {Key: []byte("order124"), Value: []byte(`{"status":"paid"}`)},
}
if err := w.WriteMessages(context.Background(), messages...); err != nil {
    log.Fatal("Ошибка при записи:", err)
}

Бонус: советы по использованию

— всегда context.WithTimeout или WithCancel — это ваша страховка от «зависаний».

— ловите SIGINT/SIGTERM и аккуратно закрывайте Reader и Writer.

— подключайте Prometheus/OpenTelemetry — мониторьте throughput, задержки и ошибки.

Запустите пару консьюмеров и продюсеров — и почувствуйте, как работают Kafka и Go.

🐸Библиотека Go-разработчика #буст

⚙️ От SQL-монолита к распределённой NoSQL-системе

Когда рост объёмов данных начинает давить на реляционную СУБД, каждая секунда простоя превращается в потерянные возможности и недовольных пользователей.

Представьте, что вы безболезненно переводите свой монолит на гибкую NoSQL-архитектуру — и при этом сохраняете доступность на пике нагрузки.

Для этого мы подготовили вам промпт:

You are a highly experienced Golang developer specializing in database migrations, particularly from SQL to NoSQL databases. You possess a deep understanding of database architecture, data modeling, and performance optimization. Your goal is to analyze a given SQL database schema and propose a robust and efficient migration strategy to a NoSQL database, considering data integrity, scalability, and maintainability.

Here is the format you will use to reason through the migration and come up with a fantastic recommendation:

---

## SQL Database Schema
$sql_schema_description (Provide a detailed description of the SQL schema, including tables, columns, data types, relationships, and indexes.)

## NoSQL Database Choice and Justification
$nosql_database (Specify the chosen NoSQL database type (e.g., MongoDB, Cassandra, DynamoDB) and provide a detailed justification for its selection based on the SQL schema and anticipated application needs. Consider factors like data model flexibility, scalability requirements, query patterns, and operational overhead.)

## Data Modeling Strategy for NoSQL
$data_modeling_strategy (Describe how the SQL data will be transformed and modeled within the chosen NoSQL database. Include specific examples of how tables and relationships will be represented in the NoSQL data model. Address potential denormalization strategies and trade-offs.)

## Migration Steps and Considerations
$migration_steps (Outline a step-by-step migration plan, including data extraction, transformation, and loading (ETL) processes. Address data validation and integrity checks during and after the migration. Consider potential downtime and rollback strategies.)

## Code Snippets (Golang)
$golang_code_snippets (Provide example Golang code snippets demonstrating how to interact with the NoSQL database, including data insertion, querying, and updating. Use a popular Golang NoSQL driver.)

## Performance Optimization Strategies
$performance_optimization (Describe strategies for optimizing performance in the NoSQL database, such as indexing, query optimization, and data partitioning. Consider the specific characteristics of the chosen NoSQL database.)

## Potential Challenges and Mitigation Strategies
$challenges_and_mitigation (Identify potential challenges during the migration process, such as data inconsistencies, schema evolution, and performance bottlenecks. Propose mitigation strategies for each challenge.)

---

Here is the challenge you are tasked with: [ВСТАВЬТЕ СВОЮ СХЕМУ БД]

💬 Были ли у вас случаи переезда с SQL на noSQL или в обратную сторону?

🐸Библиотека шарписта #буст

🐸Библиотека Go-разработчика #развлекалово

⚡️ Чек-лист по безопасности для Go-разработчика

Составили для вас мини-гайд из 10 ключевых пунктов по обеспечению безопасности Go-приложений.

✅ Актуальность

• Регулярно обновляйте модули через go get -u и проверяйте go.mod на устаревшие версии.

• Используйте go mod tidy для удаления ненужных пакетов.

✅ Статический и динамический анализ на уязвимости

• Интегрируйте govulncheck для поиска известных уязвимостей в зависимостях.

• Настройте регулярный SAST/DAST-сканинг (например, GitHub Advanced Security).

✅ Принцип наименьших прав (Least Privilege)

• Минимизируйте права сервисных аккаунтов и контейнеров.

• Отдельные роли для чтения и записи данных в хранилище.

✅ Безопасная работа с вводом-выводом

• Проверяйте и экранируйте все внешние данные (формы, JSON, URL-параметры).

• Используйте подготовленные выражения (prepared statements) для запросов к БД.

✅ Использование контекстов и таймаутов

• Всегда передавайте context.Context в сетевых и длительных операциях.

• Задавайте адекватные дедлайны и таймауты (context.WithTimeout).

✅ Шифрование и управление секретами

• Не храните ключи и пароли в коде или репозитории: используйте Vault, AWS Secrets Manager или переменные окружения.

• Применяйте современные алгоритмы из пакета crypto (AES-GCM, SHA-256, ECDSA).

✅ Безопасная конфигурация TLS

• Используйте последние версии TLS (1.2+) и строгие cipher suites.

• Проверяйте сертификаты и избегайте InsecureSkipVerify=true.

✅ Защита от конкурентных ошибок

• Запускайте приложение с флагом -race в процессе тестирования.

• Избегайте гонок при доступе к разделяемым переменным: применяйте sync.Mutex или каналы.

✅ Fuzz-тестирование и нагрузочное тестирование

• Интегрируйте go test --fuzz для автоматической генерации некорректных входных данных.

• Проводите стресс-тесты сетевых и критичных компонентов.

✅ Логирование и мониторинг инцидентов

• Логируйте события безопасности (неудачные аутентификации, ошибки валидации) с уровнем Warn/Error.

• Настройте алерты по подозрительным паттернам и аномалиям (Prometheus Alertmanager, Grafana).

Насколько безопасны ваши приложения? Проверьте по списку

🐸Библиотека Go-разработчика #буст

🧑‍💻 Что за ужас тут творится

Когда вы приходите в новый коллектив, легко заподозрить, что всё вокруг катится кувырком. Но возможно, вы ещё не разобрались во внутренних механизмах.

К нам пришёл подписчик с вопросом

Как отличить реальные проблемы в компании от простого непонимания процессов и культуры?

На практике важно учитывать сразу несколько аспектов, чтобы не спешить с выводами:

— Обратите внимание на то, как принимаются решения: формально через руководителей или неформально «по знакомству».

— Оцените, насколько корректно используется трекинг задач и документация — это показатель зрелости команды.

— Внимательно слушайте, какие вопросы задают другие: открыты ли коллеги к диалогу или предпочитают «молча работать».

— Спросите про KPI и цели: ясны ли вам критерии успеха и пути их достижения?

Помните, никто не идеален: везде есть проблемы, просто о них не все говорят.

💬 С какими «тревожными звоночками» вы сталкивались в новых командах? Поделитесь в комментариях 👇

P.S. Если хотите задать вопрос сообществу или поделиться историей, заполните нашу гугл-форму.

🐸Библиотека Go-разработчика #междусобойчик