An open API service for producing an overview of a list of open source projects.

https://github.com/IBM/sarama

go kafka kafka-client

Score: 36.79180545244953

Last synced: about 21 hours ago
JSON representation

Repository metadata:

Sarama is a Go library for Apache Kafka.


Owner metadata:


GitHub Events

Total
Last Year

Committers metadata

Last synced: 3 days ago

Total Commits: 2,647
Total Committers: 318
Avg Commits per committer: 8.324
Development Distribution Score (DDS): 0.805

Commits in past year: 232
Committers in past year: 21
Avg Commits per committer in past year: 11.048
Development Distribution Score (DDS) in past year: 0.724

Name Email Commits
Evan Huus e****e@g****m 516
Dominic Evans d****s@u****m 402
Evan Huus e****s@j****m 224
dependabot[bot] 4****] 193
Willem van Bergen w****m@v****g 160
Vlad Gorodetsky v****@g****o 91
Burke Libbey b****e@l****e 69
Mark Hindess m****s@g****m 54
Diego Alvarez d****z@s****m 45
renovate[bot] 2****] 43
Vlad Hanciuta v****d@a****m 34
Maxim Vladimirskiy h****e@g****m 30
Mike Kaminski m****i@g****m 28
Dimitrij Denissenko d****o@b****m 26
Sebastien Launay s****n@o****m 20
FrancoisPoinsot g****t@g****m 18
Varun v****r@m****m 17
Ivan Babrou i****k@g****m 14
Robin r****n@f****e 13
Aaron Kavlie a****e@w****m 13
Edoardo Comar e****r@u****m 12
Scott Kidder s****t@m****m 11
AJ Yoo a****n@a****m 11
KJ Tsanaktsidis k****s@z****m 10
DiSiqueira d****0@l****m 9
Adrian Preston p****a 9
Jacob-bzx b****9@g****m 9
Shriram Rajagopalan s****m@u****m 9
Lars Lehtonen l****n@g****m 9
unknown w****1@g****m 9
and 288 more...

Issue and Pull Request metadata

Last synced: 1 day ago

Total issues: 382
Total pull requests: 797
Average time to close issues: over 1 year
Average time to close pull requests: about 1 month
Total issue authors: 314
Total pull request authors: 91
Average comments per issue: 3.5
Average comments per pull request: 0.72
Merged pull request: 378
Bot issues: 11
Bot pull requests: 490

Past year issues: 51
Past year pull requests: 258
Past year average time to close issues: 3 months
Past year average time to close pull requests: 7 days
Past year issue authors: 41
Past year pull request authors: 24
Past year average comments per issue: 1.82
Past year average comments per pull request: 0.48
Past year merged pull request: 101
Past year bot issues: 6
Past year bot pull requests: 163

More stats: https://issues.ecosyste.ms/repositories/lookup?url=https://github.com/IBM/sarama

Top Issue Authors

  • dnwe (10)
  • bentcoder (6)
  • ajeyprasad (5)
  • dependabot[bot] (5)
  • yitian108 (5)
  • gunli (4)
  • ppatierno (4)
  • renovate[bot] (4)
  • shubham-dogra-s1 (3)
  • gopherhiro (3)
  • 3AceShowHand (3)
  • llamahunter (2)
  • wenyihu6 (2)
  • chaithraav (2)
  • HaoSunUber (2)

Top Pull Request Authors

  • dependabot[bot] (427)
  • dnwe (106)
  • renovate[bot] (61)
  • hindessm (25)
  • richardartoul (8)
  • ae-govau (6)
  • wanwenli (6)
  • 3AceShowHand (6)
  • trapped (6)
  • prestona (6)
  • Gorgonx7 (4)
  • kasimtj (4)
  • liutao365 (4)
  • Sergey-Belyakov (4)
  • puellanivis (3)

Top Issue Labels

  • stale (210)
  • needs-investigation (66)
  • bug (25)
  • stale/exempt (23)
  • enhancement (9)
  • v2 (5)
  • Feature request (5)
  • dependencies (4)
  • help wanted (3)
  • question (3)
  • maintenance (2)
  • protocol (2)
  • documentation (2)
  • bug :-( (1)
  • docs (1)
  • producer (1)
  • needs-more-info (1)
  • go (1)
  • ignore-for-release (1)
  • regression (1)

Top Pull Request Labels

  • ignore-for-release (263)
  • dependencies (222)
  • fix (56)
  • stale (53)
  • chore (33)
  • feat (23)
  • bump/minor (12)
  • ci (9)
  • bump/patch (8)
  • needs-investigation (8)
  • go (6)
  • docker (6)
  • docs (5)
  • bump/digest (5)
  • bump/major (4)
  • tests (4)
  • internal (4)
  • v2 (3)
  • stale/exempt (2)
  • performance (1)
  • github-actions (1)
  • go1.21 (1)
  • housekeeping (1)
  • maintenance (1)
  • documentation (1)

Package metadata

proxy.golang.org: github.com/IBM/sarama

Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later). It includes a high-level API for easily producing and consuming messages, and a low-level API for controlling bytes on the wire when the high-level API is insufficient. Usage examples for the high-level APIs are provided inline with their full documentation. To produce messages, use either the AsyncProducer or the SyncProducer. The AsyncProducer accepts messages on a channel and produces them asynchronously in the background as efficiently as possible; it is preferred in most cases. The SyncProducer provides a method which will block until Kafka acknowledges the message as produced. This can be useful but comes with two caveats: it will generally be less efficient, and the actual durability guarantees depend on the configured value of `Producer.RequiredAcks`. There are configurations where a message acknowledged by the SyncProducer can still sometimes be lost. To consume messages, use Consumer or Consumer-Group API. For lower-level needs, the Broker and Request/Response objects permit precise control over each connection and message sent on the wire; the Client provides higher-level metadata management that is shared between the producers and the consumer. The Request/Response objects and properties are mostly undocumented, as they line up exactly with the protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol Metrics are exposed through https://github.com/rcrowley/go-metrics library in a local registry. Broker related metrics: Note that we do not gather specific metrics for seed brokers but they are part of the "all brokers" metrics. Producer related metrics: Consumer related metrics:

  • Homepage: https://github.com/IBM/sarama
  • Documentation: https://pkg.go.dev/github.com/IBM/sarama#section-documentation
  • Licenses: MIT
  • Latest release: v1.47.0 (published about 1 month ago)
  • Last Synced: 2026-03-27T10:01:21.281Z (3 days ago)
  • Versions: 83
  • Dependent Packages: 195
  • Dependent Repositories: 6
  • Docker Downloads: 2,360,422,712
  • Rankings:
    • Forks count: 0.581%
    • Stargazers count: 0.621%
    • Docker downloads count: 1.848%
    • Dependent repos count: 2.128%
    • Average: 2.726%
    • Dependent packages count: 8.453%
proxy.golang.org: github.com/ibm/Sarama

Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later). It includes a high-level API for easily producing and consuming messages, and a low-level API for controlling bytes on the wire when the high-level API is insufficient. Usage examples for the high-level APIs are provided inline with their full documentation. To produce messages, use either the AsyncProducer or the SyncProducer. The AsyncProducer accepts messages on a channel and produces them asynchronously in the background as efficiently as possible; it is preferred in most cases. The SyncProducer provides a method which will block until Kafka acknowledges the message as produced. This can be useful but comes with two caveats: it will generally be less efficient, and the actual durability guarantees depend on the configured value of `Producer.RequiredAcks`. There are configurations where a message acknowledged by the SyncProducer can still sometimes be lost. To consume messages, use the Consumer. Note that Sarama's Consumer implementation does not currently support automatic consumer-group rebalancing and offset tracking. For Zookeeper-based tracking (Kafka 0.8.2 and earlier), the https://github.com/wvanbergen/kafka library builds on Sarama to add this support. For Kafka-based tracking (Kafka 0.9 and later), the https://github.com/bsm/sarama-cluster library builds on Sarama to add this support. For lower-level needs, the Broker and Request/Response objects permit precise control over each connection and message sent on the wire; the Client provides higher-level metadata management that is shared between the producers and the consumer. The Request/Response objects and properties are mostly undocumented, as they line up exactly with the protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol Metrics are exposed through https://github.com/rcrowley/go-metrics library in a local registry. Broker related metrics: Note that we do not gather specific metrics for seed brokers but they are part of the "all brokers" metrics. Producer related metrics:

  • Homepage: https://github.com/ibm/Sarama
  • Documentation: https://pkg.go.dev/github.com/ibm/Sarama#section-documentation
  • Licenses: MIT
  • Latest release: v1.47.0 (published about 1 month ago)
  • Last Synced: 2026-03-27T10:01:21.586Z (3 days ago)
  • Versions: 83
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Forks count: 0.747%
    • Stargazers count: 0.752%
    • Average: 3.062%
    • Dependent packages count: 5.199%
    • Dependent repos count: 5.548%
proxy.golang.org: github.com/IBM/SARAMA

Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later). It includes a high-level API for easily producing and consuming messages, and a low-level API for controlling bytes on the wire when the high-level API is insufficient. Usage examples for the high-level APIs are provided inline with their full documentation. To produce messages, use either the AsyncProducer or the SyncProducer. The AsyncProducer accepts messages on a channel and produces them asynchronously in the background as efficiently as possible; it is preferred in most cases. The SyncProducer provides a method which will block until Kafka acknowledges the message as produced. This can be useful but comes with two caveats: it will generally be less efficient, and the actual durability guarantees depend on the configured value of `Producer.RequiredAcks`. There are configurations where a message acknowledged by the SyncProducer can still sometimes be lost. To consume messages, use the Consumer. Note that Sarama's Consumer implementation does not currently support automatic consumer-group rebalancing and offset tracking. For Zookeeper-based tracking (Kafka 0.8.2 and earlier), the https://github.com/wvanbergen/kafka library builds on Sarama to add this support. For Kafka-based tracking (Kafka 0.9 and later), the https://github.com/bsm/sarama-cluster library builds on Sarama to add this support. For lower-level needs, the Broker and Request/Response objects permit precise control over each connection and message sent on the wire; the Client provides higher-level metadata management that is shared between the producers and the consumer. The Request/Response objects and properties are mostly undocumented, as they line up exactly with the protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol Metrics are exposed through https://github.com/rcrowley/go-metrics library in a local registry. Broker related metrics: Note that we do not gather specific metrics for seed brokers but they are part of the "all brokers" metrics. Producer related metrics:

  • Homepage: https://github.com/IBM/SARAMA
  • Documentation: https://pkg.go.dev/github.com/IBM/SARAMA#section-documentation
  • Licenses: MIT
  • Latest release: v1.47.0 (published about 1 month ago)
  • Last Synced: 2026-03-27T10:03:55.063Z (3 days ago)
  • Versions: 83
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Forks count: 0.58%
    • Stargazers count: 0.619%
    • Average: 5.011%
    • Dependent packages count: 8.453%
    • Dependent repos count: 10.392%
proxy.golang.org: github.com/Ibm/sarama

Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later). It includes a high-level API for easily producing and consuming messages, and a low-level API for controlling bytes on the wire when the high-level API is insufficient. Usage examples for the high-level APIs are provided inline with their full documentation. To produce messages, use either the AsyncProducer or the SyncProducer. The AsyncProducer accepts messages on a channel and produces them asynchronously in the background as efficiently as possible; it is preferred in most cases. The SyncProducer provides a method which will block until Kafka acknowledges the message as produced. This can be useful but comes with two caveats: it will generally be less efficient, and the actual durability guarantees depend on the configured value of `Producer.RequiredAcks`. There are configurations where a message acknowledged by the SyncProducer can still sometimes be lost. To consume messages, use the Consumer. Note that Sarama's Consumer implementation does not currently support automatic consumer-group rebalancing and offset tracking. For Zookeeper-based tracking (Kafka 0.8.2 and earlier), the https://github.com/wvanbergen/kafka library builds on Sarama to add this support. For Kafka-based tracking (Kafka 0.9 and later), the https://github.com/bsm/sarama-cluster library builds on Sarama to add this support. For lower-level needs, the Broker and Request/Response objects permit precise control over each connection and message sent on the wire; the Client provides higher-level metadata management that is shared between the producers and the consumer. The Request/Response objects and properties are mostly undocumented, as they line up exactly with the protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol Metrics are exposed through https://github.com/rcrowley/go-metrics library in a local registry. Broker related metrics: Note that we do not gather specific metrics for seed brokers but they are part of the "all brokers" metrics. Producer related metrics:

  • Homepage: https://github.com/Ibm/sarama
  • Documentation: https://pkg.go.dev/github.com/Ibm/sarama#section-documentation
  • Licenses: MIT
  • Latest release: v1.47.0 (published about 1 month ago)
  • Last Synced: 2026-03-27T10:02:44.049Z (3 days ago)
  • Versions: 83
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Forks count: 0.582%
    • Stargazers count: 0.621%
    • Average: 5.167%
    • Dependent packages count: 8.899%
    • Dependent repos count: 10.567%
proxy.golang.org: github.com/IBm/sarama

Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later). It includes a high-level API for easily producing and consuming messages, and a low-level API for controlling bytes on the wire when the high-level API is insufficient. Usage examples for the high-level APIs are provided inline with their full documentation. To produce messages, use either the AsyncProducer or the SyncProducer. The AsyncProducer accepts messages on a channel and produces them asynchronously in the background as efficiently as possible; it is preferred in most cases. The SyncProducer provides a method which will block until Kafka acknowledges the message as produced. This can be useful but comes with two caveats: it will generally be less efficient, and the actual durability guarantees depend on the configured value of `Producer.RequiredAcks`. There are configurations where a message acknowledged by the SyncProducer can still sometimes be lost. To consume messages, use the Consumer. Note that Sarama's Consumer implementation does not currently support automatic consumer-group rebalancing and offset tracking. For Zookeeper-based tracking (Kafka 0.8.2 and earlier), the https://github.com/wvanbergen/kafka library builds on Sarama to add this support. For Kafka-based tracking (Kafka 0.9 and later), the https://github.com/bsm/sarama-cluster library builds on Sarama to add this support. For lower-level needs, the Broker and Request/Response objects permit precise control over each connection and message sent on the wire; the Client provides higher-level metadata management that is shared between the producers and the consumer. The Request/Response objects and properties are mostly undocumented, as they line up exactly with the protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol Metrics are exposed through https://github.com/rcrowley/go-metrics library in a local registry. Broker related metrics: Note that we do not gather specific metrics for seed brokers but they are part of the "all brokers" metrics. Producer related metrics:

  • Homepage: https://github.com/IBm/sarama
  • Documentation: https://pkg.go.dev/github.com/IBm/sarama#section-documentation
  • Licenses: MIT
  • Latest release: v1.47.0 (published about 1 month ago)
  • Last Synced: 2026-03-27T10:03:52.298Z (3 days ago)
  • Versions: 83
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Forks count: 0.582%
    • Stargazers count: 0.621%
    • Average: 5.167%
    • Dependent packages count: 8.899%
    • Dependent repos count: 10.567%
proxy.golang.org: github.com/IBM/Sarama

Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later). It includes a high-level API for easily producing and consuming messages, and a low-level API for controlling bytes on the wire when the high-level API is insufficient. Usage examples for the high-level APIs are provided inline with their full documentation. To produce messages, use either the AsyncProducer or the SyncProducer. The AsyncProducer accepts messages on a channel and produces them asynchronously in the background as efficiently as possible; it is preferred in most cases. The SyncProducer provides a method which will block until Kafka acknowledges the message as produced. This can be useful but comes with two caveats: it will generally be less efficient, and the actual durability guarantees depend on the configured value of `Producer.RequiredAcks`. There are configurations where a message acknowledged by the SyncProducer can still sometimes be lost. To consume messages, use the Consumer. Note that Sarama's Consumer implementation does not currently support automatic consumer-group rebalancing and offset tracking. For Zookeeper-based tracking (Kafka 0.8.2 and earlier), the https://github.com/wvanbergen/kafka library builds on Sarama to add this support. For Kafka-based tracking (Kafka 0.9 and later), the https://github.com/bsm/sarama-cluster library builds on Sarama to add this support. For lower-level needs, the Broker and Request/Response objects permit precise control over each connection and message sent on the wire; the Client provides higher-level metadata management that is shared between the producers and the consumer. The Request/Response objects and properties are mostly undocumented, as they line up exactly with the protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol Metrics are exposed through https://github.com/rcrowley/go-metrics library in a local registry. Broker related metrics: Note that we do not gather specific metrics for seed brokers but they are part of the "all brokers" metrics. Producer related metrics:

  • Homepage: https://github.com/IBM/Sarama
  • Documentation: https://pkg.go.dev/github.com/IBM/Sarama#section-documentation
  • Licenses: MIT
  • Latest release: v1.47.0 (published about 1 month ago)
  • Last Synced: 2026-03-27T10:01:23.354Z (3 days ago)
  • Versions: 83
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Forks count: 0.582%
    • Stargazers count: 0.621%
    • Average: 5.167%
    • Dependent packages count: 8.899%
    • Dependent repos count: 10.567%
proxy.golang.org: github.com/ibm/sarama

Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later). It includes a high-level API for easily producing and consuming messages, and a low-level API for controlling bytes on the wire when the high-level API is insufficient. Usage examples for the high-level APIs are provided inline with their full documentation. To produce messages, use either the AsyncProducer or the SyncProducer. The AsyncProducer accepts messages on a channel and produces them asynchronously in the background as efficiently as possible; it is preferred in most cases. The SyncProducer provides a method which will block until Kafka acknowledges the message as produced. This can be useful but comes with two caveats: it will generally be less efficient, and the actual durability guarantees depend on the configured value of `Producer.RequiredAcks`. There are configurations where a message acknowledged by the SyncProducer can still sometimes be lost. To consume messages, use the Consumer. Note that Sarama's Consumer implementation does not currently support automatic consumer-group rebalancing and offset tracking. For Zookeeper-based tracking (Kafka 0.8.2 and earlier), the https://github.com/wvanbergen/kafka library builds on Sarama to add this support. For Kafka-based tracking (Kafka 0.9 and later), the https://github.com/bsm/sarama-cluster library builds on Sarama to add this support. For lower-level needs, the Broker and Request/Response objects permit precise control over each connection and message sent on the wire; the Client provides higher-level metadata management that is shared between the producers and the consumer. The Request/Response objects and properties are mostly undocumented, as they line up exactly with the protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol Metrics are exposed through https://github.com/rcrowley/go-metrics library in a local registry. Broker related metrics: Note that we do not gather specific metrics for seed brokers but they are part of the "all brokers" metrics. Producer related metrics:

  • Homepage: https://github.com/ibm/sarama
  • Documentation: https://pkg.go.dev/github.com/ibm/sarama#section-documentation
  • Licenses: MIT
  • Latest release: v1.47.0 (published about 1 month ago)
  • Last Synced: 2026-03-27T10:01:51.082Z (3 days ago)
  • Versions: 83
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Docker Downloads: 33,478,147
  • Rankings:
    • Forks count: 0.582%
    • Stargazers count: 0.621%
    • Average: 5.167%
    • Dependent packages count: 8.899%
    • Dependent repos count: 10.567%
proxy.golang.org: github.com/IBM/sarama/examples/sasl_scram_client

proxy.golang.org: github.com/IbM/sarama

Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later). It includes a high-level API for easily producing and consuming messages, and a low-level API for controlling bytes on the wire when the high-level API is insufficient. Usage examples for the high-level APIs are provided inline with their full documentation. To produce messages, use either the AsyncProducer or the SyncProducer. The AsyncProducer accepts messages on a channel and produces them asynchronously in the background as efficiently as possible; it is preferred in most cases. The SyncProducer provides a method which will block until Kafka acknowledges the message as produced. This can be useful but comes with two caveats: it will generally be less efficient, and the actual durability guarantees depend on the configured value of `Producer.RequiredAcks`. There are configurations where a message acknowledged by the SyncProducer can still sometimes be lost. To consume messages, use the Consumer. Note that Sarama's Consumer implementation does not currently support automatic consumer-group rebalancing and offset tracking. For Zookeeper-based tracking (Kafka 0.8.2 and earlier), the https://github.com/wvanbergen/kafka library builds on Sarama to add this support. For Kafka-based tracking (Kafka 0.9 and later), the https://github.com/bsm/sarama-cluster library builds on Sarama to add this support. For lower-level needs, the Broker and Request/Response objects permit precise control over each connection and message sent on the wire; the Client provides higher-level metadata management that is shared between the producers and the consumer. The Request/Response objects and properties are mostly undocumented, as they line up exactly with the protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol Metrics are exposed through https://github.com/rcrowley/go-metrics library in a local registry. Broker related metrics: Note that we do not gather specific metrics for seed brokers but they are part of the "all brokers" metrics. Producer related metrics:

  • Homepage: https://github.com/IbM/sarama
  • Documentation: https://pkg.go.dev/github.com/IbM/sarama#section-documentation
  • Licenses: MIT
  • Latest release: v1.47.0 (published about 1 month ago)
  • Last Synced: 2026-03-27T10:04:04.970Z (3 days ago)
  • Versions: 83
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Forks count: 0.572%
    • Stargazers count: 0.612%
    • Average: 5.39%
    • Dependent packages count: 9.576%
    • Dependent repos count: 10.802%
proxy.golang.org: github.com/IBM/sarama/examples/http_server

proxy.golang.org: github.com/IBM/sarama/examples/txn_producer

  • Homepage: https://github.com/IBM/sarama
  • Documentation: https://pkg.go.dev/github.com/IBM/sarama/examples/txn_producer#section-documentation
  • Licenses: mit
  • Latest release: v0.0.0-20260320155225-3a0f0a4c0c50 (published 10 days ago)
  • Last Synced: 2026-03-27T10:01:20.337Z (3 days ago)
  • Versions: 4
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Dependent packages count: 5.882%
    • Average: 6.079%
    • Dependent repos count: 6.276%
proxy.golang.org: github.com/IBM/sarama/examples/interceptors

  • Homepage: https://github.com/IBM/sarama
  • Documentation: https://pkg.go.dev/github.com/IBM/sarama/examples/interceptors#section-documentation
  • Licenses: mit
  • Latest release: v0.0.0-20260318212104-f184ee409fc8 (published 11 days ago)
  • Last Synced: 2026-03-27T10:03:00.276Z (3 days ago)
  • Versions: 7
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Dependent packages count: 5.882%
    • Average: 6.079%
    • Dependent repos count: 6.276%
proxy.golang.org: github.com/iBM/sarama

Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later). It includes a high-level API for easily producing and consuming messages, and a low-level API for controlling bytes on the wire when the high-level API is insufficient. Usage examples for the high-level APIs are provided inline with their full documentation. To produce messages, use either the AsyncProducer or the SyncProducer. The AsyncProducer accepts messages on a channel and produces them asynchronously in the background as efficiently as possible; it is preferred in most cases. The SyncProducer provides a method which will block until Kafka acknowledges the message as produced. This can be useful but comes with two caveats: it will generally be less efficient, and the actual durability guarantees depend on the configured value of `Producer.RequiredAcks`. There are configurations where a message acknowledged by the SyncProducer can still sometimes be lost. To consume messages, use the Consumer. Note that Sarama's Consumer implementation does not currently support automatic consumer-group rebalancing and offset tracking. For Zookeeper-based tracking (Kafka 0.8.2 and earlier), the https://github.com/wvanbergen/kafka library builds on Sarama to add this support. For Kafka-based tracking (Kafka 0.9 and later), the https://github.com/bsm/sarama-cluster library builds on Sarama to add this support. For lower-level needs, the Broker and Request/Response objects permit precise control over each connection and message sent on the wire; the Client provides higher-level metadata management that is shared between the producers and the consumer. The Request/Response objects and properties are mostly undocumented, as they line up exactly with the protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol Metrics are exposed through https://github.com/rcrowley/go-metrics library in a local registry. Broker related metrics: Note that we do not gather specific metrics for seed brokers but they are part of the "all brokers" metrics. Producer related metrics:

  • Homepage: https://github.com/iBM/sarama
  • Documentation: https://pkg.go.dev/github.com/iBM/sarama#section-documentation
  • Licenses: MIT
  • Latest release: v1.47.0 (published about 1 month ago)
  • Last Synced: 2026-03-27T10:03:05.590Z (3 days ago)
  • Versions: 83
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Dependent packages count: 6.325%
    • Average: 6.538%
    • Dependent repos count: 6.751%
proxy.golang.org: github.com/IBM/sarama/examples/exactly_once

  • Homepage: https://github.com/IBM/sarama
  • Documentation: https://pkg.go.dev/github.com/IBM/sarama/examples/exactly_once#section-documentation
  • Licenses: mit
  • Latest release: v0.0.0-20260312132609-87a9321440fc (published 18 days ago)
  • Last Synced: 2026-03-27T10:02:25.197Z (3 days ago)
  • Versions: 4
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Dependent packages count: 6.334%
    • Average: 6.548%
    • Dependent repos count: 6.762%
proxy.golang.org: github.com/ibm/sarama/examples/http_server

ubuntu-24.10: golang-github-ibm-sarama

  • Homepage: https://github.com/IBM/sarama
  • Licenses:
  • Latest release: 1.43.2-1 (published about 2 months ago)
  • Last Synced: 2026-03-08T15:44:54.801Z (22 days ago)
  • Versions: 1
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Dependent repos count: 0.0%
    • Dependent packages count: 0.0%
    • Average: 100%
debian-13: golang-github-ibm-sarama

  • Homepage: https://github.com/IBM/sarama
  • Documentation: https://packages.debian.org/trixie/golang-github-ibm-sarama
  • Licenses:
  • Latest release: 1.45.1-1 (published about 2 months ago)
  • Last Synced: 2026-03-13T19:14:35.407Z (17 days ago)
  • Versions: 1
  • Dependent Packages: 0
  • Dependent Repositories: 0
  • Rankings:
    • Dependent repos count: 0.0%
    • Dependent packages count: 0.0%
    • Average: 100%

Dependencies

.github/workflows/ci.yml actions
  • actions/cache v3 composite
  • actions/checkout v3 composite
  • actions/setup-go v3 composite
  • golangci/golangci-lint-action v3 composite
.github/workflows/codeql-analysis.yml actions
  • actions/checkout v3 composite
  • actions/setup-go v3 composite
  • github/codeql-action/analyze v2 composite
  • github/codeql-action/autobuild v2 composite
  • github/codeql-action/init v2 composite
.github/workflows/fuzz.yml actions
  • actions/cache v3 composite
  • actions/checkout v3 composite
  • actions/setup-go v3 composite
.github/workflows/fvt.yml actions
  • actions/cache v3 composite
  • actions/checkout v3 composite
  • actions/setup-go v3 composite
docker-compose.yml docker
  • docker.io/library/zookeeper 3.6.3
  • ghcr.io/shopify/toxiproxy 2.4.0
  • sarama/fv-kafka latest
examples/consumergroup/go.mod go
  • github.com/Shopify/sarama v1.34.1
examples/consumergroup/go.sum go
  • 503 dependencies
examples/exactly_once/go.mod go
  • github.com/Shopify/sarama v1.34.1
examples/exactly_once/go.sum go
  • 505 dependencies
examples/interceptors/go.mod go
  • github.com/Shopify/sarama v1.27.0
  • go.opentelemetry.io/otel v0.10.0
  • go.opentelemetry.io/otel/exporters/stdout v0.10.0
  • google.golang.org/genproto v0.0.0-20200331122359-1ee6d9798940
examples/interceptors/go.sum go
  • 144 dependencies
examples/txn_producer/go.mod go
  • github.com/Shopify/sarama v1.34.1
  • github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475
examples/txn_producer/go.sum go
  • 503 dependencies
go.mod go
  • [v1.24.1, v1.25.0]
  • [v1.26.0, v1.26.1]
  • [v1.31.0, v1.31.1]
  • github.com/Shopify/toxiproxy/v2 v2.5.0
  • github.com/davecgh/go-spew v1.1.1
  • github.com/eapache/go-resiliency v1.3.0
  • github.com/eapache/go-xerial-snappy v0.0.0-20180814174437-776d5712da21
  • github.com/eapache/queue v1.1.0
  • github.com/fortytw2/leaktest v1.3.0
  • github.com/golang/snappy v0.0.4
  • github.com/hashicorp/errwrap v1.0.0
  • github.com/hashicorp/go-multierror v1.1.1
  • github.com/hashicorp/go-uuid v1.0.3
  • github.com/jcmturner/aescts/v2 v2.0.0
  • github.com/jcmturner/dnsutils/v2 v2.0.0
  • github.com/jcmturner/gofork v1.7.6
  • github.com/jcmturner/gokrb5/v8 v8.4.3
  • github.com/jcmturner/rpc/v2 v2.0.3
  • github.com/klauspost/compress v1.15.14
  • github.com/kr/pretty v0.3.0
  • github.com/pierrec/lz4/v4 v4.1.17
  • github.com/pmezard/go-difflib v1.0.0
  • github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475
  • github.com/stretchr/testify v1.8.1
  • github.com/xdg-go/pbkdf2 v1.0.0
  • github.com/xdg-go/scram v1.1.2
  • github.com/xdg-go/stringprep v1.0.4
  • golang.org/x/crypto v0.0.0-20220722155217-630584e8d5aa
  • golang.org/x/net v0.5.0
  • golang.org/x/sync v0.1.0
  • golang.org/x/text v0.6.0
  • gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c
  • gopkg.in/yaml.v3 v3.0.1
  • retract (
go.sum go
  • github.com/Shopify/toxiproxy/v2 v2.5.0
  • github.com/creack/pty v1.1.9
  • github.com/davecgh/go-spew v1.1.0
  • github.com/davecgh/go-spew v1.1.1
  • github.com/eapache/go-resiliency v1.3.0
  • github.com/eapache/go-xerial-snappy v0.0.0-20180814174437-776d5712da21
  • github.com/eapache/queue v1.1.0
  • github.com/fortytw2/leaktest v1.3.0
  • github.com/golang/snappy v0.0.4
  • github.com/gorilla/securecookie v1.1.1
  • github.com/gorilla/sessions v1.2.1
  • github.com/hashicorp/errwrap v1.0.0
  • github.com/hashicorp/go-multierror v1.1.1
  • github.com/hashicorp/go-uuid v1.0.2
  • github.com/hashicorp/go-uuid v1.0.3
  • github.com/jcmturner/aescts/v2 v2.0.0
  • github.com/jcmturner/dnsutils/v2 v2.0.0
  • github.com/jcmturner/gofork v1.7.6
  • github.com/jcmturner/goidentity/v6 v6.0.1
  • github.com/jcmturner/gokrb5/v8 v8.4.3
  • github.com/jcmturner/rpc/v2 v2.0.3
  • github.com/klauspost/compress v1.15.14
  • github.com/kr/pretty v0.1.0
  • github.com/kr/pretty v0.2.1
  • github.com/kr/pretty v0.3.0
  • github.com/kr/pty v1.1.1
  • github.com/kr/text v0.2.0
  • github.com/kr/text v0.1.0
  • github.com/pierrec/lz4/v4 v4.1.17
  • github.com/pmezard/go-difflib v1.0.0
  • github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475
  • github.com/rogpeppe/go-internal v1.6.1
  • github.com/stretchr/objx v0.5.0
  • github.com/stretchr/objx v0.1.0
  • github.com/stretchr/objx v0.4.0
  • github.com/stretchr/testify v1.8.1
  • github.com/stretchr/testify v1.8.0
  • github.com/stretchr/testify v1.4.0
  • github.com/stretchr/testify v1.7.1
  • github.com/xdg-go/pbkdf2 v1.0.0
  • github.com/xdg-go/scram v1.1.2
  • github.com/xdg-go/stringprep v1.0.4
  • github.com/yuin/goldmark v1.4.13
  • golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2
  • golang.org/x/crypto v0.0.0-20210921155107-089bfa567519
  • golang.org/x/crypto v0.0.0-20220722155217-630584e8d5aa
  • golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4
  • golang.org/x/net v0.5.0
  • golang.org/x/net v0.0.0-20190620200207-3b0461eec859
  • golang.org/x/net v0.0.0-20220725212005-46097bf591d3
  • golang.org/x/net v0.0.0-20200114155413-6afb5195e5aa
  • golang.org/x/net v0.0.0-20210226172049-e18ecbb05110
  • golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2
  • golang.org/x/net v0.0.0-20220722155237-a158d28d115b
  • golang.org/x/sync v0.1.0
  • golang.org/x/sync v0.0.0-20190423024810-112230192c58
  • golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4
  • golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f
  • golang.org/x/sys v0.0.0-20201119102817-f84b799fce68
  • golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a
  • golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a
  • golang.org/x/sys v0.0.0-20210423082822-04245dca01da
  • golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1
  • golang.org/x/term v0.0.0-20210927222741-03fcf44c2211
  • golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1
  • golang.org/x/text v0.3.8
  • golang.org/x/text v0.6.0
  • golang.org/x/text v0.3.0
  • golang.org/x/text v0.3.3
  • golang.org/x/text v0.3.6
  • golang.org/x/text v0.3.7
  • golang.org/x/tools v0.1.12
  • golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e
  • golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e
  • golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7
  • gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127
  • gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c
  • gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405
  • gopkg.in/errgo.v2 v2.1.0
  • gopkg.in/yaml.v2 v2.2.2
  • gopkg.in/yaml.v3 v3.0.1
  • gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c
.github/workflows/apidiff.yml actions
  • actions/checkout v3 composite
  • actions/setup-go v4 composite
.github/workflows/stale.yml actions
  • actions/stale v8 composite
.github/workflows/fvt-main.yml actions
.github/workflows/scorecard.yml actions
  • actions/checkout de0fac2e4500dabe0009e67214ff5f5447ce83dd composite
  • actions/upload-artifact b7c566a772e6b6bfb58ed0dc250532a479d7789f composite
  • github/codeql-action/upload-sarif cdefb33c0f6224e58673d9004f47f7cb3e328b89 composite
  • ossf/scorecard-action 4eaacf0543bb3f2c246792bd56e8cdeffafb205a composite
.github/workflows/fvt-pr.yml actions
examples/http_server/go.mod go
  • github.com/IBM/sarama v1.46.3
  • github.com/davecgh/go-spew v1.1.1
  • github.com/eapache/go-resiliency v1.7.0
  • github.com/eapache/queue v1.1.0
  • github.com/hashicorp/go-uuid v1.0.3
  • github.com/jcmturner/aescts/v2 v2.0.0
  • github.com/jcmturner/dnsutils/v2 v2.0.0
  • github.com/jcmturner/gofork v1.7.6
  • github.com/jcmturner/gokrb5/v8 v8.4.4
  • github.com/jcmturner/rpc/v2 v2.0.3
  • github.com/klauspost/compress v1.18.2
  • github.com/pierrec/lz4/v4 v4.1.23
  • github.com/rcrowley/go-metrics v0.0.0-20250401214520-65e299d6c5c9
  • golang.org/x/crypto v0.47.0
  • golang.org/x/net v0.49.0
examples/sasl_scram_client/go.sum go
  • github.com/davecgh/go-spew v1.1.0
  • github.com/davecgh/go-spew v1.1.1
  • github.com/eapache/go-resiliency v1.7.0
  • github.com/eapache/queue v1.1.0
  • github.com/fortytw2/leaktest v1.3.0
  • github.com/gorilla/securecookie v1.1.1
  • github.com/gorilla/sessions v1.2.1
  • github.com/hashicorp/go-uuid v1.0.2
  • github.com/hashicorp/go-uuid v1.0.3
  • github.com/jcmturner/aescts/v2 v2.0.0
  • github.com/jcmturner/dnsutils/v2 v2.0.0
  • github.com/jcmturner/gofork v1.7.6
  • github.com/jcmturner/goidentity/v6 v6.0.1
  • github.com/jcmturner/gokrb5/v8 v8.4.4
  • github.com/jcmturner/rpc/v2 v2.0.3
  • github.com/klauspost/compress v1.18.2
  • github.com/pierrec/lz4/v4 v4.1.23
  • github.com/pmezard/go-difflib v1.0.0
  • github.com/rcrowley/go-metrics v0.0.0-20250401214520-65e299d6c5c9
  • github.com/stretchr/objx v0.1.0
  • github.com/stretchr/objx v0.4.0
  • github.com/stretchr/objx v0.5.0
  • github.com/stretchr/testify v1.4.0
  • github.com/stretchr/testify v1.7.1
  • github.com/stretchr/testify v1.8.0
  • github.com/stretchr/testify v1.8.1
  • github.com/stretchr/testify v1.11.1
  • github.com/xdg-go/pbkdf2 v1.0.0
  • github.com/xdg-go/scram v1.2.0
  • github.com/xdg-go/stringprep v1.0.4
  • github.com/yuin/goldmark v1.4.13
  • golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2
  • golang.org/x/crypto v0.0.0-20210921155107-089bfa567519
  • golang.org/x/crypto v0.6.0
  • golang.org/x/crypto v0.47.0
  • golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4
  • golang.org/x/net v0.0.0-20190620200207-3b0461eec859
  • golang.org/x/net v0.0.0-20200114155413-6afb5195e5aa
  • golang.org/x/net v0.0.0-20210226172049-e18ecbb05110
  • golang.org/x/net v0.0.0-20220722155237-a158d28d115b
  • golang.org/x/net v0.6.0
  • golang.org/x/net v0.7.0
  • golang.org/x/net v0.49.0
  • golang.org/x/sync v0.0.0-20190423024810-112230192c58
  • golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4
  • golang.org/x/sync v0.19.0
  • golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a
  • golang.org/x/sys v0.0.0-20201119102817-f84b799fce68
  • golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1
  • golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a
  • golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f
  • golang.org/x/sys v0.5.0
  • golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1
  • golang.org/x/term v0.0.0-20210927222741-03fcf44c2211
  • golang.org/x/term v0.5.0
  • golang.org/x/text v0.3.0
  • golang.org/x/text v0.3.3
  • golang.org/x/text v0.3.7
  • golang.org/x/text v0.3.8
  • golang.org/x/text v0.7.0
  • golang.org/x/text v0.33.0
  • golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e
  • golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e
  • golang.org/x/tools v0.1.12
  • golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7
  • gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405
  • gopkg.in/yaml.v2 v2.2.2
  • gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c
  • gopkg.in/yaml.v3 v3.0.1
examples/http_server/go.sum go
  • github.com/davecgh/go-spew v1.1.0
  • github.com/davecgh/go-spew v1.1.1
  • github.com/eapache/go-resiliency v1.7.0
  • github.com/eapache/queue v1.1.0
  • github.com/fortytw2/leaktest v1.3.0
  • github.com/gorilla/securecookie v1.1.1
  • github.com/gorilla/sessions v1.2.1
  • github.com/hashicorp/go-uuid v1.0.2
  • github.com/hashicorp/go-uuid v1.0.3
  • github.com/jcmturner/aescts/v2 v2.0.0
  • github.com/jcmturner/dnsutils/v2 v2.0.0
  • github.com/jcmturner/gofork v1.7.6
  • github.com/jcmturner/goidentity/v6 v6.0.1
  • github.com/jcmturner/gokrb5/v8 v8.4.4
  • github.com/jcmturner/rpc/v2 v2.0.3
  • github.com/klauspost/compress v1.18.2
  • github.com/pierrec/lz4/v4 v4.1.23
  • github.com/pmezard/go-difflib v1.0.0
  • github.com/rcrowley/go-metrics v0.0.0-20250401214520-65e299d6c5c9
  • github.com/stretchr/objx v0.1.0
  • github.com/stretchr/objx v0.4.0
  • github.com/stretchr/objx v0.5.0
  • github.com/stretchr/testify v1.4.0
  • github.com/stretchr/testify v1.7.1
  • github.com/stretchr/testify v1.8.0
  • github.com/stretchr/testify v1.8.1
  • github.com/stretchr/testify v1.11.1
  • github.com/yuin/goldmark v1.4.13
  • golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2
  • golang.org/x/crypto v0.0.0-20210921155107-089bfa567519
  • golang.org/x/crypto v0.6.0
  • golang.org/x/crypto v0.47.0
  • golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4
  • golang.org/x/net v0.0.0-20190620200207-3b0461eec859
  • golang.org/x/net v0.0.0-20200114155413-6afb5195e5aa
  • golang.org/x/net v0.0.0-20210226172049-e18ecbb05110
  • golang.org/x/net v0.0.0-20220722155237-a158d28d115b
  • golang.org/x/net v0.6.0
  • golang.org/x/net v0.7.0
  • golang.org/x/net v0.49.0
  • golang.org/x/sync v0.0.0-20190423024810-112230192c58
  • golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4
  • golang.org/x/sync v0.19.0
  • golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a
  • golang.org/x/sys v0.0.0-20201119102817-f84b799fce68
  • golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1
  • golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a
  • golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f
  • golang.org/x/sys v0.5.0
  • golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1
  • golang.org/x/term v0.0.0-20210927222741-03fcf44c2211
  • golang.org/x/term v0.5.0
  • golang.org/x/text v0.3.0
  • golang.org/x/text v0.3.3
  • golang.org/x/text v0.3.7
  • golang.org/x/text v0.7.0
  • golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e
  • golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e
  • golang.org/x/tools v0.1.12
  • golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7
  • gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405
  • gopkg.in/yaml.v2 v2.2.2
  • gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c
  • gopkg.in/yaml.v3 v3.0.1
examples/sasl_scram_client/go.mod go
  • github.com/IBM/sarama v1.46.3
  • github.com/davecgh/go-spew v1.1.1
  • github.com/eapache/go-resiliency v1.7.0
  • github.com/eapache/queue v1.1.0
  • github.com/hashicorp/go-uuid v1.0.3
  • github.com/jcmturner/aescts/v2 v2.0.0
  • github.com/jcmturner/dnsutils/v2 v2.0.0
  • github.com/jcmturner/gofork v1.7.6
  • github.com/jcmturner/gokrb5/v8 v8.4.4
  • github.com/jcmturner/rpc/v2 v2.0.3
  • github.com/klauspost/compress v1.18.2
  • github.com/pierrec/lz4/v4 v4.1.23
  • github.com/rcrowley/go-metrics v0.0.0-20250401214520-65e299d6c5c9
  • github.com/xdg-go/pbkdf2 v1.0.0
  • github.com/xdg-go/scram v1.2.0
  • github.com/xdg-go/stringprep v1.0.4
  • golang.org/x/crypto v0.47.0
  • golang.org/x/net v0.49.0
  • golang.org/x/text v0.33.0
.github/workflows/renovate-config.yml actions
  • actions/checkout de0fac2e4500dabe0009e67214ff5f5447ce83dd composite
  • actions/setup-node 6044e13b5dc448c55e2357c09f80417699197238 composite
.github/workflows/cache-cleanup.yml actions
.github/workflows/i386.yml actions
  • actions/checkout de0fac2e4500dabe0009e67214ff5f5447ce83dd composite
  • actions/setup-go 7a3fe6cf4cb3a834922a1244abfce67bcef6a0c5 composite
.github/workflows/dependency-review.yml actions
  • actions/checkout de0fac2e4500dabe0009e67214ff5f5447ce83dd composite
  • actions/dependency-review-action 3c4e3dcb1aa7874d2c16be7d79418e9b7efd6261 composite