Top 8.5% dependent packages on proxy.golang.org
Top 2.1% dependent repos on proxy.golang.org
Top 0.6% forks on proxy.golang.org
Top 1.8% docker downloads on proxy.golang.org
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:
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/%21i%21b%21m/sarama
Keywords:
go
, kafka
, kafka-client
License: MIT
Latest release: 3 months ago
First release: about 10 years ago
Namespace: github.com/IBM
Dependent packages: 195
Dependent repositories: 6
Stars: 10,316 on GitHub
Forks: 1,708 on GitHub
Docker dependents: 82
Docker downloads: 2,360,422,712
See more repository details: repos.ecosyste.ms
Last synced: 7 days ago
github.com/idohuber/idos-kubescape-network-scanner v0.0.4
Network scan and service discovery package5 versions - Latest release: 11 months ago - 0 stars on GitHub
github.com/kubescape/kubescape-network-scanner v0.0.15
18 versions - Latest release: 11 months agogithub.com/ab-lindex/melp v0.9.11
A Message Helper to proxy between messages and REST-APIs12 versions - Latest release: 11 months ago - 1 stars on GitHub
github.com/jayleonc/register v0.1.6
15 versions - Latest release: 11 months ago - 0 stars on GitHubgithub.com/Jayleonc/register v0.1.6
15 versions - Latest release: 11 months ago - 0 stars on GitHubgithub.phpd.cn/jaegertracing/jaeger v1.58.1
Package jaeger contains the code for Jaeger backend.81 versions - Latest release: 11 months ago
github.com/blockopsnetwork/telescope v0.2.33
Copyright © 2024 NAME HERE <EMAIL ADDRESS> Licensed under the Apache License, Version 2.0 (the "...27 versions - Latest release: 11 months ago - 0 stars on GitHub
github.com/jalapeno-api-gateway/jagw v1.4.0
Microservices for the gateway10 versions - Latest release: 12 months ago - 2 stars on GitHub
gitee.com/go-wares/ii v0.3.1
36 versions - Latest release: 12 months agogithub.com/lowl11/boost v0.9.8
193 versions - Latest release: 12 months ago - 1 dependent package - 0 stars on GitHubgithub.com/phanitejak/kptgolib v1.0.0
My library for reusable Go Libraries1 version - Latest release: 12 months ago - 0 stars on GitHub
github.com/cll-gg/benthos/v4 v4.30.1
Fancy stream processing made operationally mundane44 versions - Latest release: 12 months ago - 0 stars on GitHub
github.com/preetsarb/opentelemetry-collector-contrib v0.102.1
Contrib repository for the OpenTelemetry Collector1 version - Latest release: 12 months ago - 0 stars on GitHub
github.com/sunreaver/antman/v4 v4.0.2
DB/redis/MQ package3 versions - Latest release: 12 months ago - 0 stars on GitHub
github.com/azarc-io/components-contrib v1.13.4
Community driven, reusable components for distributed apps134 versions - Latest release: 12 months ago - 0 stars on GitHub
github.phpd.cn/influxdata/telegraf v1.31.0
116 versions - Latest release: 12 months agogithub.com/axoflow/countconnector v0.99.0
Opentelemetry connecor for counting log events, and generating metrics based on them7 versions - Latest release: 12 months ago - 0 stars on GitHub
github.com/diki-haryadi/govega v1.0.0
This library aims to provide a collection of advanced tools and technologies that developers can ...1 version - Latest release: 12 months ago - 0 stars on GitHub
github.com/alextalks/cockroach-gen v0.24.1-0
2 versions - Latest release: 12 months ago - 1 dependent packagegithub.com/open-telemetry/opentelemetry-collector-contrib/cmd/configschema v0.102.0
Deprecated: [v0.92.0] This package is deprecated and will be removed in a future release. See htt...69 versions - Latest release: 12 months ago - 2,280 stars on GitHub
github.phpd.cn/open-telemetry/opentelemetry-collector-contrib v0.102.0
151 versions - Latest release: 12 months agogithub.com/singchia/frontier v1.1.0
A cloud native gateway for edges. 一个云原生长连接网关,让微服务和客户端零距离2 versions - Latest release: about 1 year ago - 1 stars on GitHub
github.com/tyktechnologies/benthos/v4 v4.27.1
Fancy stream processing made operationally mundane2 versions - Latest release: about 1 year ago - 1 stars on GitHub
github.com/TykTechnologies/benthos/v4 v4.27.1
Fancy stream processing made operationally mundane2 versions - Latest release: about 1 year ago - 1 stars on GitHub
github.com/srenatus/benthos/v4 v4.28.0 💰
Fancy stream processing made operationally mundane2 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/sunreaver/antman/v3 v3.0.5
DB/redis/MQ package5 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/memory-qianxiao/toolbox v1.0.0
7 versions - Latest release: about 1 year agobitbucket.org/jurnal/go-common v1.0.2
3 versions - Latest release: about 1 year agogithub.phpd.cn/fission/fission v1.20.2
44 versions - Latest release: about 1 year agogit.wxl.best/numaproj/numaflow v1.2.1
52 versions - Latest release: about 1 year agogithub.com/remiges-kanchan/alya v0.11.0
12 versions - Latest release: about 1 year agogithub.xiaoq7.com/open-telemetry/opentelemetry-collector-contrib v0.101.0
150 versions - Latest release: about 1 year agogithub.com/jeffmitchell-sas/benthos/v4 v4.27.0
Fancy stream processing made operationally mundane4 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/jaywcarman/terraform-provider-ibm v1.65.1
Terraform IBM provider https://ibm-cloud.github.io/tf-ibm-docs/v0.18.0/204 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/spatialsys/dd-trace-go v1.64.0
Datadog Go Library including APM tracing, profiling, and security monitoring.222 versions - Latest release: about 1 year ago - 0 stars on GitHub
gitee.com/infobili/go-drivers v0.0.4
7 versions - Latest release: about 1 year agogithub.com/meikwei/aetim v0.0.1
1 version - Latest release: about 1 year agogithub.com/meikwei/go-tools v0.0.3
tools2 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/Meikwei/go-tools v0.0.3
tools2 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/xwc1125/xwc1125-pkg v0.1.3
Package xwc1125_pkg @author: xwc11254 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/wilsouza/testcontainers-go/modules/kafka v0.31.0
Testcontainers for Go is a Go package that makes it simple to create and clean up container-based...10 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.phpd.cn/signalfx/splunk-otel-collector v0.100.0
112 versions - Latest release: about 1 year agogithub.com/zoueature/mq v0.1.0
消息队列的封装8 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/jacktomcat/opentelemetry-collector-contrib v0.99.0
Contrib repository for the OpenTelemetry Collector2 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.xiaoq7.com/numaproj/numaflow v1.2.1
52 versions - Latest release: about 1 year agogithub.phpd.cn/numaproj/numaflow v1.2.1
52 versions - Latest release: about 1 year agogithub.com/illidaris/watermillex v0.0.6
for `github.com/ThreeDotsLabs/watermill` extensions6 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/ksmagyn/opentelemetry-collector-contrib v0.100.0
Contrib repository for the OpenTelemetry Collector152 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/AlexandruBun/opentelemetry-collector-contrib/internal/kafka v0.100.0
15 versions - Latest release: about 1 year agogithub.com/alexandrubun/opentelemetry-collector-contrib/exporter/kafkaexporter v0.100.0
75 versions - Latest release: about 1 year agogithub.com/alexandrubun/opentelemetry-collector-contrib/internal/kafka v0.100.0
15 versions - Latest release: about 1 year agogithub.com/AlexandruBun/opentelemetry-collector-contrib/exporter/kafkaexporter v0.100.0
Package kafkaexporter exports trace data to Kafka.75 versions - Latest release: about 1 year ago
github.com/ksmagyn/opentelemetry-collector-contrib/internal/kafka v0.100.0
Contrib repository for the OpenTelemetry Collector16 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/go-sigma/sigma v1.3.0
OCI artifact manager8 versions - Latest release: about 1 year ago - 5 stars on GitHub
github.com/eladleev/schema-registry-statistics v1.4.5
main ...11 versions - Latest release: about 1 year ago - 24 stars on GitHub
github.com/demdxx/redify v0.9.2
🧩 Redify any database as RedisDB30 versions - Latest release: about 1 year ago - 4 stars on GitHub
github.com/myrteametrics/myrtea-sdk/v4 v4.6.3
66 versions - Latest release: about 1 year ago - 4 dependent packages - 1 dependent repositories - 5 stars on GitHubgithub.com/toversus/opentelemetry-collector-contrib v0.99.0
Contrib repository for the OpenTelemetry Collector1 version - Latest release: about 1 year ago - 0 stars on GitHub
github.com/revdaalex/kafka-consumer-go v0.8.6
Go module that provides a Kafka consumer with built-in retry logic.13 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/hyperdxio/opentelemetry-collector-contrib v0.99.0
Contrib repository for the OpenTelemetry Collector3 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/signmem/falcon-plus v0.1.1
build !release2 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/financial-times/smartlogic-concordance-transformer v1.7.0
Service which listens to kafka for concordance updates, transforms smartlogic concordance json an...22 versions - Latest release: about 1 year ago - 2 stars on GitHub
github.com/Financial-Times/smartlogic-concordance-transformer v1.7.0
Service which listens to kafka for concordance updates, transforms smartlogic concordance json an...18 versions - Latest release: about 1 year ago - 2 stars on GitHub
github.com/violetpay-org/point3-quman v0.1.5
Queue manager designed to manage multiple streamable queues with one cue.7 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/jau1jz/cornus/v2 v2.0.1-alpha.4
cornus web server sdk14 versions - Latest release: about 1 year ago - 1 dependent repositories - 0 stars on GitHub
github.com/nachogiljaldo/watermill-kafka/v3 v3.1.3
Kafka Pub/Sub for the Watermill project.4 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/jinggangnanyou/databridge v0.0.1
1 version - Latest release: about 1 year ago - 0 stars on GitHubgithub.com/off-chain-storage/gosphere v1.0.0
1 version - Latest release: about 1 year ago - 2 stars on GitHubgithub.com/off-chain-storage/GoSphere v1.0.0
1 version - Latest release: about 1 year ago - 2 stars on GitHubgithub.com/kristofgyuracz/opentelemetry-collector-contrib v0.99.0
Contrib repository for the OpenTelemetry Collector149 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.chickoi.com/open-telemetry/opentelemetry-collector-contrib v0.99.0
56 versions - Latest release: about 1 year agogithub.com/jinggangnanyou/dataorm v0.0.1
1 version - Latest release: about 1 year ago - 0 stars on GitHubgithub.com/Sylariam/tools v0.0.48
134 versions - Latest release: about 1 year agogithub.com/sylariam/tools v0.0.48
134 versions - Latest release: about 1 year agogithub.com/andreas-habel/benthos/v4 v4.26.0-cookie
Fancy stream processing made operationally mundane1 version - Latest release: about 1 year ago - 0 stars on GitHub
github.com/TencentBlueKing/bkmonitor-datalink/pkg/bk-monitor-worker v0.3.0-alpha.34
数据链路为蓝鲸监控平台提供通用统一的数据采集、转换和存查能力。1 version - Latest release: about 1 year ago - 14 stars on GitHub
github.com/tencentblueking/bkmonitor-datalink/pkg/bk-monitor-worker v0.3.0-alpha.34
数据链路为蓝鲸监控平台提供通用统一的数据采集、转换和存查能力。1 version - Latest release: about 1 year ago - 19 stars on GitHub
github.com/zmloong/lotus v1.3.0
9 versions - Latest release: about 1 year ago - 0 stars on GitHubgithub.com/parspooyeshfanavar/sarama-cluster v1.0.0
Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]1 version - Latest release: about 1 year ago - 0 stars on GitHub
github.com/GuanceCloud/dd-trace-go v0.0.1
1 version - Latest release: about 1 year agogithub.com/guancecloud/dd-trace-go v0.0.1
1 version - Latest release: about 1 year agobitbucket.org/celtic-coder/action v0.0.5
6 versions - Latest release: about 1 year agogithub.com/fazpass/goliath/v3 v3.8.2
18 versions - Latest release: about 1 year ago - 1 stars on GitHubbitbucket.org/celtic-coder/kafka v0.0.3
4 versions - Latest release: about 1 year ago - 1 dependent packagegithub.com/weintek-mao/telegraf v1.30.1
The plugin-driven server agent for collecting & reporting metrics.1 version - Latest release: about 1 year ago - 0 stars on GitHub
github.com/hopeio/tiga v1.8.2
32 versions - Latest release: about 1 year agogithub.com/hopeio/lemon v1.8.2
40 versions - Latest release: about 1 year agogithub.com/dagdynamik/opentelemetry-collector-contrib v1.0.5
Contrib repository for the OpenTelemetry Collector7 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/go-juno/kit v0.1.9
9 versions - Latest release: about 1 year ago - 1 dependent repositoriesgithub.com/fluffy-bunny/benthos-cloudevents-fluffycore v1.0.15
Benthos plugin that processes cloudevents and sends them downstream to a gprc handler.58 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/americanas-go/ignite v1.15.5
146 versions - Latest release: about 1 year ago - 7 dependent packages - 2 dependent repositories - 13 stars on GitHubgithub.com/ttraveller7/invokerlib v0.6.0
89 versions - Latest release: about 1 year ago - 0 stars on GitHubgithub.com/TTraveller7/invokerlib v0.6.0
89 versions - Latest release: about 1 year ago - 0 stars on GitHubgithub.com/cmdrsharp/opentelemetry-collector-contrib v0.97.0
Contrib repository for the OpenTelemetry Collector1 version - Latest release: about 1 year ago - 0 stars on GitHub
github.com/CmdrSharp/opentelemetry-collector-contrib v0.97.0
Contrib repository for the OpenTelemetry Collector1 version - Latest release: about 1 year ago - 0 stars on GitHub
github.com/cmdrsharp/custom-otelcol-extensions v0.97.0
Custom extensions for OTEL Collector1 version - Latest release: about 1 year ago - 0 stars on GitHub
github.com/etf1/dd-trace-go v0.0.1
Datadog Go Library including APM tracing, profiling, and security monitoring.1 version - Latest release: about 1 year ago - 0 stars on GitHub
github.com/holden-conaway/jaegergraphana v1.56.0
Package jaeger contains the code for Jaeger backend.78 versions - Latest release: about 1 year ago - 0 stars on GitHub
gitlab.eclipse.org/eclipse/xfsc/libraries/messaging/cloudeventprovider v0.1.4
7 versions - Latest release: about 1 year agogithub.xiaoq7.com/dapr/components-contrib v1.13.1
130 versions - Latest release: about 1 year agoCheck this option to include packages that no longer depend on this package in their latest version but previously did.