We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6d38e32 commit 6359bedCopy full SHA for 6359bed
spec/functional/topic_management_spec.rb
@@ -37,7 +37,10 @@
37
unless kafka.supports_api?(Kafka::Protocol::DESCRIBE_CONFIGS_API)
38
skip("This Kafka version not support ")
39
end
40
+
41
+ topic = generate_topic_name
42
configs = kafka.describe_topic(topic, %w(retention.ms retention.bytes non_exists))
43
44
expect(configs.keys).to eql(%w(retention.ms retention.bytes))
45
expect(configs['retention.ms']).to be_a(String)
46
expect(configs['retention.bytes']).to be_a(String)
0 commit comments