BDEPEND=dev-python/confluent-kafka[python_targets_python3_10(-)?,python_targets_python3_11(-)?,python_targets_python3_12(-)?] dev-python/rocksdict[python_targets_python3_10(-)?,python_targets_python3_11(-)?,python_targets_python3_12(-)?] dev-python/PyPubSub[python_targets_python3_10(-)?,python_targets_python3_11(-)?,python_targets_python3_12(-)?] dev-python/avro[python_targets_python3_10(-)?,python_targets_python3_11(-)?,python_targets_python3_12(-)?] =dev-python/gpep517-15[python_targets_python3_10(-)?,python_targets_python3_11(-)?,python_targets_python3_12(-)?] DEFINED_PHASES=compile configure install prepare test unpack DESCRIPTION=Streamline your Kafka data processing, this tool aims to standardize streaming data from multiple Kafka clusters. With a pub-sub approach, multiple functions can easily subscribe to incoming messages, serialization can be specified per topic, and data is automatically processed by data sink functions. EAPI=8 HOMEPAGE=https://github.com/Menziess/snapstream INHERIT=python-r1 gs-pypi IUSE=python_targets_python3_10 python_targets_python3_11 python_targets_python3_12 KEYWORDS=~amd64 ~x86 LICENSE=MIT RDEPEND=dev-python/confluent-kafka[python_targets_python3_10(-)?,python_targets_python3_11(-)?,python_targets_python3_12(-)?] dev-python/rocksdict[python_targets_python3_10(-)?,python_targets_python3_11(-)?,python_targets_python3_12(-)?] dev-python/PyPubSub[python_targets_python3_10(-)?,python_targets_python3_11(-)?,python_targets_python3_12(-)?] dev-python/avro[python_targets_python3_10(-)?,python_targets_python3_11(-)?,python_targets_python3_12(-)?]