文件名称：Kafka有线协议的Golang实现。-Golang开发
文件大小：70KB
文件格式：ZIP
更新时间：2024-06-15 12:17:08
Golang Messaging
软件包libkafka是一个低级库，用于从Kafka 2.3+生成和使用。 它没有外部依赖性。 它不是在Java客户端上建模的。 所有API调用都是同步的，并且所有代码都在调用goroutine中执行。 软件包libkafka是一个低级库，用于从Kafka 2.3+生成和使用。 它没有外部依赖性。 它不是在Java客户端上建模的。 所有API调用都是同步的，并且所有代码都在调用goroutine中执行。 项目范围图书馆侧重于非交易性生产和消费。 它实现了单个分区Producer和Consumer。 多分区生产者和使用者建立在该库的顶部（示例：https://github.com/mkocikowski/kafkaclie
【文件预览】：
libkafka-master
----.travis.yml(249B)
----client()
--------partition_test.go(4KB)
--------fetcher()
--------client_test.go(2KB)
--------client.go(4KB)
--------producer()
--------group_test.go(3KB)
--------partition.go(6KB)
--------group.go(7KB)
----compression()
--------compression.go(539B)
----varint()
--------varint_test.go(396B)
--------varint.go(1KB)
----wire()
--------wire.go(5KB)
--------wire_test.go(634B)
----record()
--------record.go(4KB)
--------record_test.go(3KB)
----test()
--------wait-for-it.sh(5KB)
--------Dockerfile(796B)
--------log4j.properties(5KB)
--------docker-compose.yaml(585B)
--------v1_0()
--------server.properties(7KB)
--------zookeeper.properties(1023B)
----errors.go(7KB)
----api()
--------SyncGroup()
--------OffsetCommit()
--------JoinGroup()
--------ListOffsets()
--------doc.go(74B)
--------FindCoordinator()
--------response.go(995B)
--------Fetch()
--------api.go(3KB)
--------OffsetFetch()
--------Heartbeat()
--------Metadata()
--------Produce()
--------ApiVersions()
--------CreateTopics()
--------request.go(676B)
----LICENSE(1KB)
----.gitignore(286B)
----Makefile(44B)
----go.sum(0B)
----batch()
--------batch_test.go(6KB)
--------batch.go(9KB)
----README.md(3KB)
----libkafka.go(3KB)
----go.mod(48B)