{"id":330860,"date":"2022-03-20T21:00:06","date_gmt":"2022-03-20T21:00:06","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=330860"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=330860","title":{"rendered":"\u0421\u043e\u0437\u0434\u0430\u043d\u0438\u0435 \u0442\u0435\u043b\u0435\u0433\u0440\u0430\u043c-\u0431\u043e\u0442\u0430 (Spring Boot, Kafka, PostgreSQL), \u0447\u0430\u0441\u0442\u044c \u0432\u0442\u043e\u0440\u0430\u044f<\/span>"},"content":{"rendered":"
<\/div>\n
\n
\n
\n
\n
<\/p>\n
\u0418\u0432\u0430\u043d\u043e\u0432 \u041c\u0430\u043a\u0441\u0438\u043c<\/h5>\n

\u041c\u043b\u0430\u0434\u0448\u0438\u0439 Java \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0438\u0441\u0442<\/p>\n<\/div>\n

\u0420\u0435\u0446\u0435\u043f\u0442 \u043b\u0435\u0433\u043a\u043e\u0433\u043e \u043f\u0435\u0440\u0435\u043a\u0443\u0441\u0430 \u0434\u043b\u044f \u00abTelegram — \u043c\u043e\u043d\u0441\u0442\u0440\u0430 \u0424\u0440\u0430\u043d\u043a\u0435\u043d\u0448\u0442\u0435\u0439\u043d\u0430\u00bb<\/strong><\/p>\n

\"\u041d\u0438\u0447\u0442\u043e
\u041d\u0438\u0447\u0442\u043e \u043d\u0435 \u0432\u044b\u0437\u044b\u0432\u0430\u0435\u0442 \u0443 \u043d\u0430\u0441 \u0441\u0442\u043e\u043b\u044c \u043c\u0443\u0447\u0438\u0442\u0435\u043b\u044c\u043d\u044b\u0445 \u0441\u0442\u0440\u0430\u0434\u0430\u043d\u0438\u0439, \u043a\u0430\u043a \u0440\u0435\u0437\u043a\u0430\u044f \u0438 \u0432\u043d\u0435\u0437\u0430\u043f\u043d\u0430\u044f \u043f\u0435\u0440\u0435\u043c\u0435\u043d\u0430.- \u00ab\u0424\u0440\u0430\u043d\u043a\u0435\u043d\u0448\u0442\u0435\u0439\u043d\u00bb \u041c\u044d\u0440\u0438 \u0428\u0435\u043b\u043b\u0438<\/figcaption><\/figure>\n

\u0412\u0441\u0435\u043c \u043f\u0440\u0438\u0432\u0435\u0442, \u044d\u0442\u043e \u0432\u0442\u043e\u0440\u0430\u044f \u0447\u0430\u0441\u0442\u044c \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u044f \u0442\u0435\u043b\u0435\u0433\u0440\u0430\u043c-\u0431\u043e\u0442\u0430 (\u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043f\u0435\u0440\u0432\u0443\u044e \u0447\u0430\u0441\u0442\u044c<\/a>), \u0432 \u043d\u0435\u0439 \u043c\u044b \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u043c Kafka Consumer, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0431\u0443\u0434\u0435\u0442 \u043b\u043e\u0432\u0438\u0442\u044c \u043b\u044e\u0431\u044b\u0435 \u043a\u043e\u043b\u0435\u0431\u0430\u043d\u0438\u044f \u0432 \u0441\u0438\u043b\u0435 \u0438 \u0432\u044b\u0434\u0430\u0432\u0430\u0442\u044c \u043d\u0430\u043c \u0432\u0441\u044e \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044e \u043e \u0434\u0435\u0439\u0441\u0442\u0432\u0438\u044f\u0445 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f.<\/p>\n

\u0418\u043d\u0433\u0440\u0435\u0434\u0438\u0435\u043d\u0442\u044b:<\/h3>\n
    \n
  1. \n

    \u0420\u0435\u0433\u0438\u0441\u0442\u0440\u0430\u0446\u0438\u044f \u0431\u043e\u0442\u0430<\/a><\/p>\n<\/li>\n

  2. \n

    \u0421\u043e\u0437\u0434\u0430\u043d\u0438\u0435 Spring Boot \u043f\u0440\u043e\u0435\u043a\u0442, \u043f\u0440\u043e\u0449\u0435 \u0432\u0441\u0435\u0433\u043e \u044d\u0442\u043e \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0447\u0435\u0440\u0435\u0437 Spring Initializr<\/a>. (\u0432 \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u0441\u0438\u0441\u0442\u0435\u043c\u044b \u0441\u0431\u043e\u0440\u043a\u0438 \u0431\u0443\u0434\u0435\u0442 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c\u0441\u044f Gradle<\/a>)<\/p>\n<\/li>\n

  3. \n

    Kafka<\/a> (\u0434\u043b\u044f \u043e\u0442\u0441\u043b\u0435\u0436\u0438\u0432\u0430\u043d\u0438\u044f \u0442\u043e\u043f\u0438\u043a\u043e\u0432 \u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e Conductor<\/a>)<\/p>\n<\/li>\n

  4. \n

    PostgreSQL<\/a> (\u0434\u043b\u044f \u043a\u043e\u043c\u0444\u043e\u0440\u0442\u043d\u043e\u0439 \u0440\u0430\u0431\u043e\u0442\u044b \u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e DBeaver<\/a>)<\/p>\n<\/li>\n<\/ol>\n

    \n\u0415\u0441\u043b\u0438 \u0432\u043e\u0437\u043d\u0438\u043a\u043d\u0443\u0442 \u0441\u043b\u043e\u0436\u043d\u043e\u0441\u0442\u0438 \u0441 \u0432\u043e\u0441\u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0435\u043c \u0442\u0443\u0442\u043e\u0440\u0438\u0430\u043b\u0430<\/summary>\n
    \n

    \u041f\u0440\u043e\u0448\u0443 \u043f\u0438\u0448\u0438\u0442\u0435 \u0432 \u043a\u043e\u043c\u043c\u0435\u043d\u0442\u0430\u0440\u0438\u044f\u0445 \u0432\u043e\u0437\u043d\u0438\u043a\u0448\u0438\u0435 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u044b, \u043d\u0430 \u0432\u0441\u044f\u043a\u0438\u0439 \u0441\u043b\u0443\u0447\u0430\u0439 — \u0432\u043e\u0442 \u043c\u043e\u0439 git<\/a> \u0438 \u0422\u0413<\/a><\/p>\n<\/div>\n<\/details>\n

    \u041d\u0430\u0447\u0438\u043d\u0430\u0435\u043c \u0441 \u044f\u0438\u0447\u043d\u044b\u0445 \u0436\u0435\u043b\u0442\u043a\u043e\u0432:<\/h4>\n

    \u041f\u0435\u0440\u0432\u043e\u0441\u0442\u0435\u043f\u0435\u043d\u043d\u043e \u043d\u0443\u0436\u043d\u043e \u043d\u0430\u0441\u0442\u0440\u043e\u0438\u0442\u044c build.gradle \u0441\u043e \u0432\u0441\u0435\u043c\u0438 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e\u0441\u0442\u044f\u043c\u0438<\/p>\n

    \nbuild.gradle<\/summary>\n
    \n
    plugins { id 'org.springframework.boot' version '2.5.6' id 'io.spring.dependency-management' version '1.0.11.RELEASE' id 'java' }  group = 'com.demo.kafka' version = '0.0.1-SNAPSHOT' sourceCompatibility = '14'  repositories { mavenCentral() }  configurations.all { exclude module: 'slf4j-log4j12' }  dependencies { implementation 'org.springframework.boot:spring-boot-starter-web:2.5.6' implementation 'org.springframework.kafka:spring-kafka:2.7.6'   implementation 'org.projectlombok:lombok:1.18.22' implementation 'org.springframework.boot:spring-boot-starter-jdbc:2.5.6' implementation 'org.springframework.data:spring-data-commons:2.6.0' implementation 'org.postgresql:postgresql:42.3.1' implementation 'com.h2database:h2:1.4.200'  testImplementation 'org.springframework.boot:spring-boot-starter-test:2.5.6' testImplementation 'org.springframework.kafka:spring-kafka-test:2.7.6'  compileOnly 'org.projectlombok:lombok:1.18.22' annotationProcessor 'org.projectlombok:lombok:1.18.22' }  test { useJUnitPlatform() }<\/code><\/pre>\n<\/div>\n<\/details>\n
    \u0414\u0430\u043b\u0435\u0435 \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b Kafka \u043e\u043f\u0438\u0448\u0435\u043c application.yml, \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u043c \u043d\u0430\u0445\u043e\u0434\u044f\u0442\u0441\u044f \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438 \u043d\u0430\u0448\u0435\u0433\u043e kafka consumer<\/p>\n
    \napplication.yml<\/summary>\n
    \n
    server:   port: 9002 spring:   kafka:     consumer:       bootstrap-servers: localhost:9092       group-id: group_id       auto-offset-reset: earliest       key-deserializer: org.apache.kafka.common.serialization.StringDeserializer       value-deserializer: org.apache.kafka.common.serialization.StringDeserializer<\/code><\/pre>\n<\/div>\n<\/details>\n
    \u041d\u0443 \u0438 \u0432 \u043a\u043e\u043d\u0446\u0435 — \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438 application.properties<\/p>\n
    \napplication.properties<\/summary>\n
    \n
    # HTTP port for incoming requests server.port=8080  # Log db app.db.demo.url=jdbc:postgresql:\/\/localhost:5432\/change-me app.db.demo.driver=org.postgresql.Driver app.db.demo.user=change-me app.db.demo.password=change-me app.db.demo.pool-size=10  # kafka-metadata-consumer app.metadata.tag=logs app.metadata.bootstrapServers=athena:9092 app.metadata.groupId=group_id app.metadata.topic=users app.metadata.autoOffsetReset=earliest app.metadata.enableAutoCommit=false app.metadata.maxPollRecords=10 app.metadata.concurrency=4 app.metadata.path=files   # logging logging.level.root=INFO logging.level.org.springframework.web=DEBUG logging.level.ru.centerinform.webhook=TRACE logging.file.name=change-me<\/code><\/pre>\n<\/div>\n<\/details>\n
    \u0425\u043e\u0440\u043e\u0448\u043e, \u0433\u043e\u0432\u043e\u0440\u044f \u043e \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0435 \u043f\u0440\u043e\u0435\u043a\u0442\u0430, \u0442\u043e \u0441\u043e\u0432\u0435\u0442\u0443\u044e \u043f\u0440\u0438\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0442\u044c\u0441\u044f \u0442\u0430\u043a\u043e\u0433\u043e \u0432\u0438\u0434\u0430:<\/p>\n
    \"\u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430
    \u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 \u043f\u0440\u043e\u0435\u043a\u0442\u0430<\/figcaption><\/figure>\n
    \u041f\u0430\u043a\u0435\u0442\u044b:<\/p>\n