iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[BAEL-7199] Override bootstrap servers property (#15708)

This commit is contained in:
Constantin 2024-02-21 00:14:38 +02:00 committed by GitHub
parent f29936791c
commit 6328bf349e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
spring-kafka-2/src/main/resources/application.properties
View File

@ -1,4 +1,4 @@
spring.kafka.bootstrap-servers=localhost:9092,localhost:9093,localhost:9094,localhost:9095
spring.kafka.bootstrap-servers=localhost:9092,localhost:9093,localhost:9094
message.topic.name=baeldung
long.message.topic.name=longMessage
greeting.topic.name=greeting

3
spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaDltIntegrationTest.java
View File

@ -26,7 +26,8 @@ import com.baeldung.spring.kafka.dlt.listener.PaymentListenerDltRetryOnError;
import com.baeldung.spring.kafka.dlt.listener.PaymentListenerNoDlt;
import org.springframework.test.context.ActiveProfiles;
@SpringBootTest(classes = KafkaDltApplication.class)
@SpringBootTest(classes = KafkaDltApplication.class,
properties = "spring.kafka.bootstrap-servers=localhost:9095")
@EmbeddedKafka(
partitions = 1,
brokerProperties = { "listeners=PLAINTEXT://localhost:9095", "port=9095" },

3
spring-kafka-2/src/test/java/com/baeldung/spring/kafka/multipletopics/KafkaMultipleTopicsIntegrationTest.java
View File

@ -21,7 +21,8 @@ import org.springframework.kafka.test.context.EmbeddedKafka;
import org.springframework.kafka.test.utils.ContainerTestUtils;
import org.springframework.test.context.ActiveProfiles;
@SpringBootTest(classes = KafkaMultipleTopicsApplication.class)
@SpringBootTest(classes = KafkaMultipleTopicsApplication.class,
properties = "spring.kafka.bootstrap-servers=localhost:9099")
@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:9099", "port=9099" })
@ActiveProfiles("multipletopics")
public class KafkaMultipleTopicsIntegrationTest {