yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-08-27 18:45:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(platform): fix kafka env name for MCL_timeseries (#3198)

Browse Source
This commit is contained in:
Dexter Lee 2021-09-03 15:15:35 -07:00 committed by GitHub
parent a6aedf6492
commit d1c66167fa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
metadata-ingestion-examples/common/src/main/java/com/linkedin/metadata/examples/configs/TopicConventionFactory.java
View File

@ -30,10 +30,10 @@ public class TopicConventionFactory {
private String metadataChangeProposalName;
@Value("${METADATA_CHANGE_LOG_VERSIONED_TOPIC_NAME:" + Topics.METADATA_CHANGE_LOG_VERSIONED + "}")
private String metadataChangeLogName;
private String metadataChangeLogVersionedTopicName;
@Value("${METADATA_CHANGE_LOG_LIMITED_TOPIC_NAME:" + Topics.METADATA_CHANGE_LOG_TIMESERIES + "}")
private String metadataChangeLogLimitedName;
@Value("${METADATA_CHANGE_LOG_TIMESERIES_TOPIC_NAME:" + Topics.METADATA_CHANGE_LOG_TIMESERIES + "}")
private String metadataChangeLogTimeseriesTopicName;
@Value("${FAILED_METADATA_CHANGE_PROPOSAL_TOPIC_NAME:" + Topics.FAILED_METADATA_CHANGE_PROPOSAL + "}")
private String failedMetadataChangeProposalName;
@ -41,7 +41,7 @@ public class TopicConventionFactory {
@Bean(name = TOPIC_CONVENTION_BEAN)
protected TopicConvention createInstance() {
return new TopicConventionImpl(metadataChangeEventName, metadataAuditEventName, failedMetadataChangeEventName,
metadataChangeProposalName, metadataChangeLogName, metadataChangeLogLimitedName,
metadataChangeProposalName, metadataChangeLogVersionedTopicName, metadataChangeLogTimeseriesTopicName,
failedMetadataChangeProposalName,
// TODO once we start rolling out v5 add support for changing the new event names.
TopicConventionImpl.DEFAULT_EVENT_PATTERN);

8
metadata-service/factories/src/main/java/com/linkedin/gms/factory/common/TopicConventionFactory.java
View File

@ -30,10 +30,10 @@ public class TopicConventionFactory {
private String metadataChangeProposalName;
@Value("${METADATA_CHANGE_LOG_VERSIONED_TOPIC_NAME:" + Topics.METADATA_CHANGE_LOG_VERSIONED + "}")
private String metadataChangeLogName;
private String metadataChangeLogVersionedTopicName;
@Value("${METADATA_CHANGE_LOG_LIMITED_TOPIC_NAME:" + Topics.METADATA_CHANGE_LOG_TIMESERIES + "}")
private String metadataChangeLogLimitedName;
@Value("${METADATA_CHANGE_LOG_TIMESERIES_TOPIC_NAME:" + Topics.METADATA_CHANGE_LOG_TIMESERIES + "}")
private String metadataChangeLogTimeseriesTopicName;
@Value("${FAILED_METADATA_CHANGE_PROPOSAL_TOPIC_NAME:" + Topics.FAILED_METADATA_CHANGE_PROPOSAL + "}")
private String failedMetadataChangeProposalName;
@ -41,7 +41,7 @@ public class TopicConventionFactory {
@Bean(name = TOPIC_CONVENTION_BEAN)
protected TopicConvention createInstance() {
return new TopicConventionImpl(metadataChangeEventName, metadataAuditEventName, failedMetadataChangeEventName,
metadataChangeProposalName, metadataChangeLogName, metadataChangeLogLimitedName,
metadataChangeProposalName, metadataChangeLogVersionedTopicName, metadataChangeLogTimeseriesTopicName,
failedMetadataChangeProposalName,
// TODO once we start rolling out v5 add support for changing the new event names.
TopicConventionImpl.DEFAULT_EVENT_PATTERN);