|
Change Variable Type consumerMap : Map<String,List<KafkaStream<K,V>>> to consumerMap : Map<String,List<KafkaStream<byte[],byte[]>>> in method public start() : void in class org.apache.ignite.stream.kafka.KafkaStreamer |
From |
To |
|
Change Variable Type streams : List<KafkaStream<K,V>> to streams : List<KafkaStream<byte[],byte[]>> in method public start() : void in class org.apache.ignite.stream.kafka.KafkaStreamer |
From |
To |
|
Change Variable Type kafkaStmr : KafkaStreamer<String,String,String> to kafkaStmr : KafkaStreamer<String,String> in method private consumerStream(topic String, keyValMap Map<String,String>) : void in class org.apache.ignite.stream.kafka.KafkaIgniteStreamerSelfTest |
From |
To |
|
Change Variable Type it : ConsumerIterator<K,V> to it : ConsumerIterator<byte[],byte[]> in method public run() : void in class org.apache.ignite.stream.kafka.KafkaStreamer.start.submit |
From |
To |
|
Change Variable Type stream : KafkaStream<K,V> to stream : KafkaStream<byte[],byte[]> in method public start() : void in class org.apache.ignite.stream.kafka.KafkaStreamer |
From |
To |