Skip to content

Commit

Permalink
Update examples/rdkafka/README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
bruce-szalwinski-he authored May 5, 2024
1 parent c936f85 commit 9ae23b3
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion examples/rdkafka/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ Then start the client using the `start` method.
def self.start!(kafka_config)
Rdkafka::Config.oauthbearer_token_refresh_callback = method(:refresh_token)
@producer = Rdkafka::Config.new(kafka_config).producer(native_kafka_auto_start: false)
CLIENTS[@producer.name] = @producer
@clients[@producer.name] = @producer
@producer.start
end
```
Expand Down

0 comments on commit 9ae23b3

Please sign in to comment.