Skip to content

Commit c5004bd

Browse files
committed
2 parents 6585d0d + 060bb54 commit c5004bd

File tree

1 file changed

+7
-4
lines changed

1 file changed

+7
-4
lines changed

server/src/main/java/com/exactpro/blockchain/kafka/KafkaPublisher.java

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,10 +17,13 @@
1717
public class KafkaPublisher {
1818
private static final Logger logger = LogManager.getLogger(KafkaPublisher.class);
1919

20-
@Value("${kafka.bootstrap.servers}")
21-
private String bootstrapServers;
20+
private final String bootstrapServers;
21+
private final KafkaSender<String, String> sender;
2222

23-
private final KafkaSender<String, String> sender = createSender();
23+
public KafkaPublisher(@Value("${kafka.bootstrap.servers}") String bootstrapServers) {
24+
this.bootstrapServers = bootstrapServers;
25+
this.sender = createSender();
26+
}
2427

2528
private KafkaSender<String, String> createSender() {
2629
final Map<String, Object> producerProps = Map.of(
@@ -55,6 +58,6 @@ public Mono<Void> publishMessage(String targetBankBic, String message, String ke
5558
}
5659

5760
public Mono<Void> publishMessage(String topic, String xmlMessage) {
58-
return publishMessage(topic, xmlMessage, null); // Отправляем без ключа
61+
return publishMessage(topic, xmlMessage, null);
5962
}
6063
}

0 commit comments

Comments
 (0)