Diego Alvarez
|
574371b50a
removes var when assigning a value immediately
|
4 år sedan |
Dominic Evans
|
9f8650a8fa
fix brokerProducer goroutine leak (#1442)
|
5 år sedan |
Kieran Gorman
|
1889f366b9
async_producer: clarify ProducerMessage `Timestamp` doc
|
5 år sedan |
Nelz
|
6c354b8b3c
reduce client close bookkeeping
|
5 år sedan |
Varun
|
6a7bac87a0
Merge pull request #1160 from thomaslee/tom_backoff_func
|
5 år sedan |
Vlad Gorodetsky
|
45ea73e0fb
Merge pull request #1189 from segmentio/maintain-producer-metadata-when-retries-disabled
|
5 år sedan |
Vlad Gorodetsky
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
5 år sedan |
Vlad Gorodetsky
|
04e4286cc1
Merge pull request #1218 from nrvnrvn/match-error-codes-and-descriptions
|
5 år sedan |
Nick Revin
|
a0f0d8fcdf
synced error codes and descriptions with the kafka's protocol
|
6 år sedan |
Edoardo Comar
|
587c5f694a
Revert to individual msg retries for non-idempotent
|
6 år sedan |
Steve van Loben Sels
|
d86d8e1f78
Abandon broker connection for any error when retries are disabled
|
6 år sedan |
Steve van Loben Sels
|
459e548c02
simplified code for abandoned connection check, attempt to fix racy sync producer test
|
6 år sedan |
Steve van Loben Sels
|
9f69c41903
Maintain metadata in the producer even when retries are disabled.
|
6 år sedan |
Edoardo Comar
|
eb38bbc24f
single metadata refresh for all retries
|
6 år sedan |
Edoardo Comar
|
4e5d477980
Idempotent Producer - batch retry logic
|
6 år sedan |
Mickael Maison
|
8e2b04b363
Added support for Idempotent Producer
|
6 år sedan |
Tom Lee
|
7d903c1bb8
Add Config.Producer.Retry.BackoffFunc
|
6 år sedan |
Evan Huus
|
6d9cc201b5
Add version check for headers
|
6 år sedan |
Evan Huus
|
bc4e2742d5
Merge pull request #1112 from evan-stripe/extended-partitioner
|
6 år sedan |
Evan Broder
|
9b2c4d6e2c
Make Partitioner.RequiresConsistency vary per-message
|
6 år sedan |
tianji
|
1e2740380a
Do not modify ProducerMessage.MetaData during the whole publishing process.
|
6 år sedan |
Vlad Hanciuta
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
7 år sedan |
Dieter Plaetinck
|
5046283ff1
fix mention of Return.Successes
|
7 år sedan |
Evan Huus
|
8268907a6b
Tweak documentation of Close/AsyncClose methods
|
7 år sedan |
DiSiqueira
|
cecb3d9807
Formating all files with gofmt -s
|
7 år sedan |
Evan Huus
|
17b655d247
Producer: block in `Close` without `Return.Errors`
|
8 år sedan |
yingnanliu
|
16a22e0995
Don't propagate zero timestamp to ProducerMessage
|
8 år sedan |
Evan Huus
|
5246fed60b
Fix parsing of producer timestamp
|
8 år sedan |
Evan Huus
|
90b61cbf50
Support and provide producer message timestamps
|
8 år sedan |
Evan Huus
|
2b18ad7079
Merge pull request #589 from Shopify/retriable-errors
|
9 år sedan |