Skip to content

Commit 1f8bb90

Browse files
authored
JAVA-39227 Moving some article links on Github spring-kafka (#17585)
1 parent 5935b56 commit 1f8bb90

63 files changed

Lines changed: 137 additions & 142 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

spring-kafka-2/README.md

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,7 @@ This module contains articles about Spring with Kafka
55
### Relevant articles
66

77
- [Spring Kafka: Configure Multiple Listeners on Same Topic](https://www.baeldung.com/spring-kafka-multiple-listeners-same-topic)
8-
- [Understanding Kafka Topics and Partitions](https://www.baeldung.com/kafka-topics-partitions)
98
- [How to Subscribe a Kafka Consumer to Multiple Topics](https://www.baeldung.com/kafka-subscribe-consumer-multiple-topics)
109
- [Splitting Streams in Kafka](https://www.baeldung.com/kafka-splitting-streams)
1110
- [Manage Kafka Consumer Groups](https://www.baeldung.com/kafka-manage-consumer-groups)
12-
- [Dead Letter Queue for Kafka With Spring](https://www.baeldung.com/kafka-spring-dead-letter-queue)
13-
- [Configuring Kafka SSL Using Spring Boot](https://www.baeldung.com/spring-boot-kafka-ssl)
11+
- [Monitor the Consumer Lag in Apache Kafka](https://www.baeldung.com/java-kafka-consumer-lag)

spring-kafka-2/pom.xml

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,14 @@
6565
<artifactId>awaitility</artifactId>
6666
<scope>test</scope>
6767
</dependency>
68+
<dependency>
69+
<groupId>io.micrometer</groupId>
70+
<artifactId>micrometer-registry-prometheus</artifactId>
71+
</dependency>
72+
<dependency>
73+
<groupId>org.springframework.boot</groupId>
74+
<artifactId>spring-boot-starter-actuator</artifactId>
75+
</dependency>
6876
</dependencies>
6977

7078
<properties>

spring-kafka/src/main/java/com/baeldung/monitoring/LagAnalyzerApplication.java renamed to spring-kafka-2/src/main/java/com/baeldung/spring/kafka/monitoring/LagAnalyzerApplication.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.baeldung.monitoring;
1+
package com.baeldung.spring.kafka.monitoring;
22

33
import org.springframework.boot.SpringApplication;
44
import org.springframework.boot.autoconfigure.SpringBootApplication;

spring-kafka/src/main/java/com/baeldung/monitoring/Makefile renamed to spring-kafka-2/src/main/java/com/baeldung/spring/kafka/monitoring/Makefile

File renamed without changes.

spring-kafka/src/main/java/com/baeldung/monitoring/README.md renamed to spring-kafka-2/src/main/java/com/baeldung/spring/kafka/monitoring/README.md

File renamed without changes.

spring-kafka/src/main/java/com/baeldung/monitoring/docker-compose.yml renamed to spring-kafka-2/src/main/java/com/baeldung/spring/kafka/monitoring/docker-compose.yml

File renamed without changes.

spring-kafka/src/main/java/com/baeldung/monitoring/service/LagAnalyzerService.java renamed to spring-kafka-2/src/main/java/com/baeldung/spring/kafka/monitoring/service/LagAnalyzerService.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
1-
package com.baeldung.monitoring.service;
2-
3-
import com.baeldung.monitoring.util.MonitoringUtil;
1+
package com.baeldung.spring.kafka.monitoring.service;
42

3+
import com.baeldung.spring.kafka.monitoring.util.MonitoringUtil;
54
import org.apache.kafka.clients.admin.AdminClient;
65
import org.apache.kafka.clients.admin.AdminClientConfig;
76
import org.apache.kafka.clients.admin.ListConsumerGroupOffsetsResult;

spring-kafka/src/main/java/com/baeldung/monitoring/service/LiveLagAnalyzerService.java renamed to spring-kafka-2/src/main/java/com/baeldung/spring/kafka/monitoring/service/LiveLagAnalyzerService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.baeldung.monitoring.service;
1+
package com.baeldung.spring.kafka.monitoring.service;
22

33
import org.springframework.beans.factory.annotation.Autowired;
44
import org.springframework.beans.factory.annotation.Value;

spring-kafka/src/main/java/com/baeldung/monitoring/simulation/ConsumerSimulator.java renamed to spring-kafka-2/src/main/java/com/baeldung/spring/kafka/monitoring/simulation/ConsumerSimulator.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
1-
package com.baeldung.monitoring.simulation;
1+
package com.baeldung.spring.kafka.monitoring.simulation;
22

3-
import org.springframework.context.annotation.PropertySource;
43
import org.springframework.kafka.annotation.KafkaListener;
54
import org.springframework.stereotype.Service;
65

spring-kafka/src/main/java/com/baeldung/monitoring/simulation/KafkaConsumerConfig.java renamed to spring-kafka-2/src/main/java/com/baeldung/spring/kafka/monitoring/simulation/KafkaConsumerConfig.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
1-
package com.baeldung.monitoring.simulation;
1+
package com.baeldung.spring.kafka.monitoring.simulation;
22

3+
import io.micrometer.core.instrument.MeterRegistry;
34
import org.apache.kafka.clients.consumer.ConsumerConfig;
45
import org.apache.kafka.common.serialization.StringDeserializer;
56
import org.springframework.beans.factory.annotation.Autowired;
@@ -16,8 +17,6 @@
1617
import java.util.HashMap;
1718
import java.util.Map;
1819

19-
import io.micrometer.core.instrument.MeterRegistry;
20-
2120
@EnableKafka
2221
@Component
2322
public class KafkaConsumerConfig {

0 commit comments

Comments
 (0)