feat: Rename streaming_kafka_consumer to arroyo (#1953)

Author: lynnagara

.github/workflows/ci.yml

@@ -42,7 +42,7 @@ jobs:
           pip install pytest==6.1.2
       - name: Run mypy
         run: |
-          mypy --config-file mypy.ini --ignore-missing-imports --strict --warn-unreachable snuba streaming_kafka_consumer
+          mypy --config-file mypy.ini --ignore-missing-imports --strict --warn-unreachable snuba arroyo
 
   tests:
     needs: linting

arroyo/__init__.py

@@ -0,0 +1,9 @@
+from arroyo.metrics import configure_metrics
+from arroyo.types import Message, Partition, Topic
+
+__all__ = [
+    "Message",
+    "Partition",
+    "Topic",
+    "configure_metrics",
+]

…ming_kafka_consumer/backends/__init__.py arroyo/backends/__init__.pystreaming_kafka_consumer/backends/__init__.py renamed to arroyo/backends/__init__.py streaming_kafka_consumer/backends/__init__.py renamed to arroyo/backends/__init__.py

@@ -5,7 +5,7 @@
 from concurrent.futures import Future
 from typing import Callable, Generic, Mapping, Optional, Sequence, Union
 
-from streaming_kafka_consumer.types import Message, Partition, Topic, TPayload
+from arroyo.types import Message, Partition, Topic, TPayload
 
 logger = logging.getLogger(__name__)
 

…ming_kafka_consumer/backends/abstract.py arroyo/backends/abstract.pystreaming_kafka_consumer/backends/abstract.py renamed to arroyo/backends/abstract.py streaming_kafka_consumer/backends/abstract.py renamed to arroyo/backends/abstract.py

@@ -2,7 +2,7 @@
 import logging
 from typing import Any, Dict, Mapping, Optional, Sequence
 
-from streaming_kafka_consumer.logging import pylog_to_syslog_level
+from arroyo.logging import pylog_to_syslog_level
 
 logger = logging.getLogger(__name__)
 

…afka_consumer/backends/kafka/__init__.py arroyo/backends/kafka/__init__.pystreaming_kafka_consumer/backends/kafka/__init__.py renamed to arroyo/backends/kafka/__init__.py streaming_kafka_consumer/backends/kafka/__init__.py renamed to arroyo/backends/kafka/__init__.py

@@ -22,6 +22,16 @@
     Union,
 )
 
+from arroyo.backends.abstract import Consumer, Producer
+from arroyo.concurrent import execute
+from arroyo.errors import (
+    ConsumerError,
+    EndOfPartition,
+    OffsetOutOfRange,
+    TransportError,
+)
+from arroyo.retries import NoRetryPolicy, RetryPolicy
+from arroyo.types import Message, Partition, Topic
 from confluent_kafka import (
     OFFSET_BEGINNING,
     OFFSET_END,
@@ -34,16 +44,6 @@
 from confluent_kafka import Message as ConfluentMessage
 from confluent_kafka import Producer as ConfluentProducer
 from confluent_kafka import TopicPartition as ConfluentTopicPartition
-from streaming_kafka_consumer.backends.abstract import Consumer, Producer
-from streaming_kafka_consumer.concurrent import execute
-from streaming_kafka_consumer.errors import (
-    ConsumerError,
-    EndOfPartition,
-    OffsetOutOfRange,
-    TransportError,
-)
-from streaming_kafka_consumer.retries import NoRetryPolicy, RetryPolicy
-from streaming_kafka_consumer.types import Message, Partition, Topic
 
 logger = logging.getLogger(__name__)
 

…consumer/backends/kafka/configuration.py arroyo/backends/kafka/configuration.pystreaming_kafka_consumer/backends/kafka/configuration.py renamed to arroyo/backends/kafka/configuration.py streaming_kafka_consumer/backends/kafka/configuration.py renamed to arroyo/backends/kafka/configuration.py

@@ -20,11 +20,11 @@
     Union,
 )
 
-from streaming_kafka_consumer.backends.abstract import Consumer, Producer
-from streaming_kafka_consumer.backends.local.storages.abstract import MessageStorage
-from streaming_kafka_consumer.clock import Clock, SystemClock
-from streaming_kafka_consumer.errors import ConsumerError, EndOfPartition
-from streaming_kafka_consumer.types import Message, Partition, Topic, TPayload
+from arroyo.backends.abstract import Consumer, Producer
+from arroyo.backends.local.storages.abstract import MessageStorage
+from arroyo.clock import Clock, SystemClock
+from arroyo.errors import ConsumerError, EndOfPartition
+from arroyo.types import Message, Partition, Topic, TPayload
 
 
 class LocalBroker(Generic[TPayload]):

…afka_consumer/backends/kafka/consumer.py arroyo/backends/kafka/consumer.pystreaming_kafka_consumer/backends/kafka/consumer.py renamed to arroyo/backends/kafka/consumer.py streaming_kafka_consumer/backends/kafka/consumer.py renamed to arroyo/backends/kafka/consumer.py

@@ -0,0 +1,5 @@
+from arroyo.backends.local.storages.abstract import MessageStorage
+
+__all__ = [
+    "MessageStorage",
+]