[ 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)