yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-12-28 10:28:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(datahub-client): Fix kafka config issue (#5403)

Browse Source
This commit is contained in:
Mugdha Hardikar 2022-07-15 15:38:00 +05:30 committed by GitHub
parent 2c48329810
commit 369c65522c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
metadata-integration/java/datahub-client/src/main/java/datahub/client/kafka/KafkaEmitterConfig.java
View File

@ -22,10 +22,12 @@ public class KafkaEmitterConfig {
private final String bootstrap = "localhost:9092";
@Builder.Default
private final String schemaRegistryUrl = "http://localhost:8081";
@Builder.Default
private final Map<String, String> schemaRegistryConfig = Collections.emptyMap();
@Builder.Default
private final Map<String, String> producerConfig = Collections.emptyMap();
@Builder.Default
private final EventFormatter eventFormatter = new EventFormatter(EventFormatter.Format.PEGASUS_JSON);