 Evan Huus
|
37654da7e1
Add support for decoding versioned responses
|
8 years ago |
 Shriram Rajagopalan
|
d0d6717d96
rename doSASLPlainAuth to sendAndReceiveSASLPlainAuth
|
8 years ago |
|
Shriram Rajagopalan
|
9d69627aa9
bug fixes
|
8 years ago |
|
Shriram Rajagopalan
|
8b754479b5
error checks when doing SASL auth
|
8 years ago |
|
Shriram Rajagopalan
|
6fbcb5f07e
go fmt
|
8 years ago |
|
Shriram Rajagopalan
|
2270962248
remove use of dynamic buffer
|
8 years ago |
|
Shriram Rajagopalan
|
0a075f2fed
go fmt
|
8 years ago |
|
Shriram Rajagopalan
|
5ac5287ba1
refactor SASL PLAIN auth into its own function
|
8 years ago |
|
Shriram Rajagopalan
|
3834ba1ce0
Add support for SASL plain text authentication
|
8 years ago |
|
Evan Huus
|
62e4ae8645
Adjust broker locking order slightly
|
8 years ago |
|
Evan Huus
|
bf94d2ef46
Add two other missing broker calls for kafka 0.9
|
8 years ago |
|
Evan Huus
|
66d77e132f
Merge pull request #588 from dim/kafka-09-consumer-groups
|
8 years ago |
 Dimitrij Denissenko
|
2795466945
More 0.9 protocol additions. Add broker accessors
|
8 years ago |
 Ben Burkert
|
797cb29ada
un-export newBufConn
|
8 years ago |
|
Ben Burkert
|
6d716464e8
Add a buffer around the broker's net.Conn for reads.
|
8 years ago |
|
Evan Huus
|
b51603af22
Make dead brokers die harder
|
9 years ago |
|
Evan Huus
|
306db491eb
Fix two decoding bugs found by go-fuzz
|
9 years ago |
|
Evan Huus
|
b973736745
Merge pull request #493 from uovobw/support-ssl
|
9 years ago |
 Andrea Lusuardi - uovobw
|
589446225f
revert unwanted changed in response to https://github.com/Shopify/sarama/pull/493 comments
|
9 years ago |
|
Evan Huus
|
66411d8222
Cleanup a bunch more error formats
|
9 years ago |
|
Andrea Lusuardi - uovobw
|
1016308070
Merge branch 'master' into support-ssl
|
9 years ago |
 Maxim Vladimirsky
|
aa411f16fd
Add decode method to request types
|
9 years ago |
 Willem van Bergen
|
f33811b058
Refactor metadata retro logic and imrove logging.
|
9 years ago |
 eric
|
3a630028fc
removing the wrapper function for creating tcp connection
|
9 years ago |
|
eric
|
76aa5518b0
adding tcp keepalives to the broker's socket connection
|
9 years ago |
|
Evan Huus
|
32da1c5918
Add configuration to support broker SSL
|
10 years ago |
|
Evan Huus
|
4f7be25dfb
Reduce logging on broker close
|
9 years ago |
|
Evan Huus
|
0abdf8c4f0
Move the clientID into the config object
|
9 years ago |
|
Evan Huus
|
616ac5daa4
Unify configuration structures into config.go
|
9 years ago |
|
Evan Huus
|
9d71abeed0
Make Broker.Open truly non-blocking
|
9 years ago |
