Merge branch 'master' of http://git.homecommunity.cn/supervip/MicroCommunity

java110

2021-09-01 bdc870fab7c09b420079257fb05e3e08a5436ff9

 java110-core/src/main/java/com/java110/core/kafka/KafkaConsumerConfig.java

@@ -34,6 +34,8 @@
    private String autoOffsetReset;
    @Value("${kafka.consumer.concurrency}")
    private int concurrency;
    @Value("${kafka.consumer.topic}")
    public String topic;
    @Bean
    public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<String, String>();
@@ -61,4 +63,11 @@
        return propsMap;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }
}