JAVA-32103 Move spring-boot-kafka-ssl article to spring-kafka-2 (#16178)
This commit is contained in:
parent
663d1831da
commit
74cd524de2
|
@ -10,3 +10,4 @@ This module contains articles about Spring with Kafka
|
||||||
- [Splitting Streams in Kafka](https://www.baeldung.com/kafka-splitting-streams)
|
- [Splitting Streams in Kafka](https://www.baeldung.com/kafka-splitting-streams)
|
||||||
- [Manage Kafka Consumer Groups](https://www.baeldung.com/kafka-manage-consumer-groups)
|
- [Manage Kafka Consumer Groups](https://www.baeldung.com/kafka-manage-consumer-groups)
|
||||||
- [Dead Letter Queue for Kafka With Spring](https://www.baeldung.com/kafka-spring-dead-letter-queue)
|
- [Dead Letter Queue for Kafka With Spring](https://www.baeldung.com/kafka-spring-dead-letter-queue)
|
||||||
|
- [Configuring Kafka SSL Using Spring Boot](https://www.baeldung.com/spring-boot-kafka-ssl)
|
||||||
|
|
|
@ -1,12 +1,13 @@
|
||||||
package com.baeldung.kafka.ssl;
|
package com.baeldung.spring.kafka.ssl;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.apache.kafka.clients.consumer.ConsumerRecord;
|
import org.apache.kafka.clients.consumer.ConsumerRecord;
|
||||||
import org.springframework.kafka.annotation.KafkaListener;
|
import org.springframework.kafka.annotation.KafkaListener;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@Component
|
@Component
|
||||||
@Slf4j
|
@Slf4j
|
|
@ -1,9 +1,10 @@
|
||||||
package com.baeldung.kafka.ssl;
|
package com.baeldung.spring.kafka.ssl;
|
||||||
|
|
||||||
|
import org.springframework.kafka.core.KafkaTemplate;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
import lombok.AllArgsConstructor;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.kafka.core.KafkaTemplate;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
@Slf4j
|
@Slf4j
|
||||||
@AllArgsConstructor
|
@AllArgsConstructor
|
|
@ -1,7 +1,6 @@
|
||||||
package com.baeldung.kafka.ssl;
|
package com.baeldung.spring.kafka.ssl;
|
||||||
|
|
||||||
import org.springframework.boot.SpringApplication;
|
import org.springframework.boot.SpringApplication;
|
||||||
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
|
|
||||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||||
|
|
||||||
@SpringBootApplication
|
@SpringBootApplication
|
|
@ -1,6 +1,13 @@
|
||||||
package com.baeldung.kafka.ssl;
|
package com.baeldung.spring.kafka.ssl;
|
||||||
|
|
||||||
|
import static com.baeldung.spring.kafka.ssl.KafkaConsumer.TOPIC;
|
||||||
|
import static org.assertj.core.api.Assertions.assertThat;
|
||||||
|
import static org.awaitility.Awaitility.await;
|
||||||
|
|
||||||
|
import java.io.File;
|
||||||
|
import java.time.Duration;
|
||||||
|
import java.util.UUID;
|
||||||
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.junit.jupiter.api.Test;
|
import org.junit.jupiter.api.Test;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.boot.test.context.SpringBootTest;
|
import org.springframework.boot.test.context.SpringBootTest;
|
||||||
|
@ -10,13 +17,7 @@ import org.testcontainers.containers.wait.strategy.Wait;
|
||||||
import org.testcontainers.junit.jupiter.Container;
|
import org.testcontainers.junit.jupiter.Container;
|
||||||
import org.testcontainers.junit.jupiter.Testcontainers;
|
import org.testcontainers.junit.jupiter.Testcontainers;
|
||||||
|
|
||||||
import java.io.File;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import java.time.Duration;
|
|
||||||
import java.util.UUID;
|
|
||||||
|
|
||||||
import static com.baeldung.kafka.ssl.KafkaConsumer.TOPIC;
|
|
||||||
import static org.assertj.core.api.Assertions.assertThat;
|
|
||||||
import static org.awaitility.Awaitility.await;
|
|
||||||
|
|
||||||
@Slf4j
|
@Slf4j
|
||||||
@ActiveProfiles("ssl")
|
@ActiveProfiles("ssl")
|
|
@ -8,7 +8,6 @@ This module contains articles about Spring with Kafka
|
||||||
- [Testing Kafka and Spring Boot](https://www.baeldung.com/spring-boot-kafka-testing)
|
- [Testing Kafka and Spring Boot](https://www.baeldung.com/spring-boot-kafka-testing)
|
||||||
- [Monitor the Consumer Lag in Apache Kafka](https://www.baeldung.com/java-kafka-consumer-lag)
|
- [Monitor the Consumer Lag in Apache Kafka](https://www.baeldung.com/java-kafka-consumer-lag)
|
||||||
- [Send Large Messages With Kafka](https://www.baeldung.com/java-kafka-send-large-message)
|
- [Send Large Messages With Kafka](https://www.baeldung.com/java-kafka-send-large-message)
|
||||||
- [Configuring Kafka SSL Using Spring Boot](https://www.baeldung.com/spring-boot-kafka-ssl)
|
|
||||||
- [Kafka Streams With Spring Boot](https://www.baeldung.com/spring-boot-kafka-streams)
|
- [Kafka Streams With Spring Boot](https://www.baeldung.com/spring-boot-kafka-streams)
|
||||||
- [Get the Number of Messages in an Apache Kafka Topic](https://www.baeldung.com/java-kafka-count-topic-messages)
|
- [Get the Number of Messages in an Apache Kafka Topic](https://www.baeldung.com/java-kafka-count-topic-messages)
|
||||||
- [Sending Data to a Specific Partition in Kafka](https://www.baeldung.com/kafka-send-data-partition)
|
- [Sending Data to a Specific Partition in Kafka](https://www.baeldung.com/kafka-send-data-partition)
|
||||||
|
|
Loading…
Reference in New Issue