现在我在hbase和Kafka的基础上工作。
我的要求是:假设hbase数据库中存在一些数据。现在我要把数据库给Kafka。在这里,我的hbase数据库就像一个生产者,当我在数据库/生产者中创建任何东西时,它会自动捕获到kafka消费者。
我遵循了许多链接,但我没有得到确切的解决办法。请给我建议,并提供一些基于要求的链接。如果你需要任何额外的信息,请打电话给我。
现在我在hbase和Kafka的基础上工作。
我的要求是:假设hbase数据库中存在一些数据。现在我要把数据库给Kafka。在这里,我的hbase数据库就像一个生产者,当我在数据库/生产者中创建任何东西时,它会自动捕获到kafka消费者。
我遵循了许多链接,但我没有得到确切的解决办法。请给我建议,并提供一些基于要求的链接。如果你需要任何额外的信息,请打电话给我。
1条答案
按热度按时间vnjpjtjt1#
如果您想将数据库用作生产者,您可能需要查看kafka connect。
它允许从外部来源可靠地摄取数据到Kafka。
https://kafka.apache.org/documentation.html#connect
http://docs.confluent.io/3.0.0/connect/index.html