|
@ -9,7 +9,7 @@ import org.springframework.kafka.annotation.KafkaListener;
|
|
|
*/
|
|
|
public class ConsumerListener {
|
|
|
|
|
|
@KafkaListener(topics = "test")
|
|
|
@KafkaListener(topics = "sep-hbase-data")
|
|
|
public void loadData(ConsumerRecord<?, ?> record) {
|
|
|
|
|
|
System.out.println("-- " + record.key() + " - " + record.value());
|