crunch-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Micah Whitacre (JIRA)" <>
Subject [jira] [Commented] (CRUNCH-611) Simplified Kafka Offset Management in HDFS
Date Thu, 14 Jul 2016 17:27:20 GMT


Micah Whitacre commented on CRUNCH-611:

Optional means it is needed to compile but that the dependency is not pushed on to consumers
transitively.  If someone wants to use our Offset management they will be responsible for
including those dependencies in their assemblies.

> Simplified Kafka Offset Management in HDFS
> ------------------------------------------
>                 Key: CRUNCH-611
>                 URL:
>             Project: Crunch
>          Issue Type: Improvement
>          Components: IO
>            Reporter: Micah Whitacre
>            Assignee: Micah Whitacre
>         Attachments: CRUNCH-611.patch
> With the KafkaSource the responsibility of offset management is the burden of the consumer.
 With some simple APIs it is actually trivial to support read/storing these offsets in an
HDFS directory as checkpoints for the source.

This message was sent by Atlassian JIRA

View raw message