我正在使用来自Confluent的Kafka Connect来使用Kafka流并以镶木地板格式写入HDFS.我在1节点中使用Schema Registry服务,它运行正常.现在我想将Schema Registry分发到集群模式以处理故障转移.任何关于如何实现这一点的链接或片段都非常有用.
apache-kafka confluent
我是卡夫卡的初学者.试图将数据从kafka写入hdfs.在任何地方都没有记录如何使用Confluent的kafka-connect-hdfs Java API.任何链接或代码段都会对我有所帮助.提前致谢.
apache-kafka ×2
confluent ×2