spec/rdkafka/admin_spec.rb in karafka-rdkafka-0.15.0 vs spec/rdkafka/admin_spec.rb in karafka-rdkafka-0.15.2
- old
+ new
@@ -29,9 +29,17 @@
let(:principal) {"User:anonymous"}
let(:host) {"*"}
let(:operation) {Rdkafka::Bindings::RD_KAFKA_ACL_OPERATION_READ}
let(:permission_type) {Rdkafka::Bindings::RD_KAFKA_ACL_PERMISSION_TYPE_ALLOW}
+ describe '#describe_errors' do
+ let(:errors) { admin.class.describe_errors }
+
+ it { expect(errors.size).to eq(162) }
+ it { expect(errors[-184]).to eq(code: -184, description: 'Local: Queue full', name: '_QUEUE_FULL') }
+ it { expect(errors[21]).to eq(code: 21, description: 'Broker: Invalid required acks value', name: 'INVALID_REQUIRED_ACKS') }
+ end
+
describe 'admin without auto-start' do
let(:admin) { config.admin(native_kafka_auto_start: false) }
it 'expect to be able to start it later and close' do
admin.start