top

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:

+------------------------------------------------+------------+---------------------------------------------------------------+
| Name                                           | Type       | Description                                                   |
+------------------------------------------------+------------+---------------------------------------------------------------+
| incoming-byte-rate                             | meter      | Bytes/second read off all brokers                             |
| incoming-byte-rate-for-broker-<broker-id>      | meter      | Bytes/second read off a given broker                          |
| outgoing-byte-rate                             | meter      | Bytes/second written off all brokers                          |
| outgoing-byte-rate-for-broker-<broker-id>      | meter      | Bytes/second written off a given broker                       |
| request-rate                                   | meter      | Requests/second sent to all brokers                           |
| request-rate-for-broker-<broker-id>            | meter      | Requests/second sent to a given broker                        |
| histogram request-size                         | histogram  | Distribution of the request size in bytes for all brokers     |
| histogram request-size-for-broker-<broker-id>  | histogram  | Distribution of the request size in bytes for a given broker  |
| response-rate                                  | meter      | Responses/second received from all brokers                    |
| response-rate-for-broker-<broker-id>           | meter      | Responses/second received from a given broker                 |
| histogram response-size                        | histogram  | Distribution of the response size in bytes for all brokers    |
| histogram response-size-for-broker-<broker-id> | histogram  | Distribution of the response size in bytes for a given broker |
+------------------------------------------------+------------+---------------------------------------------------------------+

Note that we do not gather specific metrics for seed brokers but they are part of the "all brokers" metrics.

Imported by 716 package(s)

  1. github.com/756445638/imgo/logic
  2. github.com/756445638/imgo/logic/job
  3. github.com/94else/goim/logic
  4. github.com/Atlanssia/jackdaw/controller
  5. github.com/Billups/sarama/examples/http_server
  6. github.com/Billups/sarama/mocks
  7. github.com/Billups/sarama/tools/kafka-console-consumer
  8. github.com/Billups/sarama/tools/kafka-console-partitionconsumer
  9. github.com/Billups/sarama/tools/kafka-console-producer
  10. github.com/BnLCr/telegraf/plugins/inputs/kafka_consumer
  11. github.com/BnLCr/telegraf/plugins/outputs/kafka
  12. github.com/C-Pro/go-kafka-test/consumer
  13. github.com/C-Pro/go-kafka-test/producer
  14. github.com/ChannelMeter/kafka/consumergroup
  15. github.com/CrowdStrike/go_kafka_client
  16. github.com/CrowdStrike/go_kafka_client/producers
  17. github.com/CrowdStrike/go_kafka_client/producers/tailf
  18. github.com/CrowdStrike/go_kafka_client/syslog
  19. github.com/CrowdStrike/kafka
  20. github.com/CrowdStrike/kafka/consumergroup
  21. github.com/DaoCloud/cadvisor/storage/kafka
  22. github.com/DeviantArt/kafka-scribe/functional_tests
  23. github.com/ECLabs/Eaton-Feeder
  24. github.com/ECLabs/Eaton-Feeder/consumer
  25. github.com/ECLabs/Eaton-Feeder/events
  26. github.com/Fiery/fsmonitor/example
  27. github.com/Icedroid/goim/logic
  28. github.com/Ingensi/beats/libbeat/outputs/kafka
  29. github.com/JamesOwenHall/kafka/consumergroup
  30. github.com/JamesOwenHall/kafka/examples/consumergroup
  31. github.com/JamesOwenHall/kafka/tools/consoleconsumer
  32. github.com/JamesOwenHall/kafka/tools/consoleproducer
  33. github.com/JamesOwenHall/kafka/tools/stressproducer
  34. github.com/JamesOwenHall/kafka/tools/transferoffsets
  35. github.com/JamesOwenHall/kafka/tools/verifier
  36. github.com/JosephSalisbury/event-sourcing-poc/write-service
  37. github.com/Kaey/telegraf/plugins/inputs/kafka_consumer
  38. github.com/Kaey/telegraf/plugins/outputs/kafka
  39. github.com/Kane-Sendgrid/kafka_console
  40. github.com/Kane-Sendgrid/kafka_console/consumer
  41. github.com/MarianoGappa/flowbro
  42. github.com/MarianoGappa/flowbro-server
  43. github.com/MarianoGappa/kt
  44. github.com/NYTimes/gizmo/pubsub/kafka
  45. github.com/NathanielMichael/telegraf/plugins/inputs/kafka_consumer
  46. github.com/NathanielMichael/telegraf/plugins/outputs/kafka
  47. github.com/NexwayGroup/nx-lib/kafka
  48. github.com/Noxer/telegraf/plugins/inputs/kafka_consumer
  49. github.com/Noxer/telegraf/plugins/outputs/kafka
  50. github.com/ORBAT/kafka/consumergroup
  51. github.com/ORBAT/temp
  52. github.com/OrangeSword/fermchamber/fancontroller
  53. github.com/OrangeSword/fermchamber/sensormonitor
  54. github.com/OrangeSword/zymurgauge/fermentationchamber
  55. github.com/OrangeSword/zymurgauge/mastercontrol
  56. github.com/PieterD/crap/kafka
  57. github.com/PieterD/crap/kafka/internal/listenhandler
  58. github.com/PieterD/crap/kafka/internal/transmithandler
  59. github.com/Psiphon-Inc/goarista/kafka
  60. github.com/Psiphon-Inc/goarista/kafka/openconfig
  61. github.com/Psiphon-Inc/goarista/kafka/producer
  62. github.com/RobCherry/sarama/examples/http_server
  63. github.com/RobCherry/sarama/mocks
  64. github.com/RobCherry/sarama/tools/kafka-console-partitionconsumer
  65. github.com/RobCherry/sarama/tools/kafka-console-producer
  66. github.com/RobinUS2/kafka-proxy
  67. github.com/Shop2market/mq-benchmarking/benchmark/mq
  68. github.com/Shopify/sarama/examples/http_server
  69. github.com/Shopify/sarama/mocks
  70. github.com/Shopify/sarama/tools/kafka-console-consumer
  71. github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
  72. github.com/Shopify/sarama/tools/kafka-console-producer
  73. github.com/Terry-Mao/goim/logic
  74. github.com/Terry-Mao/goim/logic/job
  75. github.com/aaronwei/goim/logic
  76. github.com/actank/Burrow
  77. github.com/adamdecaf/Burrow
  78. github.com/adxhyt/Burrow
  79. github.com/adxhyt/kafka-consumer-lag
  80. github.com/ainsleyc/cadvisor/storage/kafka
  81. github.com/aiyi/agent/agent
  82. github.com/aiyi/agent/rsu
  83. github.com/andrewkroh/beats/libbeat/outputs/kafka
  84. github.com/andygrunwald/gollum/consumer
  85. github.com/andygrunwald/gollum/producer
  86. github.com/andyxning/cadvisor/storage/kafka
  87. github.com/appcelerator/amp-pilot/core
  88. github.com/appcelerator/amp/data/kafka
  89. github.com/appuri/Burrow
  90. github.com/araddon/loadtestingGoEmbeddedDbs
  91. github.com/araobp/spielzeug/misc/iot_pf
  92. github.com/ardyantohermawan/kafka-consumer
  93. github.com/ardyantohermawan/kafka-producer
  94. github.com/arhitiron/fullcontact-gin/app/controllers
  95. github.com/aristanetworks/goarista/kafka
  96. github.com/aristanetworks/goarista/kafka/openconfig
  97. github.com/aristanetworks/goarista/kafka/producer
  98. github.com/aristanetworks/telegraf/plugins/inputs/kafka_consumer
  99. github.com/aristanetworks/telegraf/plugins/outputs/kafka
  100. github.com/art4711/go_kafka_client
  101. github.com/art4711/go_kafka_client/producers
  102. github.com/art4711/go_kafka_client/syslog
  103. github.com/asiainfoLDP/datahub_commons/mq
  104. github.com/astral1/gollum/consumer
  105. github.com/astral1/gollum/producer
  106. github.com/asvins/common_io
  107. github.com/atlanssia/jackdaw/controller
  108. github.com/atongen/Burrow
  109. github.com/aybabtme/sarama/mocks
  110. github.com/basvanbeek/pubsub/kafka
  111. github.com/basvanbeek/zipkin-go-opentracing
  112. github.com/battbeach/cadvisor/storage/kafka
  113. github.com/benlightning/gopush/admin
  114. github.com/benlightning/gopush/push
  115. github.com/benschumacher/cadvisor/storage/kafka
  116. github.com/bensigelman/zipkin-go-opentracing
  117. github.com/bhirbec/kafka/consumergroup
  118. github.com/bikrant/heka-kafka
  119. github.com/binarydud/canary/canary
  120. github.com/bjorand/Burrow
  121. github.com/blacklightops/libbeat/outputs/kafka
  122. github.com/blockchaindev/go-snippets/kafka/broker
  123. github.com/blockchaindev/go-snippets/kafka/consumer
  124. github.com/blockchaindev/go-snippets/kafka/producer
  125. github.com/boyand/sarama-cluster
  126. github.com/bradhe/epee
  127. github.com/bradleyfalzon/heka/plugins/kafka
  128. github.com/brandur/stripe-warehouse/endpoint
  129. github.com/brandur/stripe-warehouse/feeder
  130. github.com/brandur/stripe-warehouse/synthesizer
  131. github.com/browny/sarama/mocks
  132. github.com/bruth/go-plugins/broker/kafka
  133. github.com/bsm/pipa
  134. github.com/bsm/rucksack/log/kafka
  135. github.com/bsm/sarama-cluster
  136. github.com/bttrs/KafkaLogrus
  137. github.com/buddhamagnet/gizmo/pubsub
  138. github.com/c-pro/go-kafka-test/consumer
  139. github.com/c-pro/go-kafka-test/producer
  140. github.com/cch123/binlog-river-es
  141. github.com/cep21/sarama/examples/http_server
  142. github.com/cep21/sarama/mocks
  143. github.com/cep21/sarama/tools/kafka-console-consumer
  144. github.com/cep21/sarama/tools/kafka-console-partitionconsumer
  145. github.com/cep21/sarama/tools/kafka-console-producer
  146. github.com/cgeoffroy/telegraf/plugins/inputs/kafka_consumer
  147. github.com/cgeoffroy/telegraf/plugins/outputs/kafka
  148. github.com/ch3lo/telegraf/plugins/inputs/kafka_consumer
  149. github.com/ch3lo/telegraf/plugins/outputs/kafka
  150. github.com/channelmeter/kafka/consumergroup
  151. github.com/chenghuama/goim/logic
  152. github.com/chenhuaying/logflume
  153. github.com/chentao/sarama/examples/http_server
  154. github.com/chentao/sarama/mocks
  155. github.com/chentao/sarama/tools/kafka-console-consumer
  156. github.com/chentao/sarama/tools/kafka-console-partitionconsumer
  157. github.com/chentao/sarama/tools/kafka-console-producer
  158. github.com/chenziliang/descartes/base
  159. github.com/chenziliang/descartes/sinks/kafka
  160. github.com/chenziliang/sarama/examples/http_server
  161. github.com/chenziliang/sarama/mocks
  162. github.com/chenziliang/sarama/tools/kafka-console-consumer
  163. github.com/chenziliang/sarama/tools/kafka-console-partitionconsumer
  164. github.com/chenziliang/sarama/tools/kafka-console-producer
  165. github.com/cihangir/kube-kafka/consumer
  166. github.com/cihangir/kube-kafka/producer
  167. github.com/coffeehc/gizmo/pubsub
  168. github.com/compassmarketing/telegraf/plugins/inputs/kafka_consumer
  169. github.com/compassmarketing/telegraf/plugins/outputs/kafka
  170. github.com/crask/kafka-pusher
  171. github.com/crask/kafka/consumergroup
  172. github.com/crast/sarama/examples/http_server
  173. github.com/crast/sarama/mocks
  174. github.com/crast/sarama/tools/kafka-console-consumer
  175. github.com/crast/sarama/tools/kafka-console-partitionconsumer
  176. github.com/crast/sarama/tools/kafka-console-producer
  177. github.com/csyangchen/beats/libbeat/outputs/kafka
  178. github.com/curzonj/kafka-http-go
  179. github.com/cxfksword/beats/libbeat/outputs/kafka
  180. github.com/cyphar/cadvisor/storage/kafka
  181. github.com/darciopacifico/taskmanager/register
  182. github.com/darciopacifico/taskmanager/taskconsumer
  183. github.com/darciopacifico/taskmanager/taskscheduler
  184. github.com/davent/telegraf/plugins/inputs/kafka_consumer
  185. github.com/davent/telegraf/plugins/outputs/kafka
  186. github.com/davewalk/adventures-in-go/graceful-shutdown
  187. github.com/dcos/dcos-metrics/producers/kafka
  188. github.com/degendra/kafka/consumergroup
  189. github.com/degendra/kafka/examples/consumergroup
  190. github.com/degendra/kafka/tools/consoleconsumer
  191. github.com/degendra/kafka/tools/consoleproducer
  192. github.com/degendra/kafka/tools/stressproducer
  193. github.com/degendra/kafka/tools/transferoffsets
  194. github.com/degendra/kafka/tools/verifier
  195. github.com/derekelkins/logspout
  196. github.com/devx/cadvisor/storage/kafka
  197. github.com/didip/haproxy-rest
  198. github.com/diebels727/ip-generator
  199. github.com/diebels727/kafka-publisher
  200. github.com/dim/sarama/examples/http_server
  201. github.com/dim/sarama/mocks
  202. github.com/dim/sarama/tools/kafka-console-consumer
  203. github.com/dim/sarama/tools/kafka-console-partitionconsumer
  204. github.com/dim/sarama/tools/kafka-console-producer
  205. github.com/disktnk/sb-kafka
  206. github.com/ds0nt/web-commander
  207. github.com/dzch/beats/libbeat/outputs/kafka
  208. github.com/dzch/binstore/binstore
  209. github.com/dzch/kafka-http-wrapper/kmonitor/kmonitor
  210. github.com/dzch/kafka-http-wrapper/kproxy/kproxy
  211. github.com/dzch/kproxy/kproxy
  212. github.com/dzlab/qbench/bench
  213. github.com/eapache/kafka-cache
  214. github.com/eapache/scratch
  215. github.com/echojc/kt
  216. github.com/eddyzhou/go-platform/trace/zipkin
  217. github.com/edwardxie/goim/logic
  218. github.com/ekarlso/sensory-persister
  219. github.com/elastic/beats/libbeat/outputs/kafka
  220. github.com/elastic/beats/metricbeat/module/kafka/partition
  221. github.com/elodina/go-kafka/producer
  222. github.com/elodina/go_kafka_client
  223. github.com/ericchiang/cadvisor/storage/kafka
  224. github.com/erimatnor/sarama/examples/http_server
  225. github.com/erimatnor/sarama/mocks
  226. github.com/erimatnor/sarama/tools/kafka-console-consumer
  227. github.com/erimatnor/sarama/tools/kafka-console-partitionconsumer
  228. github.com/erimatnor/sarama/tools/kafka-console-producer
  229. github.com/esiqveland/kafka-workshop/challenges
  230. github.com/esiqveland/kafka-workshop/setup
  231. github.com/fach/goarista/kafka
  232. github.com/fach/goarista/kafka/openconfig
  233. github.com/fach/goarista/kafka/producer
  234. github.com/fantasycool/leak_merge
  235. github.com/fantasycool/leak_merge/u_leak_merge
  236. github.com/felixb/logstash-kafka-tail
  237. github.com/fgeller/kt
  238. github.com/fire/heka/plugins/kafka
  239. github.com/foreversmart/goim/logic
  240. github.com/frodebjerke/kafka-workshop/challenges
  241. github.com/frodebjerke/kafka-workshop/setup
  242. github.com/funkygao/gafka/zk
  243. github.com/futurez/goim/logic
  244. github.com/futurez/goim/logic/job
  245. github.com/going/kafka
  246. github.com/google/cadvisor/storage/kafka
  247. github.com/gowroc/meetups/kafka2go/kafka
  248. github.com/grobie/cadvisor/storage/kafka
  249. github.com/guildencrantz/kazoo-offsets
  250. github.com/gunjan5/go30days-challenge/day28-kafka-go-sarama
  251. github.com/hanguofeng/taiji
  252. github.com/haoxins/goim-0/logic
  253. github.com/haoxins/goim-0/logic/job
  254. github.com/hartfordfive/beats/libbeat/outputs/kafka
  255. github.com/henrylee2cn/pholcus/common/kafka
  256. github.com/hongshibao/cadvisor/storage/kafka
  257. github.com/hoysoft/goim/logic
  258. github.com/hyperledger/fabric/orderer
  259. github.com/hyperledger/fabric/orderer/config
  260. github.com/hyperledger/fabric/orderer/kafka
  261. github.com/hyqer/kafka-forwarder
  262. github.com/i11cn/go_logger/extra
  263. github.com/ian-kent/service.go/consumer
  264. github.com/ian-kent/service.go/producer
  265. github.com/icebourg/Burrow
  266. github.com/ikenchina/gopush/admin
  267. github.com/ikenchina/gopush/push
  268. github.com/imc-trading/crywolf/consumer/kafka
  269. github.com/imc-trading/influxdb-consumer/kafka
  270. github.com/imroc/goim/logic
  271. github.com/imroc/imgo/logic
  272. github.com/influxdata/telegraf/plugins/inputs/kafka_consumer
  273. github.com/influxdata/telegraf/plugins/outputs/kafka
  274. github.com/ingensi/beats/libbeat/outputs/kafka
  275. github.com/innerr/heka-kafka
  276. github.com/iobeam/go_kafka_client
  277. github.com/iobeam/go_kafka_client/producers
  278. github.com/iobeam/go_kafka_client/syslog
  279. github.com/iobeam/sarama/examples/http_server
  280. github.com/iobeam/sarama/mocks
  281. github.com/iobeam/sarama/tools/kafka-console-consumer
  282. github.com/iobeam/sarama/tools/kafka-console-partitionconsumer
  283. github.com/iobeam/sarama/tools/kafka-console-producer
  284. github.com/it-man-cn/goim/logic
  285. github.com/jameswei/Burrow
  286. github.com/jamiealquiza/sangrenel
  287. github.com/janqii/kafka
  288. github.com/janqii/kafka/consumergroup
  289. github.com/jeffallen/kboing
  290. github.com/jeffchao/gomkafka
  291. github.com/jeffchao/gomkafka/gomkafka
  292. github.com/jelmersnoeck/gizmo/pubsub
  293. github.com/jeremyschlatter/sarama/mocks
  294. github.com/jghiloni/kafka-firehose-nozzle
  295. github.com/johann8384/libbeat/outputs/kafka
  296. github.com/jonbuffington/sarama/examples/http_server
  297. github.com/jonbuffington/sarama/mocks
  298. github.com/jonbuffington/sarama/tools/kafka-console-consumer
  299. github.com/jonbuffington/sarama/tools/kafka-console-partitionconsumer
  300. github.com/jonbuffington/sarama/tools/kafka-console-producer
  301. github.com/jonog/sarama/mocks
  302. github.com/joshjdevl/kafka-data-generator
  303. github.com/justinbeltran/httpkafka
  304. github.com/justinwalz/beats/libbeat/outputs/kafka
  305. github.com/jxstanford/thingz-agent/publishers
  306. github.com/jxufeliujj/goim/logic
  307. github.com/jxufeliujj/goim/logic/job
  308. github.com/kaey/telegraf/plugins/inputs/kafka_consumer
  309. github.com/kaey/telegraf/plugins/outputs/kafka
  310. github.com/kazukgw/kafka-mysql-binloger/producer
  311. github.com/kerinin/http2kafka
  312. github.com/kirk91/goim/logic
  313. github.com/kirk91/goim/logic/job
  314. github.com/kklipsch/sarama/examples/http_server
  315. github.com/kklipsch/sarama/mocks
  316. github.com/kklipsch/sarama/tools/kafka-console-consumer
  317. github.com/kklipsch/sarama/tools/kafka-console-partitionconsumer
  318. github.com/kklipsch/sarama/tools/kafka-console-producer
  319. github.com/kmiku7/kafka/consumergroup
  320. github.com/kraveio/sarama/examples/http_server
  321. github.com/kraveio/sarama/mocks
  322. github.com/kraveio/sarama/tools/kafka-console-consumer
  323. github.com/kraveio/sarama/tools/kafka-console-partitionconsumer
  324. github.com/kraveio/sarama/tools/kafka-console-producer
  325. github.com/kwilsonO/log-collector/server
  326. github.com/kyle-wang/sarama/examples/http_server
  327. github.com/kyle-wang/sarama/mocks
  328. github.com/kyle-wang/sarama/tools/kafka-console-consumer
  329. github.com/kyle-wang/sarama/tools/kafka-console-partitionconsumer
  330. github.com/kyle-wang/sarama/tools/kafka-console-producer
  331. github.com/lcplj123/goim/logic
  332. github.com/leonardyp/goim/logic
  333. github.com/leonardyp/goim/logic/job
  334. github.com/linkedin/Burrow
  335. github.com/linminglu/goim/logic
  336. github.com/linminglu/goim/logic/job
  337. github.com/linminglu/wqs/engine/kafka
  338. github.com/linminglu/wqs/engine/queue
  339. github.com/liquidm/rex
  340. github.com/liquidm/rex/kafka
  341. github.com/litgh/sarama-cluster
  342. github.com/litgh/sarama-cluster/cmd/sarama-cluster-cli
  343. github.com/litgh/sarama/examples/http_server
  344. github.com/litgh/sarama/mocks
  345. github.com/litgh/sarama/tools/kafka-console-consumer
  346. github.com/litgh/sarama/tools/kafka-console-partitionconsumer
  347. github.com/litgh/sarama/tools/kafka-console-producer
  348. github.com/liu-rui/mq-benchmarking/benchmark/mq
  349. github.com/liudanking/goim/logic
  350. github.com/liudanking/goim/logic/job
  351. github.com/liutaihua/goim/logic
  352. github.com/liutaihua/goim/logic/job
  353. github.com/lixin9311/EventTracker/eventtracker
  354. github.com/lixin9311/EventTracker/tools
  355. github.com/ljagiello/telegraf/plugins/inputs/kafka_consumer
  356. github.com/ljagiello/telegraf/plugins/outputs/kafka
  357. github.com/localhots/satan/examples/daemons-kafka/kafka
  358. github.com/localhots/shezmu/examples/daemons-kafka/kafka
  359. github.com/lorcanluo/goim/logic
  360. github.com/lorcanluo/goim/logic/job
  361. github.com/luck02/LegacyProducer/Archiver
  362. github.com/luck02/LegacyProducer/LegacyProducer
  363. github.com/lysu/go-misc/kafka/p
  364. github.com/lysu/go-saga/storage/kafka
  365. github.com/magneticio/vamp-router/metrics
  366. github.com/mailgun/kafka-pixy/admin
  367. github.com/mailgun/kafka-pixy/apiserver
  368. github.com/mailgun/kafka-pixy/consumer/consumerimpl
  369. github.com/mailgun/kafka-pixy/consumer/groupcsm
  370. github.com/mailgun/kafka-pixy/consumer/mapper
  371. github.com/mailgun/kafka-pixy/consumer/msgstream
  372. github.com/mailgun/kafka-pixy/consumer/offsetmgr
  373. github.com/mailgun/kafka-pixy/consumer/partitioncsm
  374. github.com/mailgun/kafka-pixy/logging
  375. github.com/mailgun/kafka-pixy/producer
  376. github.com/mailgun/kafka-pixy/testhelpers/kafkahelper
  377. github.com/mailgun/sarama/mocks
  378. github.com/marcotroisi/gizmo/pubsub
  379. github.com/martinhoefling/beats/libbeat/outputs/kafka
  380. github.com/mateuszdyminski/am-pipeline/feeder
  381. github.com/mateuszdyminski/am-pipeline/indexer
  382. github.com/mateuszdyminski/am-pipeline/receiver
  383. github.com/mathpl/kafka_httpcat
  384. github.com/mattkanwisher/microservices-book-code/kafka
  385. github.com/mbinge/crontabd
  386. github.com/mbinge/crontabd/tools/kafka_sender
  387. github.com/mchmarny/thingz-agent/publishers
  388. github.com/mchmarny/thingz-server/load
  389. github.com/md14454/telegraf/plugins/inputs/kafka_consumer
  390. github.com/md14454/telegraf/plugins/outputs/kafka
  391. github.com/medcl/beats/libbeat/outputs/kafka
  392. github.com/mengjinglei/sarama/examples/http_server
  393. github.com/mengjinglei/sarama/mocks
  394. github.com/mengjinglei/sarama/tools/kafka-console-consumer
  395. github.com/mengjinglei/sarama/tools/kafka-console-partitionconsumer
  396. github.com/mengjinglei/sarama/tools/kafka-console-producer
  397. github.com/mguindin/tail-kafka
  398. github.com/micahhausler/cadvisor/storage/kafka
  399. github.com/micro/go-plugins/broker/kafka
  400. github.com/miffa/cm_im/logic
  401. github.com/miffa/cm_im/msgtransfer
  402. github.com/mikif70/telegraf/plugins/inputs/kafka_consumer
  403. github.com/mikif70/telegraf/plugins/outputs/kafka
  404. github.com/millken/go/logelasticsearch
  405. github.com/mistsys/go-kafka/producer
  406. github.com/mistsys/kafkatest
  407. github.com/mjbrender/go-snippets/kafka/broker
  408. github.com/mjbrender/go-snippets/kafka/consumer
  409. github.com/mjbrender/go-snippets/kafka/producer
  410. github.com/mkobetic/scratch
  411. github.com/mkuzmin/telegraf/plugins/inputs/kafka_consumer
  412. github.com/mkuzmin/telegraf/plugins/outputs/kafka
  413. github.com/mofirouz/kumis/src
  414. github.com/mondough/telegraf/plugins/inputs/kafka_consumer
  415. github.com/mondough/telegraf/plugins/outputs/kafka
  416. github.com/movableink/brutus
  417. github.com/mozilla-services/data-pipeline/heka/plugins/kafkaconsumergroup
  418. github.com/mozilla-services/heka/plugins/kafka
  419. github.com/mynetstudy/goim/logic
  420. github.com/nadiasvertex/chrysolite/article
  421. github.com/nanoservice/core-fanout/fanout/fanout
  422. github.com/nautilus/events/kafka
  423. github.com/newrelic-forks/kafka/consumergroup
  424. github.com/newrelic-forks/kafka/examples/consumergroup
  425. github.com/newrelic-forks/kafka/tools/consoleconsumer
  426. github.com/newrelic-forks/kafka/tools/consoleproducer
  427. github.com/newrelic-forks/kafka/tools/stressproducer
  428. github.com/newrelic-forks/kafka/tools/transferoffsets
  429. github.com/newrelic-forks/kafka/tools/verifier
  430. github.com/nickbp/dcos-metrics/collector
  431. github.com/nickmarrone/go_kafka_test
  432. github.com/nicknovitski/Burrow
  433. github.com/nicolasbarbe/gizmo/pubsub
  434. github.com/nicolasbarbe/kafka
  435. github.com/nieksand/sarama/examples/http_server
  436. github.com/nieksand/sarama/mocks
  437. github.com/nieksand/sarama/tools/kafka-console-consumer
  438. github.com/nieksand/sarama/tools/kafka-console-partitionconsumer
  439. github.com/nieksand/sarama/tools/kafka-console-producer
  440. github.com/nitro/heka/plugins/kafka
  441. github.com/noise/telegraf/plugins/inputs/kafka_consumer
  442. github.com/noise/telegraf/plugins/outputs/kafka
  443. github.com/noxer/telegraf/plugins/inputs/kafka_consumer
  444. github.com/noxer/telegraf/plugins/outputs/kafka
  445. github.com/npateriya/logspout
  446. github.com/ohlol/cadvisor/storage/kafka
  447. github.com/openshift/cadvisor/storage/kafka
  448. github.com/opentable/Burrow
  449. github.com/openzipkin/zipkin-go-opentracing
  450. github.com/opsmatic/kafka
  451. github.com/opsmatic/kafka/consumergroup
  452. github.com/orange-jacky/flight_index
  453. github.com/orange-jacky/flight_index_update
  454. github.com/orange-jacky/get_kafka
  455. github.com/orange-jacky/order_history
  456. github.com/orange-jacky/send_kafka
  457. github.com/orangesword/fermchamber/fancontroller
  458. github.com/orangesword/fermchamber/sensormonitor
  459. github.com/orangesword/zymurgauge/fermentationchamber
  460. github.com/orangesword/zymurgauge/mastercontrol
  461. github.com/oruen/kafka-consumer-lag
  462. github.com/otoolep/syslog-gollector/output
  463. github.com/ovh/tat/api/hook
  464. github.com/patrickdappollonio/sarama/examples/http_server
  465. github.com/patrickdappollonio/sarama/mocks
  466. github.com/patrickdappollonio/sarama/tools/kafka-console-consumer
  467. github.com/patrickdappollonio/sarama/tools/kafka-console-partitionconsumer
  468. github.com/patrickdappollonio/sarama/tools/kafka-console-producer
  469. github.com/patyx7/telegraf/plugins/inputs/kafka_consumer
  470. github.com/patyx7/telegraf/plugins/outputs/kafka
  471. github.com/paulstuart/telegraf/plugins/inputs/kafka_consumer
  472. github.com/paulstuart/telegraf/plugins/outputs/kafka
  473. github.com/payneio/go-syslog-kafka
  474. github.com/peteryj/sarama/examples/http_server
  475. github.com/peteryj/sarama/mocks
  476. github.com/peteryj/sarama/tools/kafka-console-consumer
  477. github.com/peteryj/sarama/tools/kafka-console-partitionconsumer
  478. github.com/peteryj/sarama/tools/kafka-console-producer
  479. github.com/phemmer/telegraf/plugins/inputs/kafka_consumer
  480. github.com/phemmer/telegraf/plugins/outputs/kafka
  481. github.com/phillihq/go-trial/kafka
  482. github.com/phillihq/logshot/logsend
  483. github.com/piotrkowalczuk/gonalytics-backend/lib
  484. github.com/piotrkowalczuk/gonalytics-backend/services
  485. github.com/piotrkowalczuk/gonalytics-backend/worker
  486. github.com/pr8kerl/telegraf/plugins/inputs/kafka_consumer
  487. github.com/pr8kerl/telegraf/plugins/outputs/kafka
  488. github.com/prezi/beats/libbeat/outputs/kafka
  489. github.com/pubnative/sarama/mocks
  490. github.com/pvh/go-kafka-example/consumer
  491. github.com/pvh/go-kafka-example/producer
  492. github.com/qinlodestar/goim/logic
  493. github.com/qinlodestar/simplecomet/server
  494. github.com/qtzheng/goim/logic
  495. github.com/qtzheng/goim/logic/job
  496. github.com/raboof/beats/libbeat/outputs/kafka
  497. github.com/raboof/microchat/events
  498. github.com/racker/Burrow
  499. github.com/rafrombrc/sarama/mocks
  500. github.com/raintank/eventtank
  501. github.com/raintank/fakemetrics/out
  502. github.com/raintank/fakemetrics/out/kafkamdam
  503. github.com/raintank/fakemetrics/out/kafkamdm
  504. github.com/raintank/metrictank
  505. github.com/raintank/metrictank/in/kafkamdam
  506. github.com/raintank/metrictank/in/kafkamdm
  507. github.com/raintank/metrictank/input/kafkamdm
  508. github.com/raintank/metrictank/mdata
  509. github.com/raintank/metrictank/mdata/clkafka
  510. github.com/raintank/metrictank/mdata/notifierKafka
  511. github.com/raintank/tsdb-gw/event_publish
  512. github.com/raintank/tsdb-gw/metric_publish
  513. github.com/rakutentech/kafka-firehose-nozzle
  514. github.com/redBorder/k2http
  515. github.com/reginaldosousa/telegraf/plugins/inputs/kafka_consumer
  516. github.com/reginaldosousa/telegraf/plugins/outputs/kafka
  517. github.com/remerge/rex
  518. github.com/remerge/rex/kafka
  519. github.com/rengawm/kafka/consumergroup
  520. github.com/rengawm/kafka/examples/consumergroup
  521. github.com/rengawm/kafka/tools/consoleconsumer
  522. github.com/rengawm/kafka/tools/consoleproducer
  523. github.com/rengawm/kafka/tools/stressproducer
  524. github.com/rengawm/kafka/tools/transferoffsets
  525. github.com/rengawm/kafka/tools/verifier
  526. github.com/retzkek/gratia2-collector
  527. github.com/robinpercy/telegraf/plugins/inputs/kafka_consumer
  528. github.com/robinpercy/telegraf/plugins/outputs/kafka
  529. github.com/saj1th/sarama/mocks
  530. github.com/saleswise/Burrow
  531. github.com/saleswise/kafka/consumergroup
  532. github.com/saleswise/kafka/examples/consumergroup
  533. github.com/saleswise/kafka/tools/consoleconsumer
  534. github.com/saleswise/kafka/tools/consoleproducer
  535. github.com/saleswise/kafka/tools/stressproducer
  536. github.com/saleswise/kafka/tools/transferoffsets
  537. github.com/saleswise/kafka/tools/verifier
  538. github.com/saranrapjs/gizmo/pubsub
  539. github.com/schleppy/Burrow
  540. github.com/sclasen/event-shuttle
  541. github.com/seborama/bevel
  542. github.com/seiflotfy/beats/libbeat/outputs/kafka
  543. github.com/seiflotfy/telegraf/plugins/inputs/kafka_consumer
  544. github.com/seiflotfy/telegraf/plugins/outputs/kafka
  545. github.com/sendgrid/kafka-go-consumergroup/consumergroup
  546. github.com/serejja/go_kafka_client
  547. github.com/sheepbao/goim/logic
  548. github.com/sheepbao/goim/logic/job
  549. github.com/shopify/sarama/examples/http_server
  550. github.com/shopify/sarama/mocks
  551. github.com/shopify/sarama/tools/kafka-console-consumer
  552. github.com/shopify/sarama/tools/kafka-console-partitionconsumer
  553. github.com/shopify/sarama/tools/kafka-console-producer
  554. github.com/silentred/goim/logic
  555. github.com/silentred/goim/logic/job
  556. github.com/siliconcow/scribe_kafka_translator
  557. github.com/skyec/astore/consumer/kafka
  558. github.com/skyportsystems/sarama/mocks
  559. github.com/soundcloud/cadvisor/storage/kafka
  560. github.com/sparrc/kafka/consumergroup
  561. github.com/sparrc/kafka/examples/consumergroup
  562. github.com/sparrc/kafka/tools/consoleconsumer
  563. github.com/sparrc/kafka/tools/consoleproducer
  564. github.com/sparrc/kafka/tools/stressproducer
  565. github.com/sparrc/kafka/tools/transferoffsets
  566. github.com/sparrc/kafka/tools/verifier
  567. github.com/st3v/go-plugins/broker/kafka
  568. github.com/stealthly/go-kafka/producer
  569. github.com/stealthly/go_kafka_client
  570. github.com/stuartweir/gizmo/pubsub
  571. github.com/suicidejack/go-kafka/producer
  572. github.com/suicidejack/go_kafka_client
  573. github.com/suicidejack/go_kafka_client/producers
  574. github.com/suicidejack/go_kafka_client/syslog
  575. github.com/supershal/telegraf/plugins/inputs/kafka_consumer
  576. github.com/supershal/telegraf/plugins/outputs/kafka
  577. github.com/szferi/kafka-queue
  578. github.com/takebayashi/sarama/examples/http_server
  579. github.com/takebayashi/sarama/mocks
  580. github.com/takebayashi/sarama/tools/kafka-console-consumer
  581. github.com/takebayashi/sarama/tools/kafka-console-partitionconsumer
  582. github.com/takebayashi/sarama/tools/kafka-console-producer
  583. github.com/takebayashi/umibe
  584. github.com/talbright/saramit
  585. github.com/tangentspace/telegraf-cloudwatch-plugin/outputs/kafka
  586. github.com/tangentspace/telegraf-cloudwatch-plugin/plugins/kafka_consumer
  587. github.com/tborg/sarama/examples/http_server
  588. github.com/tborg/sarama/mocks
  589. github.com/tborg/sarama/tools/kafka-console-consumer
  590. github.com/tborg/sarama/tools/kafka-console-partitionconsumer
  591. github.com/tborg/sarama/tools/kafka-console-producer
  592. github.com/tcnksm-sample/sarama/async-producer
  593. github.com/tcnksm-sample/sarama/consumer
  594. github.com/tcnksm-sample/sarama/http-log-producer
  595. github.com/tcnksm-sample/sarama/sync-producer
  596. github.com/terryh/mq-benchmarking/benchmark/mq
  597. github.com/tgermain/telegraf/plugins/inputs/kafka_consumer
  598. github.com/tgermain/telegraf/plugins/outputs/kafka
  599. github.com/thanzen/goim/logic
  600. github.com/thbkrkr/kafka-live-stream
  601. github.com/thbkrkr/kafka-topics
  602. github.com/thbkrkr/qli/client
  603. github.com/theskyinflames/go-misc/com.theskyinflames.go.misc/lib_gc_kafka_client
  604. github.com/thinkboy/goim/logic
  605. github.com/thomaso-mirodin/cadvisor/storage/kafka
  606. github.com/tkuhlman/monasca-goapi/src
  607. github.com/tnolet/haproxy-rest
  608. github.com/tomheon/kafkafs
  609. github.com/tomheon/kafkafs/kafkafs
  610. github.com/tompao/telegraf/plugins/inputs/kafka_consumer
  611. github.com/tompao/telegraf/plugins/outputs/kafka
  612. github.com/topfreegames/kafka/consumergroup
  613. github.com/topfreegames/kafka/examples/consumergroup
  614. github.com/topfreegames/kafka/tools/consoleconsumer
  615. github.com/topfreegames/kafka/tools/consoleproducer
  616. github.com/topfreegames/kafka/tools/stressproducer
  617. github.com/topfreegames/kafka/tools/transferoffsets
  618. github.com/topfreegames/kafka/tools/verifier
  619. github.com/tossp/gizmo/pubsub
  620. github.com/tossp/goim/logic
  621. github.com/travisjeffery/jocko/example
  622. github.com/trivago/gollum/consumer
  623. github.com/trivago/gollum/producer
  624. github.com/trustedanalytics/gateway
  625. github.com/ttthzy/goim/logic
  626. github.com/tylertreat/Flotilla/flotilla-server/daemon/broker/kafka
  627. github.com/tylertreat/bench/requester
  628. github.com/tylertreat/mq-benchmarking/benchmark/mq
  629. github.com/uohzxela/heka-kafka-input
  630. github.com/uovobw/sarama/mocks
  631. github.com/urso/kafka_brokers
  632. github.com/uswitch/Burrow
  633. github.com/vanillahsu/telegraf/plugins/inputs/kafka_consumer
  634. github.com/vanillahsu/telegraf/plugins/outputs/kafka
  635. github.com/vashstorm/sarama/mocks
  636. github.com/vasilcovsky/microservices-book-code/kafka
  637. github.com/venicegeo/mpg-sandbox/piazza
  638. github.com/venicegeo/pz-alerter/workflow
  639. github.com/venicegeo/pz-gocommon/kafka
  640. github.com/venicegeo/pz-workflow/workflow
  641. github.com/vikascoupa/MQPrototype/async_producer
  642. github.com/vikascoupa/MQPrototype/consumer
  643. github.com/vikascoupa/MQPrototype/producer
  644. github.com/vishh/cadvisor/storage/kafka
  645. github.com/vladiacob/go_kafka_client
  646. github.com/vrischmann/koff
  647. github.com/vrischmann/sarama/mocks
  648. github.com/waterlink/tls-adapter
  649. github.com/weibocom/wqs/engine/kafka
  650. github.com/weibocom/wqs/engine/queue
  651. github.com/wenzhenxi/phalgo-sample/test
  652. github.com/winlinvip/sarama/mocks
  653. github.com/wjessop/krater
  654. github.com/wjessop/krater/kafkaconsumer
  655. github.com/woodsaj/go-kafka-test
  656. github.com/wujunjian/sarama/examples/http_server
  657. github.com/wujunjian/sarama/mocks
  658. github.com/wujunjian/sarama/tools/kafka-console-consumer
  659. github.com/wujunjian/sarama/tools/kafka-console-partitionconsumer
  660. github.com/wujunjian/sarama/tools/kafka-console-producer
  661. github.com/wvanbergen/kafka/consumergroup
  662. github.com/wxaxiaoyao/goim/logic
  663. github.com/wxjs33/kfkcp/kfkc
  664. github.com/wxjs33/kfkcp/kfkp
  665. github.com/xebia/micro-chat-users/kafka
  666. github.com/xert/telegraf/plugins/inputs/kafka_consumer
  667. github.com/xert/telegraf/plugins/outputs/kafka
  668. github.com/xianmau/heka/plugins/kafka
  669. github.com/xiaxin/lemo
  670. github.com/xiaxin/moii_golang
  671. github.com/xiaxin/moii_golang/kafka/worker
  672. github.com/xladykiller/goim/logic
  673. github.com/xuyi/heka/plugins/kafka
  674. github.com/yangzhao28/rtblite
  675. github.com/yanzay/go_kafka_client
  676. github.com/yanzay/go_kafka_client/producers
  677. github.com/yanzay/go_kafka_client/syslog
  678. github.com/yaxinlx/sarama/examples/http_server
  679. github.com/yaxinlx/sarama/mocks
  680. github.com/yaxinlx/sarama/tools/kafka-console-consumer
  681. github.com/yaxinlx/sarama/tools/kafka-console-partitionconsumer
  682. github.com/yaxinlx/sarama/tools/kafka-console-producer
  683. github.com/yejingx/kafka/consumergroup
  684. github.com/yejingx/kafka/examples/consumergroup
  685. github.com/yejingx/kafka/tools/consoleconsumer
  686. github.com/yejingx/kafka/tools/consoleproducer
  687. github.com/yejingx/kafka/tools/stressproducer
  688. github.com/yejingx/kafka/tools/transferoffsets
  689. github.com/yejingx/kafka/tools/verifier
  690. github.com/yichen/ktop
  691. github.com/yichen/ktop/koffset
  692. github.com/ypyf/golang-study/kafka
  693. github.com/yuankui/kafka-console
  694. github.com/yudai/go_kafka_client
  695. github.com/yunxing/kafka/consumergroup
  696. github.com/zbindenren/telegraf/plugins/inputs/kafka_consumer
  697. github.com/zbindenren/telegraf/plugins/outputs/kafka
  698. github.com/zensqlmonitor/telegraf/plugins/inputs/kafka_consumer
  699. github.com/zensqlmonitor/telegraf/plugins/outputs/kafka
  700. github.com/zhang0137/cadvisor/storage/kafka
  701. github.com/zhangpeihao/cadvisor/storage/kafka
  702. github.com/zhjh1209/goim/logic
  703. github.com/znly/sarama-cluster
  704. github.com/zstyblik/beats/libbeat/outputs/kafka
  705. github.com/zyfdegh/cadvisor/storage/kafka
  706. github.com/zyrshui/goim/logic
  707. gopkg.in/ORBAT/krater.v1
  708. gopkg.in/Shopify/sarama.v1/mocks
  709. gopkg.in/bsm/sarama-cluster.v0
  710. gopkg.in/bsm/sarama-cluster.v1
  711. gopkg.in/bsm/sarama-cluster.v2
  712. gopkg.in/elastic/beats.v5/libbeat/outputs/kafka
  713. gopkg.in/elastic/beats.v5/metricbeat/module/kafka/partition
  714. gopkg.in/linkedin/burrow.v0
  715. gopkg.in/seborama/bevel.v1
  716. gopkg.in/shopify/sarama.v1/mocks

Imported only in test by 6 package(s)

  1. github.com/elodina/go-kafka
  2. github.com/mailgun/kafka-pixy/service
  3. github.com/mistsys/go-kafka
  4. github.com/stealthly/go-kafka
  5. github.com/suicidejack/go-kafka
  6. github.com/vadimtk/telegraf/plugins/kafka_consumer

Imports 6 package(s)

  1. github.com/klauspost/crc32
  2. github.com/rcrowley/go-metrics
  3. github.com/eapache/go-xerial-snappy
  4. github.com/eapache/go-resiliency/breaker
  5. github.com/eapache/queue
  6. github.com/davecgh/go-spew/spew

Test imports 1 package(s)

  1. github.com/Shopify/toxiproxy/client