Skip to content

Commit

Permalink
Merge pull request #235 from seungsoo-lee/dev
Browse files Browse the repository at this point in the history
Updated kafka
  • Loading branch information
seungsoo-lee committed Jul 24, 2021
2 parents fc2976f + 643413b commit 2c6b425
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/feedconsumer/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ func (cfc *KnoxFeedConsumer) setupKafkaConfig() {
sessionTimeoutMs := viper.GetString("feed-consumer.kafka.session-timeout-ms")
autoOffsetReset := viper.GetString("feed-consumer.kafka.auto-offset-reset")

groupID := viper.GetString("feed-consumer.kafka.group-id")
// groupID := viper.GetString("feed-consumer.kafka.group-id")
cfc.topics = viper.GetStringSlice("feed-consumer.kafka.topics")
cfc.eventsBuffer = viper.GetInt("feed-consumer.kafka.events.buffer")

Expand All @@ -82,9 +82,9 @@ func (cfc *KnoxFeedConsumer) setupKafkaConfig() {
cfc.kafkaConfig = kafka.ConfigMap{
"bootstrap.servers": bootstrapServers,
"broker.address.family": brokderAddressFamily,
"group.id": groupID,
"session.timeout.ms": sessionTimeoutMs,
"auto.offset.reset": autoOffsetReset,
// "group.id": groupID,
"session.timeout.ms": sessionTimeoutMs,
"auto.offset.reset": autoOffsetReset,
}

// Set up SSL specific configs if SSL is enabled
Expand Down

0 comments on commit 2c6b425

Please sign in to comment.