lib/kafka/producer.rb in ruby-kafka-0.5.2 vs lib/kafka/producer.rb in ruby-kafka-0.5.3
- old
+ new
@@ -12,11 +12,11 @@
#
# Typically you won't instantiate this class yourself, but rather have {Kafka::Client}
# do it for you, e.g.
#
# # Will instantiate Kafka::Client
- # kafka = Kafka.new(...)
+ # kafka = Kafka.new(["kafka1:9092", "kafka2:9092"])
#
# # Will instantiate Kafka::Producer
# producer = kafka.producer
#
# This is done in order to share a logger as well as a pool of broker connections across
@@ -104,15 +104,10 @@
#
# # Make sure to create this topic in your Kafka cluster or configure the
# # cluster to auto-create topics.
# topic = "random-messages"
#
- # kafka = Kafka.new(
- # seed_brokers: brokers,
- # client_id: "simple-producer",
- # logger: logger,
- # )
- #
+ # kafka = Kafka.new(brokers, client_id: "simple-producer", logger: logger)
# producer = kafka.producer
#
# begin
# $stdin.each_with_index do |line, index|
# producer.produce(line, topic: topic)