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