Kafka ByteArray

Question

私はカフカを使ってプロデュースを送り、メッセージを消費しています。

プロデューサーは<String, ByteArray>プロデューサーで作業しています。

私は以下のコードを使用していますが（例ではありますが）、各レコードはちょうど8バイト（コードの下のサンプル出力）になっています。

消費者が単純にバイト配列としてメッセージ全体を取る方法はありますか？

コード：のSystem.outの

props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); 
props.put("value.deserializer", "org.apache.kafka.common.serialization.ByteArrayDeserializer"); 
KafkaConsumer<String, byte[]> consumer = new KafkaConsumer<String, byte[]>(props); 

consumer.subscribe(Arrays.asList(topic)); 
int i = 0; 

while (true) { 
    ConsumerRecords<String, byte[]> records = consumer.poll(100); 
    for (ConsumerRecord<String, byte[]> record : records) 
     System.out.printf("offset = %d, key = %s, value = %s\n", record.offset(), record.key(), record.value()); 
} 

出力：

offset = 1773133, key = 105906453, value = [B@b8eff39 
offset = 1773134, key = 105906453, value = [B@7bb1504 
offset = 1773135, key = 105906453, value = [B@67b6c728 
offset = 1773136, key = 105906453, value = [B@60b1f9c5 
offset = 1773137, key = 105906177, value = [B@1cbab5dd 
offset = 1773138, key = 105906177, value = [B@4376907b 
offset = 1773139, key = 105906177, value = [B@122880ba 
offset = 1773140, key = 105906177, value = [B@7db82ceb 
offset = 1773141, key = 105906177, value = [B@34657adc 

私は信じているように、メッセージを再作成するために、これらのレコードの負荷を組み立てるためになることを楽しみにしていませんよ私は何かが欠けているし、マニュアルの組み立てがエラーを起こしやすいかもしれません。

Answer 1

私はあなたが

System.out.printf("offset = %d, key = %s, value = %s\n", record.offset(), record.key(), java.util.Arrays.toString(record.value())); 

ではなく、（あなたの代わりに、実際のコンテンツのゴミを与える）平野array.toStringに応じて使うべきだと思います。配列はおそらく正しく来ている、あなたはちょうど間違った方法でそれをデバッグします。