github/goreplay
4
0
Fork 0
mirror of https://github.com/buger/goreplay.git synced 2024-04-21 12:32:02 +00:00
Code Issues Releases Wiki Activity

Support SASL Protocol of Kafka (#1092)

Browse Source 
* Support SASL Protocol of Kafka

* Add comments

* Fix Unused parameter detected in function RVV-B0012
This commit is contained in:
choi se
2022-07-23 17:00:43 +03:00
committed by GitHub
parent 655eacc546
commit 951cd72a92
4 changed files with 81 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
input_kafka.go
+2 -2
View File
@@ -19,8 +19,8 @@ type KafkaInput struct {
}
// NewKafkaInput creates instance of kafka consumer client with TLS config
func NewKafkaInput(address string, config *InputKafkaConfig, tlsConfig *KafkaTLSConfig) *KafkaInput {
c := NewKafkaConfig(tlsConfig)
func NewKafkaInput(_ string, config *InputKafkaConfig, tlsConfig *KafkaTLSConfig) *KafkaInput {
c := NewKafkaConfig(&config.SASLConfig, tlsConfig)
var con sarama.Consumer