两个授权型 Kafka集群数据同步问题-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

两个授权型 Kafka集群数据同步问题

1263847017820869 2020-09-02 18:31:03 514

使用java实现两个Kerberos kafka集群之间的消息同步,需要加载: System.setProperty("java.security.krb5.conf", KRB5_CONFIG); System.setProperty("java.security.auth.login.config", KAFKA_JAAS_CONF); 而生产者和消费者API的系统环境属于不同集群环境,在同一个jar程序中会造成系统配置加载冲突。 请问,有没有好的解决方式?

已解决方案: 将consumer和producer分离: 消费者程序先获取源topic数据通过CloseableHttpClient发送端口; 生产者程序在获取端口程序生产到目标topic。

缺点:这种方案需要维护两套程序,是code 维护冗余; 如果网络波动,会导致数据丢失。

消息中间件 Java Kafka API
分享到
取消 提交回答
全部回答(0)
阿里巴巴大数据计算
使用钉钉扫一扫加入圈子
+ 订阅

阿里大数据官方技术圈

推荐文章
相似问题
链接