カフカコンシューマ用に複数のデシリアライザを使用する

Question

カフカとシリアル化の初心者です。これまでjson形式のカフカイベントをシンプルコードを使ってシリアライズする必要がありました。 Avroエンコーダを使用して余分なイベントが追加されています。だから、私はこの単一の消費者がjsonの場合はStringDeserialzerを使用し、Avroの場合はそれぞれのデシリアライザを使用します。 2つのDeserializerを同じプロパティファイルにマップするにはどうすればよいですか？あなたがラップ両方オリジナルデシリアライザである単一のハイブリッドデシリアライザを提供する必要がメインメソッド

KafkaConsumer<String, String> _consumer = new KafkaConsumer<>(getProps()); 
consumers.add(_consumer); 
_consumer.subscribe(new ArrayList<>(topicConsumer.keySet())); 

Answer 1

で

private Properties getProps(){ 
    Properties props = new Properties(); 
    props.put("group.id", env.getProperty("group.id")); 
    props.put("enable.auto.commit", env.getProperty("enable.auto.commit")); 
    props.put("key.deserializer", env.getProperty("key.deserializer")); 
    props.put("value.deserializer", env.getProperty("value.deserializer")); 
    return props; 
}//here as only value can be mapped to "key.deserializer" is there anyway to do this 

。内部的には、新しいラッピングデシリアライザは、両方のタイプのメッセージを区別し、生のバイトを実際の作業を行う正しいデシリアライザに転送できる必要があります。

あなたが持っているメッセージのタイプを事前に知ることができない場合は、エラーアプローチとして試行することもできます。つまり、デフォルトで1つのシリアライザに渡します。二つ目。