Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Last login: Mon Dec 18 17:51:29 on ttys003
- ➜ nodejs_project git:(master) ✗ sudo atom /etc/hosts
- Password:
- ➜ nodejs_project git:(master) ✗
- ➜ nodejs_project git:(master) ✗
- ➜ nodejs_project git:(master) ✗
- ➜ nodejs_project git:(master) ✗
- ➜ nodejs_project git:(master) ✗
- ➜ nodejs_project git:(master) ✗ cd ..
- ➜ binding_with_kafka git:(master) ✗ cd python_project
- ➜ python_project git:(master) ✗ python3.6 -m venv ./venv
- ➜ python_project git:(master) ✗ source ./venv/bin/activate
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip list
- DEPRECATION: The default format will switch to columns in the future. You can use --format=(legacy|columns) (or define a format=(legacy|columns) in your pip.conf under the [list] section) to disable this warning.
- pip (9.0.1)
- setuptools (28.8.0)
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install confluent-kafka
- Collecting confluent-kafka
- Downloading confluent-kafka-0.11.0.tar.gz (42kB)
- 100% |████████████████████████████████| 51kB 481kB/s
- Installing collected packages: confluent-kafka
- Running setup.py install for confluent-kafka ... done
- Successfully installed confluent-kafka-0.11.0
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ main.py
- zsh: command not found: main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Received message: b'world'
- Received message: b'world'
- End of partition reached mytopic/0
- ^C% (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- End of partition reached mytopic/0
- ^C% (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Received message: b'world'
- End of partition reached mytopic/0
- ^C% (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Received message: b'world'
- Received message: b'world'
- End of partition reached mytopic/0
- ^C% (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- End of partition reached mytopic/0
- Received message: b'my message'
- Received message: b'another message'
- Received message: b'even more'
- Received message: b'messages'
- End of partition reached mytopic/0
- ^C% (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Received message: b'message from python script'
- Received message: b'my message'
- Received message: b'another message'
- Received message: b'even more'
- Received message: b'messages'
- Received message: b'message from python script'
- Received message: b'message from python script'
- End of partition reached mytopic/0
- Received message: b'[object Object]'
- End of partition reached mytopic/0
- Received message: b'key from javascript'
- End of partition reached mytopic/0
- ^C% (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- End of partition reached mytopic/0
- Received message: <cimpl.Message object at 0x1035f41e8>
- End of partition reached mytopic/0
- ^C% (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- End of partition reached mytopic/0
- Received message: None, b'key from javascript'
- End of partition reached mytopic/0
- Received message: None, b'[object Object]'
- End of partition reached mytopic/0
- %3|1513616922.776|FAIL|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Receive failed: Disconnected
- %3|1513616922.776|ERROR|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Receive failed: Disconnected
- %5|1513616922.779|FAIL|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connection closed
- %3|1513616922.779|ERROR|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connection closed
- %3|1513617522.854|FAIL|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Receive failed: Disconnected
- %3|1513617522.854|ERROR|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Receive failed: Disconnected
- %5|1513617522.854|FAIL|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connection closed
- %3|1513617522.854|ERROR|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connection closed
- %3|1513618422.928|FAIL|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Receive failed: Disconnected
- %3|1513618422.928|ERROR|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Receive failed: Disconnected
- %5|1513618422.928|FAIL|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connection closed
- %3|1513618422.928|ERROR|client-1#consumer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connection closed
- ^C% (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ deactivate
- ➜ python_project git:(master) ✗ git init
- Initialized empty Git repository in /Users/vlad/Documents/projects/binding_with_kafka/python_project/.git/
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗ git status
- On branch master
- No commits yet
- Untracked files:
- (use "git add <file>..." to include in what will be committed)
- main.py
- venv/
- nothing added to commit but untracked files present (use "git add" to track)
- ➜ python_project git:(master) ✗ git add main.py
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗ git commit -m 'First changes'
- [master (root-commit) bd0886a] First changes
- 1 file changed, 47 insertions(+)
- create mode 100644 main.py
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗
- ➜ python_project git:(master) ✗ pip list > requirements.txt
- DEPRECATION: The default format will switch to columns in the future. You can use --format=(legacy|columns) (or define a format=(legacy|columns) in your pip.conf under the [list] section) to disable this warning.
- ➜ python_project git:(master) ✗ source ./venv/bin/activate
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip list > requirements.txt
- DEPRECATION: The default format will switch to columns in the future. You can use --format=(legacy|columns) (or define a format=(legacy|columns) in your pip.conf under the [list] section) to disable this warning.
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip help install
- Usage:
- pip install [options] <requirement specifier> [package-index-options] ...
- pip install [options] -r <requirements file> [package-index-options] ...
- pip install [options] [-e] <vcs project url> ...
- pip install [options] [-e] <local project path> ...
- pip install [options] <archive url/path> ...
- Description:
- Install packages from:
- - PyPI (and other indexes) using requirement specifiers.
- - VCS project urls.
- - Local project directories.
- - Local or remote source archives.
- pip also supports installing from "requirements files", which provide
- an easy way to specify a whole environment to be installed.
- Install Options:
- -c, --constraint <file> Constrain versions using the given constraints file. This option can be used multiple times.
- -e, --editable <path/url> Install a project in editable mode (i.e. setuptools "develop mode") from a local project path or a VCS url.
- -r, --requirement <file> Install from the given requirements file. This option can be used multiple times.
- -b, --build <dir> Directory to unpack packages into and build in.
- -t, --target <dir> Install packages into <dir>. By default this will not replace existing files/folders in <dir>. Use --upgrade to replace existing packages in <dir> with new versions.
- -d, --download <dir> Download packages into <dir> instead of installing them, regardless of what's already installed.
- --src <dir> Directory to check out editable projects into. The default in a virtualenv is "<venv path>/src". The default for global installs is "<current dir>/src".
- -U, --upgrade Upgrade all specified packages to the newest available version. The handling of dependencies depends on the upgrade-strategy used.
- --upgrade-strategy <upgrade_strategy>
- Determines how dependency upgrading should be handled. "eager" - dependencies are upgraded regardless of whether the currently installed version satisfies the requirements of the upgraded package(s). "only-if-needed" - are upgraded only when they do not satisfy the requirements of the
- upgraded package(s).
- --force-reinstall When upgrading, reinstall all packages even if they are already up-to-date.
- -I, --ignore-installed Ignore the installed packages (reinstalling instead).
- --ignore-requires-python Ignore the Requires-Python information.
- --no-deps Don't install package dependencies.
- --install-option <options> Extra arguments to be supplied to the setup.py install command (use like --install-option="--install-scripts=/usr/local/bin"). Use multiple --install-option options to pass multiple options to setup.py install. If you are using an option with a directory path, be sure to use absolute
- path.
- --global-option <options> Extra global options to be supplied to the setup.py call before the install command.
- --user Install to the Python user install directory for your platform. Typically ~/.local/, or %APPDATA%\Python on Windows. (See the Python documentation for site.USER_BASE for full details.)
- --egg Install packages as eggs, not 'flat', like pip normally does. This option is not about installing *from* eggs. (WARNING: Because this option overrides pip's normal install logic, requirements files may not behave as expected.)
- --root <dir> Install everything relative to this alternate root directory.
- --prefix <dir> Installation prefix where lib, bin and other top-level folders are placed
- --compile Compile py files to pyc
- --no-compile Do not compile py files to pyc
- --no-use-wheel Do not Find and prefer wheel archives when searching indexes and find-links locations. DEPRECATED in favour of --no-binary.
- --no-binary <format_control>
- Do not use binary packages. Can be supplied multiple times, and each time adds to the existing value. Accepts either :all: to disable all binary packages, :none: to empty the set, or one or more package names with commas between them. Note that some packages are tricky to compile and
- may fail to install when this option is used on them.
- --only-binary <format_control>
- Do not use source packages. Can be supplied multiple times, and each time adds to the existing value. Accepts either :all: to disable all source packages, :none: to empty the set, or one or more package names with commas between them. Packages without binary distributions will fail to
- install when this option is used on them.
- --pre Include pre-release and development versions. By default, pip only finds stable versions.
- --no-clean Don't clean up build directories.
- --require-hashes Require a hash to check each requirement against, for repeatable installs. This option is implied when any package in a requirements file has a --hash option.
- Package Index Options (including deprecated options):
- -i, --index-url <url> Base URL of Python Package Index (default https://pypi.python.org/simple). This should point to a repository compliant with PEP 503 (the simple repository API) or a local directory laid out in the same format.
- --extra-index-url <url> Extra URLs of package indexes to use in addition to --index-url. Should follow the same rules as --index-url.
- --no-index Ignore package index (only looking at --find-links URLs instead).
- -f, --find-links <url> If a url or path to an html file, then parse for links to archives. If a local path or file:// url that's a directory, then look for archives in the directory listing.
- --process-dependency-links Enable the processing of dependency links.
- General Options:
- -h, --help Show help.
- --isolated Run pip in an isolated mode, ignoring environment variables and user configuration.
- -v, --verbose Give more output. Option is additive, and can be used up to 3 times.
- -V, --version Show version and exit.
- -q, --quiet Give less output. Option is additive, and can be used up to 3 times (corresponding to WARNING, ERROR, and CRITICAL logging levels).
- --log <path> Path to a verbose appending log.
- --proxy <proxy> Specify a proxy in the form [user:passwd@]proxy.server:port.
- --retries <retries> Maximum number of retries each connection should attempt (default 5 times).
- --timeout <sec> Set the socket timeout (default 15 seconds).
- --exists-action <action> Default action when a path already exists: (s)witch, (i)gnore, (w)ipe, (b)ackup, (a)bort.
- --trusted-host <hostname> Mark this host as trusted, even though it does not have valid or any HTTPS.
- --cert <path> Path to alternate CA bundle.
- --client-cert <path> Path to SSL client certificate, a single file containing the private key and the certificate in PEM format.
- --cache-dir <dir> Store the cache data in <dir>.
- --no-cache-dir Disable the cache.
- --disable-pip-version-check
- Don't periodically check PyPI to determine whether a new version of pip is available for download. Implied with --no-index.
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip list
- DEPRECATION: The default format will switch to columns in the future. You can use --format=(legacy|columns) (or define a format=(legacy|columns) in your pip.conf under the [list] section) to disable this warning.
- confluent-kafka (0.11.0)
- pip (9.0.1)
- setuptools (28.8.0)
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install winton-kafka-streams
- Collecting winton-kafka-streams
- Could not find a version that satisfies the requirement winton-kafka-streams (from versions: )
- No matching distribution found for winton-kafka-streams
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install winton_kafka_streams
- Collecting winton_kafka_streams
- Could not find a version that satisfies the requirement winton_kafka_streams (from versions: )
- No matching distribution found for winton_kafka_streams
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install winton_kafka_streams
- Collecting winton_kafka_streams
- Could not find a version that satisfies the requirement winton_kafka_streams (from versions: )
- No matching distribution found for winton_kafka_streams
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install ../winton-kafka-streams-master.zip
- Processing /Users/vlad/Documents/projects/binding_with_kafka/winton-kafka-streams-master.zip
- Complete output from command python setup.py egg_info:
- Traceback (most recent call last):
- File "<string>", line 1, in <module>
- File "/private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-9tn85dxr-build/setup.py", line 51, in <module>
- 'binning_example': ['jupyter', 'pandas', 'bokeh'],
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/distutils/core.py", line 108, in setup
- _setup_distribution = dist = klass(attrs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/venv/lib/python3.6/site-packages/setuptools/dist.py", line 318, in __init__
- _Distribution.__init__(self, attrs)
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/distutils/dist.py", line 281, in __init__
- self.finalize_options()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/venv/lib/python3.6/site-packages/setuptools/dist.py", line 376, in finalize_options
- ep.load()(self, ep.name, value)
- File "/private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-9tn85dxr-build/.eggs/setuptools_scm-1.15.6-py3.6.egg/setuptools_scm/integration.py", line 22, in version_keyword
- File "/private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-9tn85dxr-build/.eggs/setuptools_scm-1.15.6-py3.6.egg/setuptools_scm/__init__.py", line 119, in get_version
- File "/private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-9tn85dxr-build/.eggs/setuptools_scm-1.15.6-py3.6.egg/setuptools_scm/__init__.py", line 97, in _do_parse
- LookupError: setuptools-scm was unable to detect version for '/private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-9tn85dxr-build'.
- Make sure you're either building from a fully intact git repository or PyPI tarballs. Most other sources (such as GitHub's tarballs, a git checkout without the .git folder) don't contain the necessary metadata and will not work.
- For example, if you're using pip, instead of https://github.com/user/proj/archive/master.zip use git+https://github.com/user/proj.git#egg=proj
- ----------------------------------------
- Command "python setup.py egg_info" failed with error code 1 in /private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-9tn85dxr-build/
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install ../winton-kafka-streams/
- Directory '../winton-kafka-streams/' is not installable. File 'setup.py' not found.
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install ../winton-kafka-streams
- Processing /Users/vlad/Documents/projects/binding_with_kafka/winton-kafka-streams
- Complete output from command python setup.py egg_info:
- Traceback (most recent call last):
- File "<string>", line 1, in <module>
- File "/private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-me9xhpo3-build/setup.py", line 51, in <module>
- 'binning_example': ['jupyter', 'pandas', 'bokeh'],
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/distutils/core.py", line 108, in setup
- _setup_distribution = dist = klass(attrs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/venv/lib/python3.6/site-packages/setuptools/dist.py", line 318, in __init__
- _Distribution.__init__(self, attrs)
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/distutils/dist.py", line 281, in __init__
- self.finalize_options()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/venv/lib/python3.6/site-packages/setuptools/dist.py", line 376, in finalize_options
- ep.load()(self, ep.name, value)
- File "/private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-me9xhpo3-build/.eggs/setuptools_scm-1.15.6-py3.6.egg/setuptools_scm/integration.py", line 22, in version_keyword
- File "/private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-me9xhpo3-build/.eggs/setuptools_scm-1.15.6-py3.6.egg/setuptools_scm/__init__.py", line 119, in get_version
- File "/private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-me9xhpo3-build/.eggs/setuptools_scm-1.15.6-py3.6.egg/setuptools_scm/__init__.py", line 97, in _do_parse
- LookupError: setuptools-scm was unable to detect version for '/private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-me9xhpo3-build'.
- Make sure you're either building from a fully intact git repository or PyPI tarballs. Most other sources (such as GitHub's tarballs, a git checkout without the .git folder) don't contain the necessary metadata and will not work.
- For example, if you're using pip, instead of https://github.com/user/proj/archive/master.zip use git+https://github.com/user/proj.git#egg=proj
- ----------------------------------------
- Command "python setup.py egg_info" failed with error code 1 in /private/var/folders/_q/1h896zls3wx50gmt4bmgh_5r0000gr/T/pip-me9xhpo3-build/
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install winton-kafka-streams
- Collecting winton-kafka-streams
- Could not find a version that satisfies the requirement winton-kafka-streams (from versions: )
- No matching distribution found for winton-kafka-streams
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install --upgrade pip
- Requirement already up-to-date: pip in ./venv/lib/python3.6/site-packages
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip list
- DEPRECATION: The default format will switch to columns in the future. You can use --format=(legacy|columns) (or define a format=(legacy|columns) in your pip.conf under the [list] section) to disable this warning.
- confluent-kafka (0.11.0)
- pip (9.0.1)
- setuptools (28.8.0)
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install winton-kafka-streams
- Collecting winton-kafka-streams
- Could not find a version that satisfies the requirement winton-kafka-streams (from versions: )
- No matching distribution found for winton-kafka-streams
- (venv) ➜ python_project git:(master) ✗ pip install kafka-streams
- Collecting kafka-streams
- Could not find a version that satisfies the requirement kafka-streams (from versions: )
- No matching distribution found for kafka-streams
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install --pre winton-kafka-streams
- Collecting winton-kafka-streams
- Could not find a version that satisfies the requirement winton-kafka-streams (from versions: )
- No matching distribution found for winton-kafka-streams
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6
- Python 3.6.3 (default, Oct 4 2017, 06:09:38)
- [GCC 4.2.1 Compatible Apple LLVM 9.0.0 (clang-900.0.37)] on darwin
- Type "help", "copyright", "credits" or "license" for more information.
- >>>
- >>> exit()
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 54, in <module>
- read_stream()
- File "main.py", line 47, in read_stream
- import winton_kafka_streams.kafka_config as kafka_config
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/kafka_config.py", line 24, in <module>
- import javaproperties
- ModuleNotFoundError: No module named 'javaproperties'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install javaproperties
- Collecting javaproperties
- Downloading javaproperties-0.4.0-py2.py3-none-any.whl
- Collecting six<2,>=1.4.0 (from javaproperties)
- Using cached six-1.11.0-py2.py3-none-any.whl
- Installing collected packages: six, javaproperties
- Successfully installed javaproperties-0.4.0 six-1.11.0
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 54, in <module>
- read_stream()
- File "main.py", line 48, in read_stream
- config_file = os.path.join(os.path.dirname(__file__), 'config.properties')
- NameError: name 'os' is not defined
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 73, in <module>
- read_stream()
- File "main.py", line 59, in read_stream
- processor('double', DoubleProcessor, 'input-value')
- NameError: name 'DoubleProcessor' is not defined
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 73, in <module>
- read_stream()
- File "main.py", line 65, in read_stream
- time.sleep(1)
- NameError: name 'time' is not defined
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 73, in <module>
- read_stream()
- File "main.py", line 65, in read_stream
- time.sleep(1)
- NameError: name 'time' is not defined
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Received: b'hello', b'world'
- Received: b'hello', b'world'
- Received: b'hello', b'world'
- Received: b'hello', b'world'
- Received: b'hello', b'world'
- Received: None, b'my message'
- Received: None, b'another message'
- Received: None, b'even more'
- Received: None, b'messages'
- Received: None, b'message from python script'
- Received: None, b'my message'
- Received: None, b'another message'
- Received: None, b'even more'
- Received: None, b'messages'
- Received: None, b'message from python script'
- Received: None, b'message from python script'
- Received: None, b'[object Object]'
- Received: None, b'key from javascript'
- Received: None, b'key from javascript'
- Received: None, b'key from javascript'
- Received: None, b'[object Object]'
- ^C% (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip install dsfsdafsda
- Collecting dsfsdafsda
- Could not find a version that satisfies the requirement dsfsdafsda (from versions: )
- No matching distribution found for dsfsdafsda
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ pip list
- DEPRECATION: The default format will switch to columns in the future. You can use --format=(legacy|columns) (or define a format=(legacy|columns) in your pip.conf under the [list] section) to disable this warning.
- confluent-kafka (0.11.0)
- javaproperties (0.4.0)
- pip (9.0.1)
- setuptools (28.8.0)
- six (1.11.0)
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 99, in <module>
- write_stream()
- File "main.py", line 93, in write_stream
- wks.process(key='python stream key', value='python stream value')
- AttributeError: 'KafkaStreams' object has no attribute 'process'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 47882 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'close', 'consumer', 'kafka_config', 'on_thread_state_change', 'set_state', 'start', 'state', 'state_lock', 'stream_threads', 'thread_states', 'topology']
- Traceback (most recent call last):
- File "main.py", line 100, in <module>
- write_stream()
- File "main.py", line 94, in write_stream
- wks.process(key='python stream key', value='python stream value')
- AttributeError: 'KafkaStreams' object has no attribute 'process'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 48030 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 100, in <module>
- write_stream()
- File "main.py", line 94, in write_stream
- wks.process(key='python stream key', value='python stream value')
- AttributeError: 'KafkaStreams' object has no attribute 'process'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 48178 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__call__', '__class__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__func__', '__ge__', '__get__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__self__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Traceback (most recent call last):
- File "main.py", line 100, in <module>
- write_stream()
- File "main.py", line 94, in write_stream
- wks.topology.processor.process(key='python stream key', value='python stream value')
- AttributeError: 'function' object has no attribute 'process'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 48336 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__call__', '__class__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__func__', '__ge__', '__get__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__self__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Traceback (most recent call last):
- File "main.py", line 100, in <module>
- write_stream()
- File "main.py", line 94, in write_stream
- wks.topology.processor(key='python stream key', value='python stream value')
- TypeError: processor() got an unexpected keyword argument 'key'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 48523 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 102, in <module>
- write_stream()
- File "main.py", line 96, in write_stream
- processor_1.process(key='python stream key', value='python stream value')
- File "main.py", line 84, in process
- super().process(self, key, value)
- TypeError: process() takes 3 positional arguments but 4 were given
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 48752 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 102, in <module>
- write_stream()
- File "main.py", line 96, in write_stream
- processor_1.process('python stream key', 'python stream value')
- File "main.py", line 84, in process
- super().process(self, key, value)
- TypeError: process() takes 3 positional arguments but 4 were given
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 48892 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 102, in <module>
- write_stream()
- File "main.py", line 96, in write_stream
- processor_1.process(key='python stream key', value='python stream value')
- File "main.py", line 84, in process
- super().process(key, value)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- AttributeError: 'NoneType' object has no attribute 'timestamp'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 49010 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 102, in <module>
- write_stream()
- File "main.py", line 96, in write_stream
- processor_1.process(key='python stream key', value='python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- AttributeError: 'NoneType' object has no attribute 'timestamp'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 49171 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- File "main.py", line 93
- print(dir(wks))
- ^
- IndentationError: unexpected indent
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'close', 'consumer', 'kafka_config', 'on_thread_state_change', 'set_state', 'start', 'state', 'state_lock', 'stream_threads', 'thread_states', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 103, in <module>
- write_stream()
- File "main.py", line 97, in write_stream
- processor_1.process(key='python stream key', value='python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- AttributeError: 'NoneType' object has no attribute 'timestamp'
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 103, in <module>
- write_stream()
- File "main.py", line 97, in write_stream
- processor_1.process(key='python stream key', value='python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- AttributeError: 'NoneType' object has no attribute 'timestamp'
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__call__', '__class__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__func__', '__ge__', '__get__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__self__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 103, in <module>
- write_stream()
- File "main.py", line 97, in write_stream
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- processor_1.process(key='python stream key', value='python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- AttributeError: 'NoneType' object has no attribute 'timestamp'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 103, in <module>
- write_stream()
- File "main.py", line 97, in write_stream
- processor_1.topology.sink(key='python stream key', value='python stream value')
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- AttributeError: 'WriteProcessor' object has no attribute 'topology'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 103, in <module>
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- write_stream()
- File "main.py", line 97, in write_stream
- processor_1.sink(key='python stream key', value='python stream value')
- AttributeError: 'WriteProcessor' object has no attribute 'sink'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 103, in <module>
- write_stream()
- File "main.py", line 97, in write_stream
- wks.topology.sink(key='python stream key', value='python stream value')
- TypeError: sink() got an unexpected keyword argument 'key'
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Unexpected state transition from NOT_RUNNING to PENDING_SHUTDOWN.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__add__', '__class__', '__contains__', '__delattr__', '__delitem__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__getitem__', '__gt__', '__hash__', '__iadd__', '__imul__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__mul__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__reversed__', '__rmul__', '__setattr__', '__setitem__', '__sizeof__', '__str__', '__subclasshook__', 'append', 'clear', 'copy', 'count', 'extend', 'index', 'insert', 'pop', 'remove', 'reverse', 'sort']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__call__', '__class__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__func__', '__ge__', '__get__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__self__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__call__', '__class__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__func__', '__ge__', '__get__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__self__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__call__', '__class__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__func__', '__ge__', '__get__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__self__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__call__', '__class__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__func__', '__ge__', '__get__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__self__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'close', 'consumer', 'kafka_config', 'on_thread_state_change', 'set_state', 'start', 'state', 'state_lock', 'stream_threads', 'thread_states', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 109, in <module>
- write_stream()
- File "main.py", line 100, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, consumer, producer, kafka_config)
- NameError: name 'StreamTask' is not defined
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 109, in <module>
- write_stream()
- File "main.py", line 100, in write_stream
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.consumer, producer, wks.kafka_config)
- NameError: name 'StreamTask' is not defined
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'close', 'consumer', 'kafka_config', 'on_thread_state_change', 'set_state', 'start', 'state', 'state_lock', 'stream_threads', 'thread_states', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 109, in <module>
- write_stream()
- File "main.py", line 100, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.consumer, producer, wks.kafka_config)
- NameError: name 'StreamTask' is not defined
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__add__', '__class__', '__contains__', '__delattr__', '__delitem__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__getitem__', '__gt__', '__hash__', '__iadd__', '__imul__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__mul__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__reversed__', '__rmul__', '__setattr__', '__setitem__', '__sizeof__', '__str__', '__subclasshook__', 'append', 'clear', 'copy', 'count', 'extend', 'index', 'insert', 'pop', 'remove', 'reverse', 'sort']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 109, in <module>
- write_stream()
- File "main.py", line 100, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.consumer, producer, wks.kafka_config)
- NameError: name 'StreamTask' is not defined
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'add_records_to_tasks', 'add_stream_tasks', 'close', 'commit', 'commit_all', 'config', 'consumer', 'kafka_supplier', 'log', 'on_assign', 'on_revoke', 'poll_requests', 'process_and_punctuate', 'run', 'set_state', 'set_state_listener', 'set_state_when_not_in_pending_shutdown', 'shutdown', 'start', 'state', 'state_listener', 'still_running', 'tasks', 'thread', 'thread_id', 'topics', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 109, in <module>
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- write_stream()
- File "main.py", line 100, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.consumer, producer, wks.kafka_config)
- NameError: name 'StreamTask' is not defined
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'add_records_to_tasks', 'add_stream_tasks', 'close', 'commit', 'commit_all', 'config', 'consumer', 'kafka_supplier', 'log', 'on_assign', 'on_revoke', 'poll_requests', 'process_and_punctuate', 'run', 'set_state', 'set_state_listener', 'set_state_when_not_in_pending_shutdown', 'shutdown', 'start', 'state', 'state_listener', 'still_running', 'tasks', 'thread', 'thread_id', 'topics', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 109, in <module>
- write_stream()
- File "main.py", line 100, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.consumer, wks.stream_threads[0].kafka_supplier.producer(), wks.kafka_config)
- NameError: name 'StreamTask' is not defined
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'add_records_to_tasks', 'add_stream_tasks', 'close', 'commit', 'commit_all', 'config', 'consumer', 'kafka_supplier', 'log', 'on_assign', 'on_revoke', 'poll_requests', 'process_and_punctuate', 'run', 'set_state', 'set_state_listener', 'set_state_when_not_in_pending_shutdown', 'shutdown', 'start', 'state', 'state_listener', 'still_running', 'tasks', 'thread', 'thread_id', 'topics', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 109, in <module>
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- write_stream()
- File "main.py", line 100, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.consumer(), wks.stream_threads[0].kafka_supplier.producer(), wks.kafka_config)
- NameError: name 'StreamTask' is not defined
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'add_records_to_tasks', 'add_stream_tasks', 'close', 'commit', 'commit_all', 'config', 'consumer', 'kafka_supplier', 'log', 'on_assign', 'on_revoke', 'poll_requests', 'process_and_punctuate', 'run', 'set_state', 'set_state_listener', 'set_state_when_not_in_pending_shutdown', 'shutdown', 'start', 'state', 'state_listener', 'still_running', 'tasks', 'thread', 'thread_id', 'topics', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 110, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.consumer(), wks.stream_threads[0].kafka_supplier.producer(), wks.kafka_config)
- NameError: name 'TaskId' is not defined
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'add_records_to_tasks', 'add_stream_tasks', 'close', 'commit', 'commit_all', 'config', 'consumer', 'kafka_supplier', 'log', 'on_assign', 'on_revoke', 'poll_requests', 'process_and_punctuate', 'run', 'set_state', 'set_state_listener', 'set_state_when_not_in_pending_shutdown', 'shutdown', 'start', 'state', 'state_listener', 'still_running', 'tasks', 'thread', 'thread_id', 'topics', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- File "main.py", line 102, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.consumer(), wks.stream_threads[0].kafka_supplier.producer(), wks.kafka_config)
- TypeError: 'NoneType' object is not callable
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'add_records_to_tasks', 'add_stream_tasks', 'close', 'commit', 'commit_all', 'config', 'consumer', 'kafka_supplier', 'log', 'on_assign', 'on_revoke', 'poll_requests', 'process_and_punctuate', 'run', 'set_state', 'set_state_listener', 'set_state_when_not_in_pending_shutdown', 'shutdown', 'start', 'state', 'state_listener', 'still_running', 'tasks', 'thread', 'thread_id', 'topics', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- File "main.py", line 102, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.stream_threads[0].kafka_supplier.consumer(), wks.stream_threads[0].kafka_supplier.producer(), wks.kafka_config)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 50, in __init__
- self.sinks = [sink_builder(self) for sink_builder in sinks]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 50, in <listcomp>
- self.sinks = [sink_builder(self) for sink_builder in sinks]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 203, in build_sink
- topology._add_node(name, sink, parents)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 63, in _add_node
- node_inputs = list(self.nodes[i] for i in inputs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 63, in <genexpr>
- node_inputs = list(self.nodes[i] for i in inputs)
- KeyError: 'my-processor'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- File "main.py", line 102, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.stream_threads[0].kafka_supplier.consumer(), wks.stream_threads[0].kafka_supplier.producer(), wks.kafka_config)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 50, in __init__
- self.sinks = [sink_builder(self) for sink_builder in sinks]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 50, in <listcomp>
- self.sinks = [sink_builder(self) for sink_builder in sinks]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 203, in build_sink
- topology._add_node(name, sink, parents)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 63, in _add_node
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- node_inputs = list(self.nodes[i] for i in inputs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 63, in <genexpr>
- node_inputs = list(self.nodes[i] for i in inputs)
- KeyError: <class '__main__.write_stream.<locals>.WriteProcessor'>
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- File "main.py", line 102, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.stream_threads[0].kafka_supplier.consumer(), wks.stream_threads[0].kafka_supplier.producer(), wks.kafka_config)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'add_records_to_tasks', 'add_stream_tasks', 'close', 'commit', 'commit_all', 'config', 'consumer', 'kafka_supplier', 'log', 'on_assign', 'on_revoke', 'poll_requests', 'process_and_punctuate', 'run', 'set_state', 'set_state_listener', 'set_state_when_not_in_pending_shutdown', 'shutdown', 'start', 'state', 'state_listener', 'still_running', 'tasks', 'thread', 'thread_id', 'topics', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- File "main.py", line 102, in write_stream
- task = StreamTask(TaskId('testgroup', 0), "myapp", [0], topology_builder, wks.stream_threads[0].kafka_supplier.consumer(), wks.stream_threads[0].kafka_supplier.producer(), wks.kafka_config)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'add_records_to_tasks', 'add_stream_tasks', 'close', 'commit', 'commit_all', 'config', 'consumer', 'kafka_supplier', 'log', 'on_assign', 'on_revoke', 'poll_requests', 'process_and_punctuate', 'run', 'set_state', 'set_state_listener', 'set_state_when_not_in_pending_shutdown', 'shutdown', 'start', 'state', 'state_listener', 'still_running', 'tasks', 'thread', 'thread_id', 'topics', 'topology']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Unexpected state transition from NOT_RUNNING to PENDING_SHUTDOWN.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__add__', '__class__', '__contains__', '__delattr__', '__delitem__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__getitem__', '__gt__', '__hash__', '__iadd__', '__imul__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__mul__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__reversed__', '__rmul__', '__setattr__', '__setitem__', '__sizeof__', '__str__', '__subclasshook__', 'append', 'clear', 'copy', 'count', 'extend', 'index', 'insert', 'pop', 'remove', 'reverse', 'sort']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Unexpected state transition from NOT_RUNNING to PENDING_SHUTDOWN.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__annotations__', '__call__', '__class__', '__closure__', '__code__', '__defaults__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__get__', '__getattribute__', '__globals__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__kwdefaults__', '__le__', '__lt__', '__module__', '__name__', '__ne__', '__new__', '__qualname__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 112, in <module>
- write_stream()
- File "main.py", line 95, in write_stream
- print(wks.stream_threads[0].topology._processors.count())
- TypeError: count() takes exactly one argument (0 given)
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 112, in <module>
- write_stream()
- File "main.py", line 95, in write_stream
- print(wks.stream_threads[0].topology._processors.count())
- TypeError: count() takes exactly one argument (0 given)
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- File "main.py", line 95, in write_stream
- print(dir(wks.stream_threads[0].topology._processors[1]))
- IndexError: list index out of range
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- File "main.py", line 95, in write_stream
- print(dir(wks.stream_threads[0].topology._processors[1]))
- IndexError: list index out of range
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__annotations__', '__call__', '__class__', '__closure__', '__code__', '__defaults__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__get__', '__getattribute__', '__globals__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__kwdefaults__', '__le__', '__lt__', '__module__', '__name__', '__ne__', '__new__', '__qualname__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__annotations__', '__call__', '__class__', '__closure__', '__code__', '__defaults__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__get__', '__getattribute__', '__globals__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__kwdefaults__', '__le__', '__lt__', '__module__', '__name__', '__ne__', '__new__', '__qualname__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to set subscription: Local: Invalid argument or configuration"}
- write_stream()
- File "main.py", line 97, in write_stream
- wks.topology.processor('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 188, in processor
- raise KafkaStreamsError("Processor '%s' must have a minimum of 1 input", name)
- winton_kafka_streams.errors.kafka_streams_error.KafkaStreamsError: ("Processor '%s' must have a minimum of 1 input", 'python stream key')
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__annotations__', '__call__', '__class__', '__closure__', '__code__', '__defaults__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__get__', '__getattribute__', '__globals__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__kwdefaults__', '__le__', '__lt__', '__module__', '__name__', '__ne__', '__new__', '__qualname__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- File "main.py", line 97, in write_stream
- wks.topology.processor('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 188, in processor
- raise KafkaStreamsError("Processor '%s' must have a minimum of 1 input", name)
- winton_kafka_streams.errors.kafka_streams_error.KafkaStreamsError: ("Processor '%s' must have a minimum of 1 input", 'python stream key')
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 54224 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'close', 'consumer', 'kafka_config', 'on_thread_state_change', 'set_state', 'start', 'state', 'state_lock', 'stream_threads', 'thread_states', 'topology']
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- File "main.py", line 97, in write_stream
- wks.topology.processor('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 188, in processor
- raise KafkaStreamsError("Processor '%s' must have a minimum of 1 input", name)
- winton_kafka_streams.errors.kafka_streams_error.KafkaStreamsError: ("Processor '%s' must have a minimum of 1 input", 'python stream key')
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 54326 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- File "main.py", line 95
- print(dir(wks.stream_threads[0]]))
- ^
- SyntaxError: invalid syntax
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- File "main.py", line 95
- print(dir(wks.stream_threads[0]]))
- ^
- SyntaxError: invalid syntax
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['State', '__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'add_records_to_tasks', 'add_stream_tasks', 'close', 'commit', 'commit_all', 'config', 'consumer', 'kafka_supplier', 'log', 'on_assign', 'on_revoke', 'poll_requests', 'process_and_punctuate', 'run', 'set_state', 'set_state_listener', 'set_state_when_not_in_pending_shutdown', 'shutdown', 'start', 'state', 'state_listener', 'still_running', 'tasks', 'thread', 'thread_id', 'topics', 'topology']
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- File "main.py", line 97, in write_stream
- wks.topology.processor('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 188, in processor
- raise KafkaStreamsError("Processor '%s' must have a minimum of 1 input", name)
- winton_kafka_streams.errors.kafka_streams_error.KafkaStreamsError: ("Processor '%s' must have a minimum of 1 input", 'python stream key')
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 54460 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 111, in <module>
- write_stream()
- File "main.py", line 97, in write_stream
- wks.topology.processor('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 188, in processor
- raise KafkaStreamsError("Processor '%s' must have a minimum of 1 input", name)
- winton_kafka_streams.errors.kafka_streams_error.KafkaStreamsError: ("Processor '%s' must have a minimum of 1 input", 'python stream key')
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 54558 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 113, in <module>
- write_stream()
- File "main.py", line 98, in write_stream
- wks.topology.process('python stream key', 'python stream value')
- AttributeError: 'TopologyBuilder' object has no attribute 'process'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 55127 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗ \\\\\\\
- >
- zsh: command not found: \\\
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ \\\\\\\
- zsh: command not found: \\\
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 113, in <module>
- write_stream()
- File "main.py", line 98, in write_stream
- wks.topology.processor('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 188, in processor
- raise KafkaStreamsError("Processor '%s' must have a minimum of 1 input", name)
- winton_kafka_streams.errors.kafka_streams_error.KafkaStreamsError: ("Processor '%s' must have a minimum of 1 input", 'python stream key')
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 55248 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__enter__', '__eq__', '__exit__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_processors', '_sinks', '_sources', '_state_stores', 'build', 'processor', 'sink', 'sinks', 'source', 'sources', 'state_store', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 113, in <module>
- write_stream()
- File "main.py", line 98, in write_stream
- wks.topology.processor.process('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'function' object has no attribute 'process'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 55745 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__call__', '__class__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__func__', '__ge__', '__get__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__self__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- Traceback (most recent call last):
- File "main.py", line 113, in <module>
- write_stream()
- File "main.py", line 98, in write_stream
- wks.topology.processor.process('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'function' object has no attribute 'process'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- [1] 55874 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__annotations__', '__call__', '__class__', '__closure__', '__code__', '__defaults__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__get__', '__getattribute__', '__globals__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__kwdefaults__', '__le__', '__lt__', '__module__', '__name__', '__ne__', '__new__', '__qualname__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__']
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__add__', '__class__', '__contains__', '__delattr__', '__delitem__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__getitem__', '__gt__', '__hash__', '__iadd__', '__imul__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__mul__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__reversed__', '__rmul__', '__setattr__', '__setitem__', '__sizeof__', '__str__', '__subclasshook__', 'append', 'clear', 'copy', 'count', 'extend', 'index', 'insert', 'pop', 'remove', 'reverse', 'sort']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 113, in <module>
- write_stream()
- File "main.py", line 95, in write_stream
- print(dir(wks.topology.nodes))
- AttributeError: 'TopologyBuilder' object has no attribute 'nodes'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 115, in <module>
- write_stream()
- File "main.py", line 94, in write_stream
- topology = topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 192, in build_processor
- processor_node = ProcessorNode(name, processor_type())
- TypeError: __init__() missing 1 required positional argument: '_topic'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 115, in <module>
- write_stream()
- File "main.py", line 94, in write_stream
- topology = topology_builder.build()
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 209, in build
- return Topology(self._sources, self._processors, self._sinks, self._state_stores)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in __init__
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 49, in <listcomp>
- self.processors = [processor_builder(self) for processor_builder in processors]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 193, in build_processor
- topology._add_node(name, processor_node, parents)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 63, in _add_node
- node_inputs = list(self.nodes[i] for i in inputs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 63, in <genexpr>
- node_inputs = list(self.nodes[i] for i in inputs)
- KeyError: 'output-value'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 115, in <module>
- write_stream()
- File "main.py", line 91, in write_stream
- topology_builder.processor('write', BaseProcessor)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 188, in processor
- raise KafkaStreamsError("Processor '%s' must have a minimum of 1 input", name)
- winton_kafka_streams.errors.kafka_streams_error.KafkaStreamsError: ("Processor '%s' must have a minimum of 1 input", 'write')
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 115, in <module>
- write_stream()
- File "main.py", line 96, in write_stream
- wks = kafka_streams.KafkaStreams(topology, kafka_config)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/kafka_streams.py", line 95, in __init__
- for i in range(int(self.kafka_config.NUM_STREAM_THREADS))]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/kafka_streams.py", line 95, in <listcomp>
- for i in range(int(self.kafka_config.NUM_STREAM_THREADS))]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 89, in __init__
- self.topics = _topology.topics
- AttributeError: 'Topology' object has no attribute 'topics'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__contains__', '__delattr__', '__delitem__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__getitem__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__setitem__', '__sizeof__', '__str__', '__subclasshook__', 'clear', 'copy', 'fromkeys', 'get', 'items', 'keys', 'pop', 'popitem', 'setdefault', 'update', 'values']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- TypeError: expected list of topic unicode strings
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processor('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'Topology' object has no attribute 'processor'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 98, in write_stream
- print(dir(wks.topology.nodes[0]))
- KeyError: 0
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processor('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'Topology' object has no attribute 'processor'
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- TypeError: expected list of topic unicode strings
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- TypeError: expected list of topic unicode strings
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processor('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'Topology' object has no attribute 'processor'
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 98, in write_stream
- print(dir(wks.topology.processors.processors))
- AttributeError: 'list' object has no attribute 'processors'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__add__', '__class__', '__contains__', '__delattr__', '__delitem__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__getitem__', '__gt__', '__hash__', '__iadd__', '__imul__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__mul__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__reversed__', '__rmul__', '__setattr__', '__setitem__', '__sizeof__', '__str__', '__subclasshook__', 'append', 'clear', 'copy', 'count', 'extend', 'index', 'insert', 'pop', 'remove', 'reverse', 'sort']
- Unexpected state transition from RUNNING to NOT_RUNNING.
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processor('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'Topology' object has no attribute 'processor'
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 130, in run
- self.consumer.subscribe(self.topics, on_assign=self.on_assign, on_revoke=self.on_revoke)
- TypeError: expected list of topic unicode strings
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__add__', '__class__', '__contains__', '__delattr__', '__delitem__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__getitem__', '__gt__', '__hash__', '__iadd__', '__imul__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__mul__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__reversed__', '__rmul__', '__setattr__', '__setitem__', '__sizeof__', '__str__', '__subclasshook__', 'append', 'clear', 'copy', 'count', 'extend', 'index', 'insert', 'pop', 'remove', 'reverse', 'sort']
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processor('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'Topology' object has no attribute 'processor'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 57388 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processor('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'Topology' object has no attribute 'processor'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 57406 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__contains__', '__delattr__', '__delitem__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__getitem__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__setitem__', '__sizeof__', '__str__', '__subclasshook__', 'clear', 'copy', 'fromkeys', 'get', 'items', 'keys', 'pop', 'popitem', 'setdefault', 'update', 'values']
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processor('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'Topology' object has no attribute 'processor'
- ^CException ignored in: <module 'threading' from '/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py'>
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 1294, in _shutdown
- t.join()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 1056, in join
- self._wait_for_tstate_lock()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 1072, in _wait_for_tstate_lock
- elif lock.acquire(block, timeout):
- KeyboardInterrupt
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__and__', '__class__', '__contains__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__ne__', '__new__', '__or__', '__rand__', '__reduce__', '__reduce_ex__', '__repr__', '__ror__', '__rsub__', '__rxor__', '__setattr__', '__sizeof__', '__str__', '__sub__', '__subclasshook__', '__xor__', 'isdisjoint']
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processor('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'Topology' object has no attribute 'processor'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 57575 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- File "main.py", line 99
- wks.start()
- ^
- SyntaxError: invalid syntax
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 98, in write_stream
- print(dir(wks.topology.nodes['isdisjoint']))
- KeyError: 'isdisjoint'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'children', 'initialise', 'name', 'process', 'processor', 'punctuate', 'state_stores']
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processor('mytopic', 'python stream key', 'python stream value')
- AttributeError: 'Topology' object has no attribute 'processor'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 57745 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- File "main.py", line 101
- wks.topology.processors[0].process(python stream key', 'python stream value')
- ^
- SyntaxError: invalid syntax
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'children', 'initialise', 'name', 'process', 'processor', 'punctuate', 'state_stores']
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processors[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- AttributeError: 'BaseProcessor' object has no attribute 'process'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 57951 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processors[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- AttributeError: 'BaseProcessor' object has no attribute 'process'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 58060 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__add__', '__class__', '__contains__', '__delattr__', '__delitem__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__getitem__', '__gt__', '__hash__', '__iadd__', '__imul__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__mul__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__reversed__', '__rmul__', '__setattr__', '__setitem__', '__sizeof__', '__str__', '__subclasshook__', 'append', 'clear', 'copy', 'count', 'extend', 'index', 'insert', 'pop', 'remove', 'reverse', 'sort']
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processors[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- AttributeError: 'BaseProcessor' object has no attribute 'process'
- ^CException ignored in: <module 'threading' from '/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py'>
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 1294, in _shutdown
- t.join()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 1056, in join
- self._wait_for_tstate_lock()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 1072, in _wait_for_tstate_lock
- elif lock.acquire(block, timeout):
- KeyboardInterrupt
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'children', 'initialise', 'name', 'process', 'processor', 'punctuate', 'state_stores']
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.processors[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- AttributeError: 'BaseProcessor' object has no attribute 'process'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 58226 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'children', 'initialise', 'name', 'process', 'processor', 'punctuate', 'state_stores']
- Traceback (most recent call last):
- File "main.py", line 116, in <module>
- write_stream()
- File "main.py", line 101, in write_stream
- wks.topology.sinks[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- AttributeError: 'NoneType' object has no attribute 'timestamp'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 58326 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'children', 'initialise', 'name', 'process', 'processor', 'punctuate', 'state_stores']
- Traceback (most recent call last):
- File "main.py", line 120, in <module>
- write_stream()
- File "main.py", line 102, in write_stream
- class TimestampContainer:
- File "main.py", line 103, in TimestampContainer
- timestamp = datetime.now()
- AttributeError: module 'datetime' has no attribute 'now'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 58542 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'children', 'initialise', 'name', 'process', 'processor', 'punctuate', 'state_stores']
- Traceback (most recent call last):
- File "main.py", line 120, in <module>
- write_stream()
- File "main.py", line 104, in write_stream
- wks.topology.sinks[0].initialize('write', TimestampContainer)
- AttributeError: 'ProcessorNode' object has no attribute 'initialize'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 58615 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'children', 'initialise', 'name', 'process', 'processor', 'punctuate', 'state_stores']
- Traceback (most recent call last):
- File "main.py", line 120, in <module>
- write_stream()
- File "main.py", line 104, in write_stream
- wks.topology.sinks[0].initialise('write', TimestampContainer)
- TypeError: initialise() takes 2 positional arguments but 3 were given
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 58690 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'children', 'initialise', 'name', 'process', 'processor', 'punctuate', 'state_stores']
- Traceback (most recent call last):
- File "main.py", line 120, in <module>
- write_stream()
- File "main.py", line 105, in write_stream
- wks.topology.sinks[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- AttributeError: 'str' object has no attribute 'timestamp'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 58793 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', 'children', 'initialise', 'name', 'process', 'processor', 'punctuate', 'state_stores']
- Traceback (most recent call last):
- File "main.py", line 120, in <module>
- write_stream()
- File "main.py", line 105, in write_stream
- wks.topology.sinks[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 59, in _send
- self.context.recordCollector.send(self.topic, key, value, timestamp)
- AttributeError: type object 'TimestampContainer' has no attribute 'recordCollector'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 58857 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- File "main.py", line 99
- print(dir(wks.topology]))
- ^
- SyntaxError: invalid syntax
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 120, in <module>
- write_stream()
- File "main.py", line 105, in write_stream
- wks.topology.sinks[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 59, in _send
- self.context.recordCollector.send(self.topic, key, value, timestamp)
- AttributeError: type object 'TimestampContainer' has no attribute 'recordCollector'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 59000 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- Traceback (most recent call last):
- File "main.py", line 123, in <module>
- write_stream()
- File "main.py", line 99, in write_stream
- context = Context(wks.topology.state_stores)
- UnboundLocalError: local variable 'wks' referenced before assignment
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 123, in <module>
- write_stream()
- File "main.py", line 108, in write_stream
- wks.topology.sinks[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 59, in _send
- self.context.recordCollector.send(self.topic, key, value, timestamp)
- AttributeError: type object 'TimestampContainer' has no attribute 'recordCollector'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 59224 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 123, in <module>
- write_stream()
- File "main.py", line 108, in write_stream
- wks.topology.sinks[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 59, in _send
- self.context.recordCollector.send(self.topic, key, value, timestamp)
- AttributeError: type object 'TimestampContainer' has no attribute 'recordCollector'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 59335 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- File "main.py", line 82
- from winton-kafka-streams.winton_kafka_streams.processor._record_collector import RecordCollector
- ^
- SyntaxError: invalid syntax
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 130, in <module>
- write_stream()
- File "main.py", line 115, in write_stream
- wks.topology.sinks[0].process('python stream key', 'python stream value')
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/topology.py", line 25, in process
- self.processor.process(key, value)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 53, in process
- self._send(key, value, self.context.timestamp)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/processor.py", line 59, in _send
- self.context.recordCollector.send(self.topic, key, value, timestamp)
- AttributeError: type object 'TimestampContainer' has no attribute 'recordCollector'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 59739 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 132, in <module>
- write_stream()
- File "main.py", line 114, in write_stream
- record_collector.send('mytopic', 'python key', 'python value', datetime.time())
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_record_collector.py", line 30, in send
- ser_key = self.key_serde.serializer.serialize(topic, key)
- AttributeError: 'function' object has no attribute 'serializer'
- Unexpected state transition from RUNNING to ASSIGNING_PARTITIONS.
- Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING.
- Exception in thread Thread-1:
- Traceback (most recent call last):
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 916, in _bootstrap_inner
- self.run()
- File "/usr/local/Cellar/python3/3.6.3/Frameworks/Python.framework/Versions/3.6/lib/python3.6/threading.py", line 864, in run
- self._target(*self._args, **self._kwargs)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 134, in run
- records = self.poll_requests(0.1)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 157, in poll_requests
- record = self.consumer.poll(poll_timeout)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 215, in on_assign
- self.add_stream_tasks(partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 209, in add_stream_tasks
- in grouped_tasks.items()]
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_thread.py", line 208, in <listcomp>
- for (task_id, partitions)
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_stream_task.py", line 59, in __init__
- self.topology = _topology_builder.build()
- AttributeError: 'Topology' object has no attribute 'build'
- [1] 60028 segmentation fault python3.6 main.py
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 132, in <module>
- write_stream()
- File "main.py", line 114, in write_stream
- record_collector.send('mytopic', key='python key', value='python value', timestamp=datetime.time())
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_record_collector.py", line 30, in send
- ser_key = self.key_serde.serializer.serialize(topic, key)
- AttributeError: 'function' object has no attribute 'serializer'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 135, in <module>
- write_stream()
- File "main.py", line 117, in write_stream
- record_collector.send('mytopic', key='python key', value='python value', timestamp=datetime.time())
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_record_collector.py", line 30, in send
- ser_key = self.key_serde.serializer.serialize(topic, key)
- AttributeError: type object 'Serializer' has no attribute 'serializer'
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 135, in <module>
- write_stream()
- File "main.py", line 117, in write_stream
- record_collector.send('mytopic', key='python key', value='python value', timestamp=datetime.time())
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_record_collector.py", line 30, in send
- ser_key = self.key_serde.serializer.serialize(topic, key)
- AttributeError: 'function' object has no attribute 'serialize'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 136, in <module>
- write_stream()
- File "main.py", line 118, in write_stream
- record_collector.send('mytopic', key='python key', value='python value', timestamp=datetime.time())
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_record_collector.py", line 30, in send
- ser_key = self.key_serde.serializer.serialize(topic, key)
- AttributeError: type object 'KeySerde' has no attribute 'serializer'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- Traceback (most recent call last):
- File "main.py", line 136, in <module>
- write_stream()
- File "main.py", line 118, in write_stream
- record_collector.send('mytopic', key='python key', value='python value', timestamp=datetime.time())
- File "/Users/vlad/Documents/projects/binding_with_kafka/python_project/winton_kafka_streams/processor/_record_collector.py", line 31, in send
- ser_value = self.value_serde.serializer.serialize(topic, value)
- AttributeError: 'function' object has no attribute 'serializer'
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗
- (venv) ➜ python_project git:(master) ✗ python3.6 main.py
- ['__class__', '__delattr__', '__dict__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_add_node', 'nodes', 'processors', 'sinks', 'sources', 'state_stores', 'topics']
- (venv) ➜ python_project git:(master) ✗
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement