Skip to content
This repository was archived by the owner on Dec 7, 2020. It is now read-only.

Commit 1cbb6b4

Browse files
committed
allow sending of compressed.topics as an array. form into comma separated list.
1 parent 490a961 commit 1cbb6b4

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

lib/jruby-kafka/producer.rb

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,9 @@ def initialize(opts = {})
5454
if options['metadata.broker.list'].is_a? Array
5555
options['metadata.broker.list'] = options['metadata.broker.list'].join(',')
5656
end
57+
if options['compressed.topics'].is_a? Array
58+
options['compressed.topics'] = options['compressed.topics'].join(',')
59+
end
5760
validate_arguments
5861
@send_method = proc { throw StandardError.new "Producer is not connected" }
5962
end

0 commit comments

Comments
 (0)