4
byte[]
形式のカフカからデータを読み取るにはどうすればよいですか?Apache Flink:カフカのデータをバイト配列として読み取る
SimpleStringSchema()
でイベントを読み取る実装がありますが、データを読み取るスキーマがbyte[]
で見つかりませんでした。ここで
は私のコードです:
Properties properties = new Properties();
properties.setProperty("bootstrap.servers", "kafka1:9092");
properties.setProperty("zookeeper.connect", "zookeeper1:2181");
properties.setProperty("group.id", "test");
properties.setProperty("key.deserializer","org.apache.kafka.common.serialization.StringDeserializer");
properties.setProperty("value.deserializer", "org.apache.kafka.common.serialization.ByteArrayDeserializer");
properties.setProperty("auto.offset.reset", "earliest");
DataStream<byte[]> stream = env
.addSource(new FlinkKafkaConsumer010<byte[]>("testStr", ? ,properties));