"""Kafka executor structs."""
from collections import namedtuple

PartitionOffset = namedtuple('PartitionOffset', ['partition', 'offset'])
"""Storage class to store topic offsets per partition."""


class AutoOffsetReset:
    """Offset reset strategy acceptable config options."""

    LATEST = str('latest')
    EARLIEST = str('earliest')