dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix TbKafkaSettingsTest

Browse Source
This commit is contained in:
ViacheslavKlimov 2024-05-16 14:34:50 +03:00
parent e8d14f37cb
commit 1a264dafa7
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaSettings.java
View File

@ -228,7 +228,7 @@ public class TbKafkaSettings {
return adminClient; return adminClient;
} }
private Properties toAdminProps() { protected Properties toAdminProps() {
Properties props = toProps(); Properties props = toProps();
props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, servers); props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, servers);
props.put(AdminClientConfig.RETRIES_CONFIG, retries); props.put(AdminClientConfig.RETRIES_CONFIG, retries);