我需要读Kafka主题的加密信息。我当前从主题中读取字符串的代码如下所示:
JavaPairReceiverInputDStream<String, String> pairrdd =
KafkaUtils.createStream(jssc, zkQuorum, group, topicmap);
我应该怎么做才能从kafka队列中更改此代码,以确保读取的字节数组、加密的数据没有损坏
我需要读Kafka主题的加密信息。我当前从主题中读取字符串的代码如下所示:
JavaPairReceiverInputDStream<String, String> pairrdd =
KafkaUtils.createStream(jssc, zkQuorum, group, topicmap);
我应该怎么做才能从kafka队列中更改此代码,以确保读取的字节数组、加密的数据没有损坏
1条答案
按热度按时间qv7cva1a1#
用于读取Kafka在
<byte[], byte[]>
窗体,您可以使用KafkaUtils
. 像这样-我希望这有帮助!