文件名称：Go-JOCKO用Golang实现Kafka
文件大小：85KB
文件格式：ZIP
更新时间：2022-09-02 21:11:24
Go开发-消息系统
JOCKO：用Golang实现Kafka
【文件预览】：
travisjeffery-jocko-c4bdec8
----Gopkg.toml(2KB)
----.goreleaser.yml(483B)
----.gitignore(69B)
----prometheus()
--------metrics.go(404B)
----Dockerfile(451B)
----Makefile(388B)
----server()
--------server.go(6KB)
--------server_test.go(4KB)
--------join_test.go(1KB)
--------client.go(2KB)
----.travis.yml(150B)
----raft()
--------fsm.go(845B)
--------raft.go(4KB)
--------leader.go(3KB)
--------option.go(482B)
----CONTRIBUTING.md(1KB)
----LICENSE(1KB)
----serf()
--------serf.go(6KB)
--------option.go(384B)
--------serf_test.go(2KB)
----commitlog()
--------commitlog.go(4KB)
--------message_set.go(819B)
--------cleaner.go(936B)
--------util.go(354B)
--------segment.go(4KB)
--------commitlog_test.go(3KB)
--------message.go(97B)
--------index.go(4KB)
--------message_set_test.go(552B)
--------reader.go(1002B)
--------index_test.go(1KB)
----docker-compose.yml(466B)
----examples()
--------sarama()
--------cluster()
----README.md(3KB)
----testutil()
--------test.sh(274B)
--------mock()
--------wait.go(703B)
----broker()
--------fsm.go(2KB)
--------replicator_test.go(1KB)
--------broker_test.go(41KB)
--------util.go(1KB)
--------option.go(2KB)
--------broker.go(20KB)
--------replicator.go(2KB)
----jocko.go(6KB)
----Gopkg.lock(7KB)
----protocol()
--------metadata_response.go(3KB)
--------response.go(601B)
--------request_header.go(868B)
--------group_coordinator_request.go(434B)
--------delete_topic_response.go(747B)
--------heartbeat_request.go(751B)
--------offsets_request.go(2KB)
--------fetch_request.go(2KB)
--------leader_and_isr_request.go(2KB)
--------sync_group_response.go(524B)
--------join_group_request.go(2KB)
--------message_set.go(835B)
--------describe_groups_response.go(3KB)
--------error.go(7KB)
--------list_groups_request.go(334B)
--------create_topics_response.go(815B)
--------crc_field.go(621B)
--------metadata_request.go(400B)
--------create_topic_requests.go(2KB)
--------sync_group_request.go(1KB)
--------heartbeat_response.go(395B)
--------stop_replica_request.go(1KB)
--------leader_and_isr_response.go(1KB)
--------fetch_response.go(2KB)
--------decoder.go(5KB)
--------leave_group_request.go(544B)
--------stop_replica_response.go(1KB)
--------produce_response.go(2KB)
--------encoder.go(5KB)
--------api_key.go(685B)
--------api_versions_response.go(1000B)
--------message.go(1011B)
--------join_group_response.go(2KB)
--------produce_request.go(2KB)
--------protocol.go(328B)
--------list_groups_response.go(1KB)
--------describe_groups_request.go(437B)
--------group_coordinator_response.go(820B)
--------offsets_response.go(2KB)
--------leave_group_response.go(400B)
--------delete_topic_request.go(569B)
--------request.go(440B)
--------size_field.go(573B)
--------api_versions_requests.go(332B)
----cmd()
--------jocko()