 Edoardo Comar
|
587c5f694a
Revert to individual msg retries for non-idempotent
|
%!s(int64=5) %!d(string=hai) anos |
|
Edoardo Comar
|
eb38bbc24f
single metadata refresh for all retries
|
%!s(int64=5) %!d(string=hai) anos |
|
Edoardo Comar
|
4e5d477980
Idempotent Producer - batch retry logic
|
%!s(int64=5) %!d(string=hai) anos |
 Mickael Maison
|
8e2b04b363
Added support for Idempotent Producer
|
%!s(int64=6) %!d(string=hai) anos |
 Evan Huus
|
6d9cc201b5
Add version check for headers
|
%!s(int64=6) %!d(string=hai) anos |
|
Evan Huus
|
bc4e2742d5
Merge pull request #1112 from evan-stripe/extended-partitioner
|
%!s(int64=6) %!d(string=hai) anos |
 Evan Broder
|
9b2c4d6e2c
Make Partitioner.RequiresConsistency vary per-message
|
%!s(int64=6) %!d(string=hai) anos |
 tianji
|
1e2740380a
Do not modify ProducerMessage.MetaData during the whole publishing process.
|
%!s(int64=6) %!d(string=hai) anos |
 Vlad Hanciuta
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
%!s(int64=6) %!d(string=hai) anos |
 Dieter Plaetinck
|
5046283ff1
fix mention of Return.Successes
|
%!s(int64=7) %!d(string=hai) anos |
|
Evan Huus
|
8268907a6b
Tweak documentation of Close/AsyncClose methods
|
%!s(int64=7) %!d(string=hai) anos |
 DiSiqueira
|
cecb3d9807
Formating all files with gofmt -s
|
%!s(int64=7) %!d(string=hai) anos |
|
Evan Huus
|
17b655d247
Producer: block in `Close` without `Return.Errors`
|
%!s(int64=7) %!d(string=hai) anos |
 yingnanliu
|
16a22e0995
Don't propagate zero timestamp to ProducerMessage
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
5246fed60b
Fix parsing of producer timestamp
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
90b61cbf50
Support and provide producer message timestamps
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
2b18ad7079
Merge pull request #589 from Shopify/retriable-errors
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
55f98d5111
Upstream has spoken on retriable errors
|
%!s(int64=8) %!d(string=hai) anos |
 Ben Burkert
|
29d4b91ea5
replace label & goto with a method
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
b8b4670075
Merge pull request #562 from Shopify/producer-syn-fin
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
52c880384b
Extract produceSet and add tests
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
976e0ef2f6
Adjust logging to match the explicit state machine
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
77c54f710e
producer: explicitly register partitions
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
b3cb7cadf1
Refactor the producer, part 3
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
733c74f30d
Refactor the producer, part 2
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
aa044e2295
Refactor the producer, part 1
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
2d2d5472f8
producer: simplify initial "too large" check
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
53f2a54a5c
Merge pull request #538 from Shopify/handle-unencodable-messages
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
6facece8ef
Wrap godoc to 80 chars, round 2
|
%!s(int64=8) %!d(string=hai) anos |
|
Evan Huus
|
93c1f7437d
Wrap all godoc at 80 characters
|
%!s(int64=8) %!d(string=hai) anos |
