consumer.go
.
<BOOTSTRAP SERVERS>
endpoint and <API KEY>
in the bootstrap.servers
and sasl.password
properties where the consumer is instantiated via the kafka.NewConsumer
method. Compile the consumer as follows:
consumer.go
.
<BOOTSTRAP SERVERS>
endpoint and <API KEY>
in the bootstrap.servers
and sasl.password
properties where the consumer is instantiated via the kafka.NewConsumer
method. Compile the consumer as follows: