gistfile1.txt

^C2018-12-26 12:39:48,288 - root - ERROR - 
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/asyncio/runners.py", line 43, in run
    return loop.run_until_complete(main)
  File "/usr/local/lib/python3.7/asyncio/base_events.py", line 560, in run_until_complete
    self.run_forever()
  File "/usr/local/lib/python3.7/asyncio/base_events.py", line 528, in run_forever
    self._run_once()
  File "/usr/local/lib/python3.7/asyncio/base_events.py", line 1728, in _run_once
    event_list = self._selector.select(timeout)
  File "/usr/local/lib/python3.7/selectors.py", line 468, in select
    fd_event_list = self._selector.poll(timeout, max_ev)
KeyboardInterrupt

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/aiokafka/consumer/consumer.py", line 967, in _wait_for_data_or_error
    loop=self._loop)
  File "/usr/local/lib/python3.7/asyncio/tasks.py", line 363, in wait
    return await _wait(fs, timeout, return_when, loop)
  File "/usr/local/lib/python3.7/asyncio/tasks.py", line 456, in _wait
    await waiter
concurrent.futures._base.CancelledError

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/usr/src/app/aio_garb/kafka/__init__.py", line 55, in consume
    async for msg in consumer:
  File "/usr/local/lib/python3.7/site-packages/aiokafka/consumer/consumer.py", line 1097, in __anext__
    return (yield from self.getone())
  File "/usr/local/lib/python3.7/site-packages/aiokafka/consumer/consumer.py", line 1023, in getone
    self._fetcher.next_record(partitions))
  File "/usr/local/lib/python3.7/site-packages/aiokafka/consumer/consumer.py", line 970, in _wait_for_data_or_error
    return (yield from data_task)
concurrent.futures._base.CancelledError
2018-12-26 12:39:48,307 - aiokafka.consumer.consumer - DEBUG - Closing the KafkaConsumer.
2018-12-26 12:39:48,308 - aiokafka.consumer.group_coordinator - ERROR - Unexpected error in coordinator routine
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/asyncio/runners.py", line 43, in run
    return loop.run_until_complete(main)
  File "/usr/local/lib/python3.7/asyncio/base_events.py", line 560, in run_until_complete
    self.run_forever()
  File "/usr/local/lib/python3.7/asyncio/base_events.py", line 528, in run_forever
    self._run_once()
  File "/usr/local/lib/python3.7/asyncio/base_events.py", line 1728, in _run_once
    event_list = self._selector.select(timeout)
  File "/usr/local/lib/python3.7/selectors.py", line 468, in select
    fd_event_list = self._selector.poll(timeout, max_ev)
KeyboardInterrupt

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/aiokafka/consumer/group_coordinator.py", line 232, in _on_coordination_done
    fut.result()
concurrent.futures._base.CancelledError
2018-12-26 12:39:48,312 - root - ERROR - stop
2018-12-26 12:39:48,314 - root - ERROR - stop2
Traceback (most recent call last):
  File "run_kafka.py", line 29, in <module>
    asyncio.run(start_kafka())
  File "/usr/local/lib/python3.7/asyncio/runners.py", line 43, in run
    return loop.run_until_complete(main)
  File "/usr/local/lib/python3.7/asyncio/base_events.py", line 560, in run_until_complete
    self.run_forever()
  File "/usr/local/lib/python3.7/asyncio/base_events.py", line 528, in run_forever
    self._run_once()
  File "/usr/local/lib/python3.7/asyncio/base_events.py", line 1728, in _run_once
    event_list = self._selector.select(timeout)
  File "/usr/local/lib/python3.7/selectors.py", line 468, in select
    fd_event_list = self._selector.poll(timeout, max_ev)
KeyboardInterrupt