[jira] [Commented] (ARROW-10979) [Rust] Basic Kafka Reader

["Andrew Lamb (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/ARROW-10979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332176#comment-17332176 ] 

Andrew Lamb commented on ARROW-10979:
-------------------------------------

Migrated to github: https://github.com/apache/arrow-rs/issues/148

> [Rust] Basic Kafka Reader
> -------------------------
>
>                 Key: ARROW-10979
>                 URL: https://issues.apache.org/jira/browse/ARROW-10979
>             Project: Apache Arrow
>          Issue Type: Improvement
>          Components: Rust
>            Reporter: Kevin Flansburg
>            Priority: Minor
>              Labels: pull-request-available
>          Time Spent: 5h 10m
>  Remaining Estimate: 0h
>
> Introduce a basic Kafka reader based on `rdkafka`. Exposes an `Iterator` interface which yields `Result<RecordBatch>`. 
> Columns in the batch are:
> *key* (Binary, nullable): The key of a message, if present.
> *payload* (Binary, nullable): The payload bytes of a message, if present.
> *topic* (Utf8): The topic of the message.
> *partition* (Int32): The partition of the message.
> *offset* (Int64): The offset of the message.
>  
> Note that `rdkafka` has a C++ dependency (`librdkafka`), but we can choose to make this dynamically linked. `rdkafka` provides an `async` Consumer, but I have explicitly chosen the non-`async` Consumer.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)