Commit 284e8ecd authored by 宋新宇's avatar 宋新宇

短剧APP归因

parent 82ce30d3
...@@ -34,7 +34,7 @@ public class DyVideoActiveKafkaConsumerConfig { ...@@ -34,7 +34,7 @@ public class DyVideoActiveKafkaConsumerConfig {
@Value("${spring.kafka2.consumer.auto-offset-reset}") @Value("${spring.kafka2.consumer.auto-offset-reset}")
private String autoOffsetReset; private String autoOffsetReset;
@Value("${system.consumer.novel.active.group_id}") @Value("${system.consumer.dyvideo.active.group_id}")
private String groupId; private String groupId;
@Value("${spring.kafka2.consumer.max-poll-records}") @Value("${spring.kafka2.consumer.max-poll-records}")
......
...@@ -33,7 +33,7 @@ public class DyVideoBehavoirKafkaConsumerConfig { ...@@ -33,7 +33,7 @@ public class DyVideoBehavoirKafkaConsumerConfig {
@Value("${spring.kafka2.consumer.auto-offset-reset}") @Value("${spring.kafka2.consumer.auto-offset-reset}")
private String autoOffsetReset; private String autoOffsetReset;
@Value("${system.consumer.novel.active.group_id}") @Value("${system.consumer.dyvideo.behavoir.group_id}")
private String groupId; private String groupId;
@Value("${spring.kafka2.consumer.max-poll-records}") @Value("${spring.kafka2.consumer.max-poll-records}")
......
...@@ -33,7 +33,7 @@ public class VideoAppActiveKafkaConsumerConfig { ...@@ -33,7 +33,7 @@ public class VideoAppActiveKafkaConsumerConfig {
@Value("${spring.kafka2.consumer.auto-offset-reset}") @Value("${spring.kafka2.consumer.auto-offset-reset}")
private String autoOffsetReset; private String autoOffsetReset;
@Value("${system.consumer.novel.active.group_id}") @Value("${system.consumer.videoapp.active.group_id}")
private String groupId; private String groupId;
@Value("${spring.kafka2.consumer.max-poll-records}") @Value("${spring.kafka2.consumer.max-poll-records}")
......
...@@ -34,7 +34,7 @@ public class VideoAppBehavoirKafkaConsumerConfig { ...@@ -34,7 +34,7 @@ public class VideoAppBehavoirKafkaConsumerConfig {
@Value("${spring.kafka2.consumer.auto-offset-reset}") @Value("${spring.kafka2.consumer.auto-offset-reset}")
private String autoOffsetReset; private String autoOffsetReset;
@Value("${system.consumer.novel.active.group_id}") @Value("${system.consumer.videoapp.behavoir.group_id}")
private String groupId; private String groupId;
@Value("${spring.kafka2.consumer.max-poll-records}") @Value("${spring.kafka2.consumer.max-poll-records}")
......
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