[
https://issues.apache.org/jira/browse/KAFKA-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15067437#comment-15067437
]
James Cheng commented on KAFKA-2914:
------------------------------------
https://github.com/wushujames/copycat-connector-skeleton has now been updated
to support 0.9.0. And it has been renamed to
https://github.com/wushujames/kafka-connector-skeleton
> Kafka Connect Source connector for HBase
> -----------------------------------------
>
> Key: KAFKA-2914
> URL: https://issues.apache.org/jira/browse/KAFKA-2914
> Project: Kafka
> Issue Type: New Feature
> Components: copycat
> Reporter: Niels Basjes
> Assignee: Ewen Cheslack-Postava
>
> In many cases I see HBase being used to persist data.
> I would like to listen to the changes and process them in a streaming system
> (like Apache Flink).
> Feature request: A Kafka Connect "Source" that listens to the changes in a
> specified HBase table. These changes are then stored in a 'standardized' form
> in Kafka so that it becomes possible to process the observed changes in
> near-realtime. I expect this 'standard' to be very HBase specific.
> Implementation suggestion: Perhaps listening to the HBase WAL like the "HBase
> Side Effects Processor" does?
> https://github.com/NGDATA/hbase-indexer/tree/master/hbase-sep
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)