Created
July 14, 2020 18:10
-
-
Save maelfosso/3be57de6bede85f67b36b0143fd6ae58 to your computer and use it in GitHub Desktop.
Log when running `bundle exec karafka exec`
This file contains hidden or 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
| Initializing Karafka server 3610 | |
| Karafka version: 1.3.6 | |
| Ruby version: 2.6.5 | |
| Ruby-kafka version: 1.1.0 | |
| Application client id: nkapsi_accounts_development | |
| Backend: inline | |
| Batch fetching: true | |
| Batch consuming: false | |
| Boot file: /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/karafka.rb | |
| Environment: development | |
| Kafka seed brokers: ["kafka://192.168.8.101:9092"] | |
| Running Karafka server 3610 | |
| New topics added to target list: business | |
| Fetching cluster metadata from kafka://192.168.8.101:9092 | |
| [topic_metadata] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [topic_metadata] Sending topic_metadata API request 1 to 192.168.8.101:9092 | |
| [topic_metadata] Waiting for response 1 from 192.168.8.101:9092 | |
| [topic_metadata] Received response 1 from 192.168.8.101:9092 | |
| Discovered cluster metadata; nodes: 192.168.8.101:9092 (node_id=0) | |
| Closing socket to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {}:] Handling fetcher command: subscribe | |
| [[nkapsi_accounts_development_business] {}:] Getting group coordinator for `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {}:] Will fetch at most 1048576 bytes at a time per partition from business | |
| [[nkapsi_accounts_development_business] {}:] Fetching cluster metadata from kafka://192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {}:] Fetching cluster metadata from kafka://192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [topic_metadata] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {}:] [topic_metadata] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {}:] [topic_metadata] Sending topic_metadata API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [topic_metadata] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [topic_metadata] Sending topic_metadata API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [topic_metadata] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [topic_metadata] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] Discovered cluster metadata; nodes: 192.168.8.101:9092 (node_id=0) | |
| [[nkapsi_accounts_development_business] {}:] [topic_metadata] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] Closing socket to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] Discovered cluster metadata; nodes: 192.168.8.101:9092 (node_id=0) | |
| [[nkapsi_accounts_development_business] {}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {}:] Closing socket to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [find_coordinator] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {}:] [find_coordinator] Sending find_coordinator API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [find_coordinator] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [find_coordinator] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] Coordinator for `nkapsi_accounts_development_business` is 0. Connecting... | |
| [[nkapsi_accounts_development_business] {}:] Connected to coordinator: 192.168.8.101:9092 (node_id=0) for `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-1f9595fa-efd1-4aaf-8aad-5b389a62da63` | |
| [[nkapsi_accounts_development_business] {}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {}:] [offset_fetch] Sending offset_fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [offset_fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [offset_fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [list_offset] Sending list_offset API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [list_offset] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [list_offset] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] New topics added to target list: business | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching cluster metadata from kafka://192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [topic_metadata] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [topic_metadata] Sending topic_metadata API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [topic_metadata] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [topic_metadata] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Discovered cluster metadata; nodes: 192.168.8.101:9092 (node_id=0) | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 2 from 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {}:] Exception raised when processing business/0 in offset range 0..0 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {}:] [leave_group] Sending leave_group API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [leave_group] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] [leave_group] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-81a33adb-ff6d-4066-8a7f-b54fd83aeee7` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Automatically resuming partition business/0, pause timeout expired | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Sending list_offset API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Exception raised when processing business/0 in offset range 0..0 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-def6c2c5-73c2-4f4f-a273-24a5ca058c32` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Automatically resuming partition business/0, pause timeout expired | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Sending list_offset API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 6 from 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Exception raised when processing business/0 in offset range 0..0 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-809376c6-1144-49cb-bac7-ab6a024b2fe6` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Automatically resuming partition business/0, pause timeout expired | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Sending list_offset API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 8 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 8 from 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Exception raised when processing business/0 in offset range 0..0 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 8 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-7b85c05b-1195-4046-8f9e-71cfe747bac0` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Automatically resuming partition business/0, pause timeout expired | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Sending list_offset API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 9 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 9 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 9 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 10 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 10 from 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Exception raised when processing business/0 in offset range 0..0 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 10 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-612d51ed-c8f6-42b5-a8e8-4f982361a58a` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Automatically resuming partition business/0, pause timeout expired | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Sending list_offset API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 11 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 11 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 11 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 12 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 12 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 7 from 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Exception raised when processing business/0 in offset range 0..0 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 12 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 8 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 8 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 8 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-fab582ca-c837-42d2-a1c5-1d60ea52c64b` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Automatically resuming partition business/0, pause timeout expired | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Sending list_offset API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 13 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 13 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 13 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 14 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 14 from 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Exception raised when processing business/0 in offset range 0..0 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 14 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-7c00f817-74af-49d2-8936-cacf16693831` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Automatically resuming partition business/0, pause timeout expired | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Sending list_offset API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 15 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 15 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 15 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 16 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 16 from 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Exception raised when processing business/0 in offset range 0..0 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 16 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-83e4717b-f815-4bda-9527-9703df7b299a` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Automatically resuming partition business/0, pause timeout expired | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Sending list_offset API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 17 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 17 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 17 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 18 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 18 from 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Exception raised when processing business/0 in offset range 0..0 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 18 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-0d6fd7a0-276a-4d10-9ff4-f3e16b6bd7ed` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Automatically resuming partition business/0, pause timeout expired | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Sending list_offset API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 19 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 19 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 19 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 20 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 20 from 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Exception raised when processing business/0 in offset range 0..0 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 20 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-5199abef-f6f1-4424-a6d1-85c153cd316c` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Automatically resuming partition business/0, pause timeout expired | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Sending list_offset API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [list_offset] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: seek | |
| [[nkapsi_accounts_development_business] {business: 0}:] Seeking business/0 to offset 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 21 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 21 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 21 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Sending fetch API request 22 to 192.168.8.101:9092 | |
| New [Business] event: | |
| Params deserialization error for business topic: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Waiting for response 22 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Exception raised when processing business/0 in offset range 0..1 -- Karafka::Errors::DeserializationError: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:22:in `rescue in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/serialization/json/deserializer.rb:19:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:60:in `block in deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:59:in `deserialize' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params.rb:51:in `deserialize!' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/params/params_batch.rb:42:in `first' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/consumers/single_params.rb:11:in `params' | |
| /home/maelfosso/Documents/Projects/Nkapsi/api/accounts/app/consumers/business_consumer.rb:5:in `consume' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `block in process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/backends/inline.rb:12:in `process' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/base_consumer.rb:38:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:43:in `block (2 levels) in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:38:in `block in call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `block in instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:11:in `measure' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/dry-monitor-0.3.2/lib/dry/monitor/notifications.rb:43:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/batch_delegator.rb:18:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:46:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `block in fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:331:in `block (3 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:329:in `block (2 levels) in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `each' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:310:in `block in each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:28:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:414:in `block in consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/activesupport-6.0.3.2/lib/active_support/notifications.rb:182:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:21:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/instrumenter.rb:35:in `instrument' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:412:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/patches/ruby_kafka.rb:16:in `consumer_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/ruby-kafka-1.1.0/lib/kafka/consumer.rb:307:in `each_batch' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/client.rb:36:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:39:in `fetch_loop' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/connection/listener.rb:24:in `call' | |
| /home/maelfosso/.rvm/gems/ruby-2.6.5/gems/karafka-1.3.6/lib/karafka/fetcher.rb:18:in `block (2 levels) in call' | |
| [[nkapsi_accounts_development_business] {business: 0}:] [fetch] Received response 22 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 7 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 7 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 | |
| Client fetch loop error: 767: unexpected token at '{ | |
| activities: [], | |
| _id: 5f0dd8df919fec6c2294fd28, | |
| delivrables: [], | |
| __v: 0 | |
| }' | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: configure | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Opening connection to 192.168.8.101:9092 with client id nkapsi_accounts_development... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 1 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 1 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Failed to join group; resetting member id and retrying in 1s... | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joining group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Sending join_group API request 2 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Waiting for response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [join_group] Received response 2 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Joined group `nkapsi_accounts_development_business` with member id `nkapsi_accounts_development-b654b79d-fb81-4be3-8e9b-251cf050deb7` | |
| [[nkapsi_accounts_development_business] {business: 0}:] Chosen as leader of group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Sending sync_group API request 3 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Waiting for response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [sync_group] Received response 3 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Partitions assigned for `business`: 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Not fetching from business/0 due to pause | |
| [[nkapsi_accounts_development_business] {business: 0}:] Sending heartbeat... | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Sending heartbeat API request 4 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Waiting for response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [heartbeat] Received response 4 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Sending offset_fetch API request 5 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Waiting for response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [offset_fetch] Received response 5 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: reset | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] No batches to process | |
| Received SIGINT system signal | |
| Stopping Karafka server 3610 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Fetching batches | |
| [[nkapsi_accounts_development_business] {business: 0}:] There are no partitions to fetch from, sleeping for 1s | |
| [[nkapsi_accounts_development_business] {business: 0}:] Handling fetcher command: stop | |
| [nkapsi_accounts_development_business] {business: 0}: Fetcher thread exited. | |
| [[nkapsi_accounts_development_business] {business: 0}:] Leaving group `nkapsi_accounts_development_business` | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Sending leave_group API request 6 to 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Waiting for response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] [leave_group] Received response 6 from 192.168.8.101:9092 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Disconnecting broker 0 | |
| [[nkapsi_accounts_development_business] {business: 0}:] Closing socket to 192.168.8.101:9092 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment