Skip to content

Commit 3d60e0b

Browse files
Merge pull request #3 from DIMO-Network/intg-1783_kafka_consumer
Removed sasl auth
2 parents 4c9ca1c + 3d5e343 commit 3d60e0b

File tree

6 files changed

+310
-54
lines changed

6 files changed

+310
-54
lines changed

.github/workflows/rules.yml

Lines changed: 0 additions & 32 deletions
This file was deleted.

cmd/oracle-example/main.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,6 @@ func main() {
115115
settings.UnbufferedTelemetryTopic,
116116
settings.UnbufferedTelemetryConsumerGroup,
117117
kafka.MessageHandlerUnbuffered{Logger: &logger, OracleService: oracleService},
118-
settings.UnbufferedTelemetryPassword,
119118
)
120119
if err != nil {
121120
logger.Fatal().Err(err).Msg("Failed to setup consumer for UnbufferedTelemetryTopic")
@@ -131,7 +130,6 @@ func main() {
131130
settings.OperationsTopic,
132131
settings.OperationsConsumerGroup,
133132
kafka.MessageHandlerOperations{Logger: &logger, OracleService: oracleService, EnrollmentChannel: enrollmentChannel},
134-
settings.OperationsPassword,
135133
)
136134
if err != nil {
137135
logger.Fatal().Err(err).Msg("Failed to setup consumer for OperationsTopic")

0 commit comments

Comments
 (0)