Please enable JavaScript.

Coggle requires JavaScript to display documents.

Kafka (Пользователи (производители (генераторы) producers/publishers/writ…

- - - - «Сделать и забыть»
      - Синхронная
        (send () возвращает фьючерс)
      - Асинхронная
        (send() получает функцию
        обратного вызова)
    - - acks
        
        0
        произв не ждёт ответа от брокера
        
        1
        получает ответ при получении
        сообщения ведущей репликой
        
        all
        после успешного получения всеми репликами
      - buffer.memory
      - compression.type
        snappy/gzip/lz4
      - retries
      - batch.size
        объём памяти в байтах для
        пакета сообщений
      - linger.ms
        длительность ожидания доп
        сообщений перед отправкой
        пакета
      - client.id
      - max.in.flight.requests.in.connection
        1 гарантирует запись в брокер в
        порядке отправки
      - timeout.ms
        длительность ожидания ответа
        от сервера
      - max.block.ms
        длительность блокировки при
        вызове send()
      - max.request.size
      - receive.buffer.bytes
        send.buffer.bytes
- - - - может содержать ключ (key)
        с метаданными
        
        смещение (offset)