ACK (acknowledgment) — подтверждение от Kafka брокера, что сообщение успешно получено и записано. Kafka поддерживает 3 уровня подтверждения: 0 - Продюсер не ждёт подтверждения (возможна потеря сообщений). 1 - Брокер-лидер партиции подтверждает получение.
all / -1 - Сообщение считается принятым, когда все ISR (in-sync replicas) подтвердят запись. Это наиболее надежный вариант. goКопироватьРедактироватьw := kafka.NewWriter(kafka.WriterConfig{
Brokers: []string{"localhost:9092"},
Topic: "example-topic",
RequiredAcks: kafka...
Работает в FIFO - просто последовательный лог, пишем на диск в одном стриме (sequential write), читаем не удаляя сообщения (а перемещаем offset на каждую группу). Да, можно! Ты можешь явно указать, что консьюмер должен читать только из конкретной партиции топика, не участвуя в балансировке через Consumer Group. Пример на Java: consumer.assign(Arrays.asList(new TopicPartition("my-topic", 0))); Или в Go (с использованием segmentio/kafka-go, например): r := kafka...
1. Архитектура и модель данных 2. Сильные стороны 3. Типичные сценарии 4. Что же выбрать ScyllaDB или CockroachDB? CockroachDB оптимален там, где нужны: Иными словами, CockroachDB стоит выбирать, если вы хотите преимущества...
Ключевые различия: CockroachDB лучше подходит для распределённых (multi-region) систем с высокой нагрузкой на запись, когда важна горизонтальная масштабируемость и автоматическая репликация данных без сложных кластерных надстроек. PostgreSQL обычно эффективнее на одном узле или в классической репликации, особенно при сложных запросах и транзакциях...
7 месяцев назад
Если нравится — подпишитесь
Так вы не пропустите новые публикации этого канала