amalgame-kafka

Vue d'ensemble

Kafka est l'épine dorsale d'innombrables pipelines event-streaming. Le package se lie dynamiquement à librdkafka — le client C de référence (utilisé aussi par Python, Ruby, Node.js). Compatible Apache Kafka, Confluent, Redpanda, Aiven, AWS MSK.

Caractéristiques

• ✓Producer avec batching et compression (gzip/snappy/lz4/zstd)
• ✓Consumer avec offset management et consumer groups
• ✓Compatible : Apache Kafka, Confluent, Redpanda, Aiven, AWS MSK
• ✓TLS + SASL/SCRAM via la chaîne librdkafka
• ✓Pattern dynamic-link — pas de fork à maintenir

Exemple

Exemple minimal d'utilisation — recopiable tel quel après l'install.

amc package add kafka

let p = KafkaProducer.New("broker1:9092,broker2:9092")
p.Send("user-events", "user-42", "{ action: 'login' }")

let c = KafkaConsumer.Subscribe(["user-events"], "my-group")
c.OnMessage(fn(topic, key, value) {
    Console.WriteLine(topic + "/" + key + " → " + value)
})

Packages liés