Начало Каталог Помощ
Регистрация Вход
publics
/
sarama
0
0
Разклонения 0
Файлове Задачи 0 Заявки за сливане 0 Уики

Няма описание

ИН на ревизия: ee044df3c7
Клонове Маркери
sarama
Evan Huus ee044df3c7 Merge pull request #664 from slaunay/bugfix/empty-client-id преди 9 години
examples af448a6f24 Fix names as a_name to be aName преди 10 години
mocks e0cbdba3d1 Fixes typo. преди 10 години
tools 9008214b35 Rename topicConsumer tool to just consumer преди 10 години
vagrant d094b35ff3 Bump to toxiproxy 2.0 преди 9 години
.gitignore d3bc825c36 Add Vagrantfile, and provisioning scripts that set up a working 5-node cluster. преди 11 години
.travis.yml 5e89a31b27 Drop go 1.4 and update tools/docs appropriately преди 9 години
CHANGELOG.md 38d579a708 Prep for v1.9 преди 9 години
CONTRIBUTING.md 6aacbb7d86 Some additions преди 11 години
MIT-LICENSE 86b4691cdd Add license information преди 12 години
Makefile 5e89a31b27 Drop go 1.4 and update tools/docs appropriately преди 9 години
README.md 5e89a31b27 Drop go 1.4 and update tools/docs appropriately преди 9 години
Vagrantfile f3aa1b53de Upgrade vagrant from precise to trusty преди 10 години
async_producer.go 2b18ad7079 Merge pull request #589 from Shopify/retriable-errors преди 10 години
async_producer_test.go 201ab73cb4 Make mock brokers and protocol packets available for outsider преди 10 години
broker.go d0d6717d96 rename doSASLPlainAuth to sendAndReceiveSASLPlainAuth преди 9 години
broker_test.go 201ab73cb4 Make mock brokers and protocol packets available for outsider преди 10 години
client.go bed560f780 Add additional error handling based on spec преди 10 години
client_test.go 201ab73cb4 Make mock brokers and protocol packets available for outsider преди 10 години
config.go 666bedf384 Moving constant to client.go and making it private преди 9 години
config_test.go eb9150647a Forbid empty ClientID and use 'sarama' as default преди 9 години
consumer.go bbe99d8b16 occured -> occurred преди 9 години
consumer_group_members.go 83f973c2d6 More feedback, renamed structs преди 10 години
consumer_group_members_test.go 1ad3d11a6a Fix flaky test преди 10 години
consumer_metadata_request.go aa411f16fd Add decode method to request types преди 10 години
consumer_metadata_request_test.go aa411f16fd Add decode method to request types преди 10 години
consumer_metadata_response.go 9b6ac1a0fe Add mock responses for OffsetManager testing преди 10 години
consumer_metadata_response_test.go 9b6ac1a0fe Add mock responses for OffsetManager testing преди 10 години
consumer_test.go 5d23f48cfe Makes newMockMetadataResponse exported (fixes #609) преди 10 години
crc32_field.go 8fa523b125 Use an optimized crc32 library which is faster преди 10 години
describe_groups_request.go 7611ea6ab0 Add DescribeGroup request and response pair. преди 10 години
describe_groups_request_test.go 1621c4959a Add tests for all new request types. преди 10 години
describe_groups_response.go 7611ea6ab0 Add DescribeGroup request and response pair. преди 10 години
describe_groups_response_test.go 756801dfa2 Add tests for all new response types преди 10 години
dev.yml 388a9be865 fix name in dev.yml преди 9 години
encoder_decoder.go 66411d8222 Cleanup a bunch more error formats преди 10 години
errors.go 2bac783afa Add new protocol errors with their respective messages. преди 10 години
fetch_request.go aa411f16fd Add decode method to request types преди 10 години
fetch_request_test.go aa411f16fd Add decode method to request types преди 10 години
fetch_response.go 900e4f4595 Centralize and unify getSubset error checking преди 10 години
fetch_response_test.go 87c89f868c Also prefix KError instances with Err. преди 11 години
functional_client_test.go f0fc7e9247 Finalize most of the toxiproxy test framework преди 10 години
functional_consumer_test.go f0fc7e9247 Finalize most of the toxiproxy test framework преди 10 години
functional_offset_manager_test.go 1e5cc31d7c Fix offset_manager for Kafka 0.9.0.0 преди 10 години
functional_producer_test.go f0fc7e9247 Finalize most of the toxiproxy test framework преди 10 години
functional_test.go 2c40df751c Fix version.satisfies so all tests run against 0.9 преди 10 години
heartbeat_request.go b1d40bdba9 Add Heartbeat request and response pair. преди 10 години
heartbeat_request_test.go 1621c4959a Add tests for all new request types. преди 10 години
heartbeat_response.go b1d40bdba9 Add Heartbeat request and response pair. преди 10 години
heartbeat_response_test.go 756801dfa2 Add tests for all new response types преди 10 години
join_group_request.go 83f973c2d6 More feedback, renamed structs преди 10 години
join_group_request_test.go 1621c4959a Add tests for all new request types. преди 10 години
join_group_response.go 83f973c2d6 More feedback, renamed structs преди 10 години
join_group_response_test.go 756801dfa2 Add tests for all new response types преди 10 години
leave_group_request.go ccec1aae54 Add LeaveGroup request and response pair. преди 10 години
leave_group_request_test.go 1621c4959a Add tests for all new request types. преди 10 години
leave_group_response.go ccec1aae54 Add LeaveGroup request and response pair. преди 10 години
leave_group_response_test.go 756801dfa2 Add tests for all new response types преди 10 години
length_field.go 66411d8222 Cleanup a bunch more error formats преди 10 години
list_groups_request.go 037310ad5d Add ListGroups request and response pair. преди 10 години
list_groups_request_test.go 1621c4959a Add tests for all new request types. преди 10 години
list_groups_response.go 037310ad5d Add ListGroups request and response pair. преди 10 години
list_groups_response_test.go 756801dfa2 Add tests for all new response types преди 10 години
message.go 2594b8edd6 Fix and simplify message decoding преди 10 години
message_set.go 2018fd405e Prefix error variables with Err преди 11 години
message_test.go 9675a91962 Added Gzip test. Simplified a little. преди 12 години
metadata_request.go aa411f16fd Add decode method to request types преди 10 години
metadata_request_test.go aa411f16fd Add decode method to request types преди 10 години
metadata_response.go 7f2cdf6cd2 Do not use partition cache for unknown topics. преди 11 години
metadata_response_test.go 87c89f868c Also prefix KError instances with Err. преди 11 години
mockbroker.go 6888eccc97 Don't import `testing` in the main lib преди 10 години
mockresponses.go 6888eccc97 Don't import `testing` in the main lib преди 10 години
offset_commit_request.go f13498ffc9 tweak docs преди 10 години
offset_commit_request_test.go aa411f16fd Add decode method to request types преди 10 години
offset_commit_response.go 9b6ac1a0fe Add mock responses for OffsetManager testing преди 10 години
offset_commit_response_test.go 9b6ac1a0fe Add mock responses for OffsetManager testing преди 10 години
offset_fetch_request.go aa411f16fd Add decode method to request types преди 10 години
offset_fetch_request_test.go aa411f16fd Add decode method to request types преди 10 години
offset_fetch_response.go 9b6ac1a0fe Add mock responses for OffsetManager testing преди 10 години
offset_fetch_response_test.go 9b6ac1a0fe Add mock responses for OffsetManager testing преди 10 години
offset_manager.go 53285c9f5e Fix race condition on OffsetManager shutdown преди 9 години
offset_manager_test.go 7f63fa323d Merge pull request #570 from mailgun/maxim/publish преди 10 години
offset_request.go aa411f16fd Add decode method to request types преди 10 години
offset_request_test.go aa411f16fd Add decode method to request types преди 10 години
offset_response.go 39823e3af9 Check some errors преди 11 години
offset_response_test.go 87c89f868c Also prefix KError instances with Err. преди 11 години
packet_decoder.go 1badb8e8c4 Add JoinGroup request and response pair. преди 10 години
packet_encoder.go 1badb8e8c4 Add JoinGroup request and response pair. преди 10 години
partitioner.go 6facece8ef Wrap godoc to 80 chars, round 2 преди 10 години
partitioner_test.go faec514115 Add an example for different partitioning per topic. преди 11 години
prep_encoder.go 1badb8e8c4 Add JoinGroup request and response pair. преди 10 години
produce_request.go 900e4f4595 Centralize and unify getSubset error checking преди 10 години
produce_request_test.go aa411f16fd Add decode method to request types преди 10 години
produce_response.go 5509b4a29c wip преди 12 години
produce_response_test.go 87c89f868c Also prefix KError instances with Err. преди 11 години
produce_set.go 52c880384b Extract produceSet and add tests преди 10 години
produce_set_test.go ec382518ee Fix errcheck преди 10 години
real_decoder.go 1badb8e8c4 Add JoinGroup request and response pair. преди 10 години
real_encoder.go 1badb8e8c4 Add JoinGroup request and response pair. преди 10 години
request.go a050648142 Register new request type keys in request.go преди 10 години
request_test.go 9dbdf89484 Better assertion failure messages from request_test. преди 10 години
response_header.go 66411d8222 Cleanup a bunch more error formats преди 10 години
response_header_test.go 893044d278 Fix Golint errors, except for all the missing comments. преди 12 години
sarama.go 21c17a5001 Update a bunch of docs преди 9 години
snappy.go 0aeb8f0f95 Update snappy repo path and encoding interface преди 10 години
snappy_test.go 03d03b3c61 Minor lint changes преди 10 години
sync_group_request.go 83f973c2d6 More feedback, renamed structs преди 10 години
sync_group_request_test.go 1621c4959a Add tests for all new request types. преди 10 години
sync_group_response.go 83f973c2d6 More feedback, renamed structs преди 10 години
sync_group_response_test.go 756801dfa2 Add tests for all new response types преди 10 години
sync_producer.go 21c17a5001 Update a bunch of docs преди 9 години
sync_producer_test.go 201ab73cb4 Make mock brokers and protocol packets available for outsider преди 10 години
utils.go 797cb29ada un-export newBufConn преди 10 години

README.md

sarama

GoDoc Build Status

Sarama is an MIT-licensed Go client library for Apache Kafka version 0.8 (and later).

Getting started

  • API documentation and examples are available via godoc.
  • Mocks for testing are available in the mocks subpackage.
  • The examples directory contains more elaborate example applications.
  • The tools directory contains command line tools that can be useful for testing, diagnostics, and instrumentation.

Compatibility and API stability

Sarama provides a "2 releases + 2 months" compatibility guarantee: we support the two latest stable releases of Kafka and Go, and we provide a two month grace period for older releases. This means we currently officially support Go 1.6 and 1.5, and Kafka 0.9.0 and 0.8.2, although older releases are still likely to work.

Sarama follows semantic versioning and provides API stability via the gopkg.in service. You can import a version with a guaranteed stable API via http://gopkg.in/Shopify/sarama.v1. A changelog is available here.

Contributing