{"@context":"https://w3id.org/codemeta/3.0","@type":"SoftwareSourceCode","identifier":"pkg:golang/github.com/2lambda123/sarama","name":"github.com/2lambda123/sarama","description":"Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later). It includes a high-level\nAPI for easily producing and consuming messages, and a low-level API for controlling bytes on the wire when the high-level\nAPI is insufficient. Usage examples for the high-level APIs are provided inline with their full documentation.\n\nTo produce messages, use either the AsyncProducer or the SyncProducer. The AsyncProducer accepts messages on a channel\nand produces them asynchronously in the background as efficiently as possible; it is preferred in most cases.\nThe SyncProducer provides a method which will block until Kafka acknowledges the message as produced. This can be\nuseful but comes with two caveats: it will generally be less efficient, and the actual durability guarantees\ndepend on the configured value of `Producer.RequiredAcks`. There are configurations where a message acknowledged by the\nSyncProducer can still sometimes be lost.\n\nTo consume messages, use the Consumer. Note that Sarama's Consumer implementation does not currently support automatic\nconsumer-group rebalancing and offset tracking. For Zookeeper-based tracking (Kafka 0.8.2 and earlier), the\nhttps://github.com/wvanbergen/kafka library builds on Sarama to add this support. For Kafka-based tracking (Kafka 0.9\nand later), the https://github.com/bsm/sarama-cluster library builds on Sarama to add this support.\n\nFor lower-level needs, the Broker and Request/Response objects permit precise control over each connection\nand message sent on the wire; the Client provides higher-level metadata management that is shared between\nthe producers and the consumer. The Request/Response objects and properties are mostly undocumented, as they line up\nexactly with the protocol fields documented by Kafka at\nhttps://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol\n\nMetrics are exposed through https://github.com/rcrowley/go-metrics library in a local registry.\n\nBroker related metrics:\n\nNote that we do not gather specific metrics for seed brokers but they are part of the \"all brokers\" metrics.\n\nProducer related metrics:","version":"v1.38.1","softwareVersion":"v1.38.1","license":"https://spdx.org/licenses/MIT","codeRepository":"https://github.com/2lambda123/sarama","issueTracker":"https://github.com/2lambda123/sarama/issues","url":"https://github.com/2lambda123/sarama","programmingLanguage":{"@type":"ComputerLanguage","name":"Go"},"dateCreated":"2015-03-17","dateModified":"2023-01-20","datePublished":"2023-01-20","copyrightYear":2015,"downloadUrl":"https://proxy.golang.org/github.com/2lambda123/sarama/@v/v1.38.1.zip","softwareHelp":{"@type":"WebSite","url":"https://pkg.go.dev/github.com/2lambda123/sarama#section-documentation"},"applicationCategory":"go","runtimePlatform":"go","developmentStatus":"active","sameAs":["https://pkg.go.dev/github.com/2lambda123/sarama"]}