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

使用java实现两个Kerberos kafka集群之间的消息同步,需要加载: System.setProperty("java.security.krb5.} Y Bconf", KRB5_CONFIG); System.setProperty("java.sei u D V $ icurity.auth.login.config", KAFKA_JAAS_CONF); 而生产者和消费者API的系统环境属于不同集群环境,在& a X 9 S h l同一个jar程序中会造成系统配置. K ( ` 6加载冲突。 请问,有没O + 3 6 $ 6 %有好的解决方式?

已解决方案: 将cons7 z :umer和producer分离: 消费者程+ ` E y 6 ^ R [ [序先获取源topic数据通过CloseableHttpClient发送端口; 生产者程序在获取端口程序生产到目标topic。

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