Created
November 15, 2017 16:15
-
-
Save klippx/0ca38936059118ecbd8d701b9d7ddb3d to your computer and use it in GitHub Desktop.
Running spec/lib/phobos/listener_spec.rb:54 with ruby kafka 0.5.1
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ## With Ruby kafka 0.5.1 | |
| # | |
| ~ src phobos debug-0.5.x-issues docker-compose run -e DEFAULT_TIMEOUT=30 --rm test rspec spec/lib/phobos/listener_spec.rb:54 | |
| Starting phobos_zookeeper_1 ... done | |
| Starting phobos_kafka_1 ... done | |
| Run options: include {:locations=>{"./spec/lib/phobos/listener_spec.rb"=>[54]}} | |
| Randomized with seed 7064 | |
| Phobos::Listener | |
| consuming in batches | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"Phobos configured", :env=>"development"} | |
| [<timestamp>] INFO -- RubyKafka : New topics added to target list: test-topic-1 | |
| [<timestamp>] INFO -- RubyKafka : Fetching cluster metadata from kafka://localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to localhost:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending topic_metadata API request 1 to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from localhost:9092 | |
| [<timestamp>] INFO -- RubyKafka : Discovered cluster metadata; nodes: 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to localhost:9092 | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"Listener started", :listener_id=>"listener-id-1", :group_id=>"testgroup_id-group-1", :topic=>"test-topic-1"} | |
| [<timestamp>] INFO -- RubyKafka : Joining group `testgroup_id-group-1` | |
| [<timestamp>] DEBUG -- RubyKafka : Getting group coordinator for `testgroup_id-group-1` | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to 10.3.220.156:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending group_coordinator API request 1 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Coordinator for group `testgroup_id-group-1` is 0. Connecting... | |
| [<timestamp>] DEBUG -- RubyKafka : Connected to coordinator: 10.3.220.156:9092 (node_id=0) for group `testgroup_id-group-1` | |
| [<timestamp>] INFO -- RubyKafka : Starting async producer in the background... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending join_group API request 2 to 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : New topics added to target list: test-topic-1 | |
| [<timestamp>] INFO -- RubyKafka : Fetching cluster metadata from kafka://localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to localhost:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 2 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending topic_metadata API request 1 to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 2 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Joined group `testgroup_id-group-1` with member id `phobos-a447c84b-2126-4bad-956c-c0c76fed3144` | |
| [<timestamp>] INFO -- RubyKafka : Chosen as leader of group `testgroup_id-group-1` | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from localhost:9092 | |
| [<timestamp>] INFO -- RubyKafka : Discovered cluster metadata; nodes: 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to localhost:9092 | |
| [<timestamp>] ERROR -- RubyKafka : Failed to assign partitions to 1 messages in test-topic-1 | |
| [<timestamp>] WARN -- RubyKafka : Failed to send all messages; attempting retry 1 of 2 after 1s | |
| [<timestamp>] INFO -- RubyKafka : Fetching cluster metadata from kafka://localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to localhost:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending topic_metadata API request 1 to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from localhost:9092 | |
| [<timestamp>] INFO -- RubyKafka : Discovered cluster metadata; nodes: 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending sync_group API request 3 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 3 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 3 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Partitions assigned for `test-topic-1`: 0 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending offset_fetch API request 4 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 4 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 4 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending list_offset API request 5 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 5 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 5 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Fetching batch from test-topic-1/0 starting at offset 0 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending fetch API request 6 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 6 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Fetching cluster metadata from kafka://localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to localhost:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending topic_metadata API request 1 to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from localhost:9092 | |
| [<timestamp>] INFO -- RubyKafka : Discovered cluster metadata; nodes: 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Current leader for test-topic-1/0 is node 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] INFO -- RubyKafka : Sending 1 messages to 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to 10.3.220.156:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending produce API request 1 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Successfully appended 1 messages to test-topic-1/0 on 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 6 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"message-1", :listener_id=>"listener-id-1", :group_id=>"testgroup_id-group-1", :topic=>"test-topic-1", :key=>nil, :partition=>0, :offset=>0, :retry_count=>0} | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"Committed offset", :listener_id=>"listener-id-1", :group_id=>"testgroup_id-group-1", :topic=>"test-topic-1", :batch_size=>1, :partition=>0, :offset_lag=>0, :time_elapsed=>0.001} | |
| [<timestamp>] DEBUG -- RubyKafka : Marking test-topic-1/0:0 as processed | |
| [<timestamp>] INFO -- RubyKafka : Committing offsets with recommit: test-topic-1/0:1 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending offset_commit API request 7 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 7 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"Listener stopping", :listener_id=>"listener-id-1", :group_id=>"testgroup_id-group-1", :topic=>"test-topic-1"} | |
| [<timestamp>] INFO -- RubyKafka : Disconnecting broker 0 | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Committing offsets: test-topic-1/0:1 | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to 10.3.220.156:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending offset_commit API request 1 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Leaving group `testgroup_id-group-1` | |
| [<timestamp>] DEBUG -- RubyKafka : Sending leave_group API request 2 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 2 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 2 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Disconnecting broker 0 | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to 10.3.220.156:9092 | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"Listener stopped", :listener_id=>"listener-id-1", :group_id=>"testgroup_id-group-1", :topic=>"test-topic-1"} | |
| calls Phobos::Actions::ProcessBatch with the fetched Kafka batch (FAILED - 1) | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"Phobos configured", :env=>"development"} | |
| [<timestamp>] INFO -- RubyKafka : New topics added to target list: test-topic-2 | |
| [<timestamp>] INFO -- RubyKafka : Fetching cluster metadata from kafka://localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to localhost:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending topic_metadata API request 1 to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from localhost:9092 | |
| [<timestamp>] INFO -- RubyKafka : Discovered cluster metadata; nodes: 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to localhost:9092 | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"Listener started", :listener_id=>"listener-id-2", :group_id=>"testgroup_id-group-2", :topic=>"test-topic-2"} | |
| [<timestamp>] INFO -- RubyKafka : Joining group `testgroup_id-group-2` | |
| [<timestamp>] DEBUG -- RubyKafka : Getting group coordinator for `testgroup_id-group-2` | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to 10.3.220.156:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending group_coordinator API request 1 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Coordinator for group `testgroup_id-group-2` is 0. Connecting... | |
| [<timestamp>] DEBUG -- RubyKafka : Connected to coordinator: 10.3.220.156:9092 (node_id=0) for group `testgroup_id-group-2` | |
| [<timestamp>] DEBUG -- RubyKafka : Sending join_group API request 2 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 2 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : New topics added to target list: test-topic-2 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 2 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Fetching cluster metadata from kafka://localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to localhost:9092 with client id phobos... | |
| [<timestamp>] INFO -- RubyKafka : Joined group `testgroup_id-group-2` with member id `phobos-f3b01de8-ee2e-4439-95c9-a29ffdfd8b92` | |
| [<timestamp>] INFO -- RubyKafka : Chosen as leader of group `testgroup_id-group-2` | |
| [<timestamp>] DEBUG -- RubyKafka : Sending topic_metadata API request 1 to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from localhost:9092 | |
| [<timestamp>] INFO -- RubyKafka : Discovered cluster metadata; nodes: 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to localhost:9092 | |
| [<timestamp>] ERROR -- RubyKafka : Failed to assign partitions to 1 messages in test-topic-2 | |
| [<timestamp>] WARN -- RubyKafka : Failed to send all messages; attempting retry 1 of 2 after 1s | |
| [<timestamp>] INFO -- RubyKafka : Fetching cluster metadata from kafka://localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to localhost:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending topic_metadata API request 1 to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from localhost:9092 | |
| [<timestamp>] INFO -- RubyKafka : Discovered cluster metadata; nodes: 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending sync_group API request 3 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 3 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 3 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Partitions assigned for `test-topic-2`: 0 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending offset_fetch API request 4 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 4 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 4 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending list_offset API request 5 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 5 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 5 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Fetching batch from test-topic-2/0 starting at offset 0 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending fetch API request 6 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 6 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Fetching cluster metadata from kafka://localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to localhost:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending topic_metadata API request 1 to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from localhost:9092 | |
| [<timestamp>] INFO -- RubyKafka : Discovered cluster metadata; nodes: 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to localhost:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Current leader for test-topic-2/0 is node 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] INFO -- RubyKafka : Sending 1 messages to 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to 10.3.220.156:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending produce API request 1 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 6 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"Committed offset", :listener_id=>"listener-id-2", :group_id=>"testgroup_id-group-2", :topic=>"test-topic-2", :batch_size=>1, :partition=>0, :offset_lag=>0, :time_elapsed=>0.1} | |
| [<timestamp>] DEBUG -- RubyKafka : Marking test-topic-2/0:0 as processed | |
| [<timestamp>] INFO -- RubyKafka : Committing offsets with recommit: test-topic-2/0:1 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending offset_commit API request 7 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Successfully appended 1 messages to test-topic-2/0 on 10.3.220.156:9092 (node_id=0) | |
| [<timestamp>] INFO -- RubyKafka : Disconnecting broker 0 | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 7 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 7 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Fetching batch from test-topic-2/0 starting at offset 1 | |
| [<timestamp>] DEBUG -- RubyKafka : Sending fetch API request 8 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 8 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"Listener stopping", :listener_id=>"listener-id-2", :group_id=>"testgroup_id-group-2", :topic=>"test-topic-2"} | |
| [<timestamp>] INFO -- RubyKafka : Disconnecting broker 0 | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to 10.3.220.156:9092 | |
| [<timestamp>] ERROR -- RubyKafka : Timed out while waiting for response 8 | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to 10.3.220.156:9092 | |
| [<timestamp>] ERROR -- RubyKafka : Connection error while fetching messages: Connection error Errno::ETIMEDOUT: Operation timed out | |
| [<timestamp>] INFO -- RubyKafka : Committing offsets: test-topic-2/0:1 | |
| [<timestamp>] DEBUG -- RubyKafka : Opening connection to 10.3.220.156:9092 with client id phobos... | |
| [<timestamp>] DEBUG -- RubyKafka : Sending offset_commit API request 1 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 1 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 1 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Leaving group `testgroup_id-group-2` | |
| [<timestamp>] DEBUG -- RubyKafka : Sending leave_group API request 2 to 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Waiting for response 2 from 10.3.220.156:9092 | |
| [<timestamp>] DEBUG -- RubyKafka : Received response 2 from 10.3.220.156:9092 | |
| [<timestamp>] INFO -- RubyKafka : Disconnecting broker 0 | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to 10.3.220.156:9092 | |
| [<timestamp>] INFO -- Phobos : <Hash> {:message=>"Listener stopped", :listener_id=>"listener-id-2", :group_id=>"testgroup_id-group-2", :topic=>"test-topic-2"} | |
| calls handler with message payload, group_id and topic | |
| Failures: | |
| 1) Phobos::Listener consuming in batches calls Phobos::Actions::ProcessBatch with the fetched Kafka batch | |
| Failure/Error: | |
| @consumer.each_batch(@consumer_opts) do |batch| | |
| batch_processor = Phobos::Actions::ProcessBatch.new( | |
| listener: self, | |
| batch: batch, | |
| listener_metadata: listener_metadata | |
| ) | |
| batch_processor.execute | |
| Phobos.logger.info { Hash(message: 'Committed offset').merge(batch_processor.metadata) } | |
| return if should_stop? | |
| IOError: | |
| closed stream | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/socket_with_timeout.rb:60:in `select' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/socket_with_timeout.rb:60:in `read' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/protocol/decoder.rb:104:in `read' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/protocol/decoder.rb:93:in `bytes' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/connection.rb:180:in `read_response' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/connection.rb:199:in `block in wait_for_response' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/connection.rb:198:in `loop' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/connection.rb:198:in `wait_for_response' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/connection.rb:104:in `block in send_request' | |
| # /usr/local/bundle/gems/activesupport-5.1.4/lib/active_support/notifications.rb:168:in `instrument' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/instrumenter.rb:19:in `instrument' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/connection.rb:94:in `send_request' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/broker.rb:127:in `send_request' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/broker.rb:79:in `commit_offsets' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/consumer_group.rb:73:in `commit_offsets' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/offset_manager.rb:120:in `commit_offsets' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/offset_manager.rb:137:in `commit_offsets_if_necessary' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/consumer.rb:307:in `block (2 levels) in each_batch' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/consumer.rb:279:in `each' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/consumer.rb:279:in `block in each_batch' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/consumer.rb:356:in `consumer_loop' | |
| # /usr/local/bundle/gems/ruby-kafka-0.5.1/lib/kafka/consumer.rb:271:in `each_batch' | |
| # ./lib/phobos/listener.rb:80:in `consume_each_batch' | |
| # ./lib/phobos/listener.rb:48:in `start' | |
| # ./spec/lib/phobos/listener_spec.rb:41:in `block (3 levels) in <top (required)>' | |
| # /usr/local/bundle/gems/logging-2.2.2/lib/logging/diagnostic_context.rb:474:in `block in create_with_logging_context' | |
| Finished in 12.34 seconds (files took 0.75848 seconds to load) | |
| 2 examples, 1 failure | |
| Failed examples: | |
| rspec ./spec/lib/phobos/listener_spec.rb:87 # Phobos::Listener consuming in batches calls Phobos::Actions::ProcessBatch with the fetched Kafka batch | |
| Randomized with seed 7064 | |
| Coverage report generated for RSpec to /opt/phobos/coverage. 301 / 365 LOC (82.47%) covered. | |
| [<timestamp>] INFO -- RubyKafka : Disconnecting broker 0 | |
| [<timestamp>] DEBUG -- RubyKafka : Closing socket to 10.3.220.156:9092 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment