sentry-arroyo

library2.39.2pypypi✓ verified 80d ago

Arroyo is a Python library for working with streaming data, providing a Kafka consumer/producer abstraction with processing guarantees. Current version 2.39.2, released regularly.

devops

pip install sentry-arroyo

github ↗homepage ↗

INSTALL

IMPORT

SIG · SENTRY-ARROYO

sentry-arroyo

devopspythonv2.39.2

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

Message

✓ from arroyo import Message

✗ from arroyo import Consumer

Partition

✓ from arroyo import Partition

Topic

✓ from arroyo import Topic

Minimal consumer example reading from Kafka.

import os from arroyo import Consumer, TopicPartition from arroyo.backends.kafka import KafkaProducer, KafkaConsumer from arroyo.processing.strategies import RunTask # Initialize a consumer consumer = Consumer( KafkaConsumer( bootstrap_servers=os.environ.get('KAFKA_BOOTSTRAP_SERVERS', 'localhost:9092'), group_id='my-group', ) ) consumer.subscribe([TopicPartition('my-topic', 0)]) # Process messages for message in consumer: print(message.value) consumer.commit()

Debug

Known issues

breakingIn v2.0, the ProcessingStrategy base class changed from Strategy to ProcessingStrategy. All custom strategies must be updated.

fix

Rename class to inherit from ProcessingStrategy and update any references.

affects: >=2.0.0

breakingThe KafkaConsumer and KafkaProducer classes moved from arroyo.backends.kafka to arroyo.backends.kafka. Old imports will break.

fix

Use 'from arroyo.backends.kafka import KafkaConsumer' instead of old path.

affects: >=1.0.0

gotchaAlways call consumer.commit() after processing a batch of messages to avoid duplicates or data loss.

fix

Implement proper commit logic in your processing loop.

affects: all

Upgrade

Version history

2.39.2latest on PyPI · released May 8, 2026

Audit

Dependencies

kafka-pythonrequiredKafka client used by Arroyo

confluent-kafkaoptionalAlternative Kafka client (optional)

Agent activity

13 hits · last 30 days

node

Amazon

Resources

githubhttps://github.com/getsentry/arroyo ↗

homepagehttps://github.com/getsentry/arroyo ↗