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
from confluent_kafka import Consumer | |
import unittest | |
class MinimalTest(unittest.TestCase): | |
def test(self): | |
conf = { | |
'bootstrap.servers': 'localhost:9092', | |
'group.id': 'test.py', |
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
Jul 12 02:02:41 bigdata-dmp-testing python[16583]: Exception in thread Thread-1: | |
Jul 12 02:02:41 bigdata-dmp-testing python[16583]: Traceback (most recent call last): | |
Jul 12 02:02:41 bigdata-dmp-testing python[16583]: File "/usr/lib/python3.5/threading.py", line 914, in _bootstrap_inner | |
Jul 12 02:02:41 bigdata-dmp-testing python[16583]: self.run() | |
Jul 12 02:02:41 bigdata-dmp-testing python[16583]: File "/usr/lib/python3.5/threading.py", line 862, in run | |
Jul 12 02:02:41 bigdata-dmp-testing python[16583]: self._target(*self._args, **self._kwargs) | |
Jul 12 02:02:41 bigdata-dmp-testing python[16583]: File "/usr/lib/python3.5/multiprocessing/pool.py", line 119, in worker | |
Jul 12 02:02:41 bigdata-dmp-testing python[16583]: result = (True, func(*args, **kwds)) | |
Jul 12 02:02:41 bigdata-dmp-testing python[16583]: File "/usr/local/lib/python3.5/dist-packages/bigartm-0.8.3-py3.5.egg/artm/master_component.py", line 865, in transform | |
Jul 12 02:02:41 bigdata-dmp-testing python[16583]: theta_matrix_info |
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
FROM python:3.5-alpine | |
WORKDIR /app | |
EXPOSE 8888 | |
COPY requirements.txt . | |
RUN pip install -r requirements.txt |
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
# coding: utf-8 | |
"""Test message logging end to end.""" | |
from __future__ import ( | |
absolute_import, division, print_function, unicode_literals | |
) | |
from kafka import KafkaConsumer, KafkaProducer |
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
# coding: utf-8 | |
"""Test message logging end to end.""" | |
from __future__ import ( | |
absolute_import, division, print_function, unicode_literals | |
) | |
from kafka import KafkaConsumer, KafkaProducer |
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
... | |
+ 2 hidden modules | |
Child extract-text-webpack-plugin: | |
+ 2 hidden modules | |
Child extract-text-webpack-plugin: | |
+ 3 hidden modules | |
/Users/srk/workspace/go-starter-kit/bin/go-bindata -pkg=server -prefix=src/app/server/data -o=src/app/server/bindata.go src/app/server/data/... | |
fatal: No names found, cannot describe anything. | |
# app | |
link: warning: option -X main.buildstamp 2015-10-17_03:42:42 may not work in future releases; use -X main.buildstamp=2015-10-17_03:42:42 |
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
function git() { | |
GIT_CMD=`which git` | |
$GIT_CMD "$@" | |
status="$?" | |
[[ $status = 0 ]] || return $status | |
for opt in "$@"; do | |
case "$opt" in | |
commit | rebase) | |
$GIT_CMD ctags |