Commit 2a7851f8 authored by 宋新宇's avatar 宋新宇

Merge branch '8-抖小更改' into 'release_20240411'

kafka

See merge request !51
parents dc595ecf ff87c8e5
...@@ -25,19 +25,19 @@ import java.util.Map; ...@@ -25,19 +25,19 @@ import java.util.Map;
@EnableKafka @EnableKafka
public class VideoAppBehavoirKafkaConsumerConfig { public class VideoAppBehavoirKafkaConsumerConfig {
@Value("${spring.kafka2.bootstrap-servers}") @Value("${spring.kafka.bootstrap-servers}")
private String servers; private String servers;
@Value("${spring.kafka2.consumer.enable-auto-commit}") @Value("${spring.kafka.consumer.enable-auto-commit}")
private boolean enableAutoCommit; private boolean enableAutoCommit;
@Value("${spring.kafka2.consumer.auto-offset-reset}") @Value("${spring.kafka.consumer.auto-offset-reset}")
private String autoOffsetReset; private String autoOffsetReset;
@Value("${system.consumer.videoapp.behavoir.group_id}") @Value("${system.consumer.videoapp.behavoir.group_id}")
private String groupId; private String groupId;
@Value("${spring.kafka2.consumer.max-poll-records}") @Value("${spring.kafka.consumer.max-poll-records}")
private int maxPollRecordsConfig; private int maxPollRecordsConfig;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment