kafka adapter example fails
Open
Nobody has claimed this yet.
type: bug
- Dominant language
- Python
- Stars
- 441
- Forks
- 90
- Avg merge
- 1d 12m
- Merged PRs (30d)
- 5
Description
Describe the bug
Running e_08_kafka.py errors out
To Reproduce
Steps to reproduce the behavior:
cd csp/examples
python e_08_kafka.py
Traceback (most recent call last):
File "/Users/goldbaum/Documents/csp/csp/examples/e_08_kafka.py", line 6, in <module>
from csp.adapters.kafka import (
ImportError: cannot import name 'ProtoMessageMapper' from 'csp.adapters.kafka' (/Users/goldbaum/Documents/csp/csp/adapters/kafka.py)
Expected behavior
No error
Contributor guide
No contributing guide indexed for this repository
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Run cd csp/examples && python e_08_kafka.py first to reproduce the import error in e_08_kafka.py. Then inspect the import from csp.adapters.kafka and the corresponding adapter module; done means the example runs without the reported ImportError.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- kafka, python
- Domain
- stream-processing
- Issue type
- Bug
- Difficulty
- 2/5
- Estimated time
- 1-3 hours
- Activity status
- Stale
- Clarity
- Clearly specified
- Newbie friendliness
- 45/100