修改kafka 消息主题

src/main/java/com/yihu/quota/kafka/ConsumerListener.java

@@ -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());

src/main/java/com/yihu/quota/kafka/KafkaConsumerConfig.java

@@ -23,7 +23,7 @@ public class KafkaConsumerConfig {
    @Value("${kafka.broker.address}")
    private String kafkaBrokerAddress;
    private static String GROUP_ID = "test";
    private static String GROUP_ID = "sep-hbase-data";
    /* --------------producer configuration-----------------**/
    @Bean