文件名称：基于低级libkafka库的高级Golang kafka客户端-Golang开发
文件大小：37KB
文件格式：ZIP
更新时间：2024-06-15 12:54:20
Golang Messaging
这是基于低级libkafka库的高级kafka客户端。 它是Sarama产生大量消息的替代方法。 概述这是基于低级libkafka库的高级kafka客户端。 它是Sarama产生大量消息的替代方法。 主要设计要点是该库按记录批次而不是单个记录进行操作。 这使其在大批量生产时更加高效。 将记录编组为批次（构建批次）是从发送（生产）批次到Kafka的单独步骤。 这意味着可以更精确地控制资源使用（内存，cpu）。 通讯
【文件预览】：
kafkaclient-master
----consumer()
--------static_test.go(2KB)
--------handler.go(3KB)
--------batch.go(2KB)
--------handler_test.go(2KB)
--------doc.go(1KB)
--------exchange_test.go(2KB)
--------batch_test.go(2KB)
--------static.go(3KB)
--------exchange.go(2KB)
----go.mod(192B)
----go.sum(183B)
----groups()
--------assigners()
--------groups.go(3KB)
--------groups_test.go(2KB)
----offsets()
--------offsets.go(2KB)
--------offsets_test.go(1KB)
----builder()
--------partitioner.go(534B)
--------builder.go(7KB)
--------partitioner_test.go(296B)
--------builder_test.go(5KB)
----.travis.yml(249B)
----LICENSE(1KB)
----doc.go(362B)
----test()
--------Dockerfile(806B)
--------wait-for-it.sh(5KB)
--------zookeeper.properties(1023B)
--------server.properties(7KB)
--------docker-compose.yaml(595B)
----producer()
--------producer_test.go(4KB)
--------producer.go(11KB)
----README.md(1KB)
----Makefile(44B)
----errors()
--------errors_test.go(747B)
--------errors.go(817B)
----.gitignore(23B)