sorenz / alamut.kafka Goto Github PK

var config = new ConsumerConfig
            {
                ClientId =_kafkaConfig.ClientId,
                EnableAutoCommit = _kafkaConfig.EnableAutoCommit,
                SaslUsername = _kafkaConfig.SaslUsername ,
                EnablePartitionEof = _kafkaConfig.EnablePartitionEof,
                StatisticsIntervalMs = _kafkaConfig.StatisticsIntervalMs,
                GroupId = _kafkaConfig.GroupId,
                SaslMechanism = _kafkaConfig.SaslMechanism,
                BootstrapServers = _kafkaConfig.BootstrapServers,
                AutoOffsetReset = _kafkaConfig.AutoOffsetReset,
                SaslPassword = _kafkaConfig.SaslPassword,
                SecurityProtocol = _kafkaConfig.SecurityProtocol
            };