franz-go:franz-go包含一个高性能的纯Go库，用于与从0.8.0到2.7.0+的Kafka进行交互。 生产，消费，...
需积分: 31 76 浏览量
2021-04-19
15:34:21
上传
评论
收藏 414KB ZIP 举报
franz-go:franz-go包含一个高性能的纯Go库，用于与从0.8.0到2.7.0+的Kafka进行交互。 生产，消费，交易，管理等 （139个子文件） 
00_produce 7KB 01_fetch 10KB 02_list_offsets 5KB 03_metadata 5KB 04_leader_and_isr 2KB 05_stop_replica 1KB 06_update_metadata 1KB 07_controlled_shutdown 811B 08_offset_commit 5KB 09_offset_fetch 3KB 10_find_coordinator 2KB 11_join_group 7KB 12_heartbeat 1KB 13_leave_group 2KB 14_sync_group 3KB 15_describe_groups 3KB 16_list_groups 1KB 17_sasl_handshake 1KB 18_api_versions 3KB 19_create_topics 5KB 20_delete_topics 2KB 21_delete_records 3KB 22_init_producer_id 2KB 23_offset_for_leader_epoch 4KB 24_add_partitions_to_txn 3KB 25_add_offsets_to_txn 1KB 26_end_txn 2KB 27_write_txn_markers 670B 28_txn_offset_commit 4KB 29_describe_acls 3KB 30_create_acls 2KB 31_delete_acls 1KB 32_describe_configs 4KB 33_alter_configs 3KB 34_alter_replica_log_dirs 2KB 35_describe_log_dirs 2KB 36_sasl_authenticate 1KB 37_create_partitions 3KB 38_create_delegation_token 2KB 39_renew_delegation_token 884B 40_expire_delegation_token 1KB 41_describe_delegation_token 2KB 42_delete_groups 1KB 43_elect_leaders 3KB 44_incremental_alter_configs 3KB 45_alter_partition_assignments 2KB 46_list_partition_reassignments 2KB 47_offset_delete 2KB 48_describe_client_quotas 2KB 49_alter_client_quotas 2KB 50_describe_user_scram_credentials 1KB 51_alter_user_scram_credentials 1KB 52_vote 1KB 53_begin_quorum_epoch 896B 54_end_quorum_epoch 1013B 55_describe_quorum 1KB 56_alter_isr 996B 57_update_features 1KB 58_envelope 792B 59_fetch_snapshot 2KB 60_describe_cluster 1KB 61_describe_producers 2KB 62_broker_registration 1KB 63_broker_heartbeat 867B 64_unregister_broker 469B 65_describe_transactions 2KB 66_list_transactions 2KB kafka_server_jaas.conf 286B enums 2KB .gitignore 23B generated.go 876KB client.go 74KB consumer_group.go 64KB sink.go 56KB source.go 43KB consumer.go 39KB broker.go 39KB config.go 36KB sticky_test.go 31KB kversion.go 27KB txn.go 24KB gen.go 22KB group_balancer.go 22KB kerr.go 21KB sticky.go 20KB producer.go 19KB parse.go 17KB primitives.go 15KB metadata.go 12KB main.go 12KB produce_request_test.go 11KB interface.go 9KB topics_and_partitions.go 9KB scram.go 8KB record_and_fetch.go 8KB compression.go 8KB txn_test.go 6KB helpers_test.go 6KB partitioner.go 6KB kerberos.go 5KB共 139 条
- 1
- 2
资源评论
giao金
- 粉丝: 31
- 资源: 4604
最新资源
- 这是一个保存Springboot+MyBaits项目的仓库.zip
- tensorflow-gpu-2.7.2-cp39-cp39-manylinux2010-x86-64.whl
- tensorflow-2.7.4-cp38-cp38-manylinux2010-x86-64.whl
- tensorflow-gpu-2.7.4-cp38-cp38-manylinux2010-x86-64.whl
- 詹佳 陈敏 口语2.mp3
- 图书管理系统毕业设计Java语言实现
- turtle-0.0.2.zip
- 机器学习（股票），基于机器学习算法支持向量机SVM的交易策略
- 1713969763417.png
- 国家药品编码本位码,国家药品编码本位码,国家药品编码本位码,国家药品编码本位码
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
