producer.go
.
<BOOTSTRAP SERVERS>
endpoint and <API KEY>
in the bootstrap.servers
and sasl.password
properties where the producer is instantiated using the kafka.NewProducer
method.
Compile the producer with the following:
producer.go
.
<BOOTSTRAP SERVERS>
endpoint and <API KEY>
in the bootstrap.servers
and sasl.password
properties where the producer is instantiated using the kafka.NewProducer
method.
Compile the producer with the following: