kirshiyin89

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.kafka</groupId>
			<artifactId>spring-kafka</artifactId>
		</dependency>

		<dependency>

kirshiyin89

@Configuration
public class KafkaConsumerConfiguration {
    
    @Bean
    ConcurrentKafkaListenerContainerFactory<String, String> kafkaBlockingRetryContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory);
        factory.setCommonErrorHandler(new DefaultErrorHandler(
                new DeadLetterPublishingRecoverer(template), new FixedBackOff(5000, 3))
        );

kirshiyin89

[
   {
      "id":"1",
      "serviceName":"SERVICE1",
      "serviceCase":"TEST1",
      "serviceClient":null
   },
   {
      "id":"12",
      "serviceName":"SERVICE12",

kirshiyin89

{
   "status":"UP",
   "components":{
      "db":{
         "status":"UP",
         "details":{
            "database":"H2",
            "validationQuery":"isValid()"
         }
      },

kirshiyin89

@Component
public class InventoryChecker implements HealthIndicator {

    private final BookRepository bookRepository;
    private static final int MIN_AMOUNT = 10;

    public InventoryChecker(BookRepository bookRepository) {
        this.bookRepository = bookRepository;
    }

kirshiyin89

public interface BookRepository extends JpaRepository<Book, Long> {

}

kirshiyin89

@Entity
@Table(name = "Book")
@Getter
public class Book {

    @Id
    private Long id;

    private String name;

kirshiyin89

spring:
  application:
    name: monitoring-demo
  datasource:
    driverClassName: org.h2.Driver
    url: jdbc:h2:mem:testdb
    username: sa
    password: pass
  jpa:
    database-platform: org.hibernate.dialect.H2Dialect

kirshiyin89

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-actuator</artifactId>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>

kirshiyin89

package com.univocity.demo.rest;

import com.univocity.demo.dto.CsvData;
import com.univocity.demo.service.CsvDataService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;