FileMood

Download [ DevCourseWeb.com ] Udemy - Event-Driven Microservices - Spring Boot, Kafka and Elastic

DevCourseWeb com Udemy Event Driven Microservices Spring Boot Kafka and Elastic

Name

[ DevCourseWeb.com ] Udemy - Event-Driven Microservices - Spring Boot, Kafka and Elastic

 DOWNLOAD Copy Link

Total Size

4.0 GB

Total Files

3550

Last Seen

2024-07-08 23:37

Hash

2BE218EB1D943B408221CEEE10D62B3590AF3AAD

/

Get Bonus Downloads Here.url

0.2 KB

/1/

001 Introduction to microservices architecture.mp4

233.5 MB

001 Introduction to microservices architecture_en.srt

16.0 KB

002 Project overview & Introduction to Event-driven architecture.mp4

240.7 MB

002 Project overview & Introduction to Event-driven architecture_en.srt

15.1 KB

003 Implementation details for each microservice.mp4

192.6 MB

003 Implementation details for each microservice_en.srt

12.4 KB

32579138-introduction.pptx

69.6 KB

37330710-big-picture-share.pptx

602.9 KB

/10/

001 Introduction to Kafka streams.mp4

10.8 MB

001 Introduction to Kafka streams_en.srt

3.0 KB

002 Kafka streams microservice base project.mp4

17.2 MB

002 Kafka streams microservice base project_en.srt

7.0 KB

003 Completing the Kafka streams microservice.mp4

33.8 MB

003 Completing the Kafka streams microservice_en.srt

13.0 KB

004 Creating an endpoint for Kafka state store.mp4

8.1 MB

004 Creating an endpoint for Kafka state store_en.srt

4.7 KB

005 Calling the Kafka State Store from Query Service.mp4

87.9 MB

005 Calling the Kafka State Store from Query Service_en.srt

15.1 KB

32579282-kafka-streams.pptx

64.2 KB

HELP.md

0.4 KB

README.md

0.4 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

10.1 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

1.0 KB

ElasticQueryWebClientConfigData.java

1.1 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

KafkaStreamsConfigData.java

0.5 KB

KafkaStreamsServiceConfigData.java

0.4 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/10/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/10/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/10/common-util/

common-util.iml

0.7 KB

pom.xml

0.5 KB

/10/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-elastic_query.yml

2.4 KB

config-client-elastic_query_web.yml

1.6 KB

config-client-elastic_query_web_2.yml

1.6 KB

config-client-kafka_streams.yml

1.1 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-reactive_elastic_query.yml

0.8 KB

config-client-reactive_elastic_query_web.yml

0.6 KB

config-client-twitter_to_kafka.yml

1.1 KB

config-client.yml

0.1 KB

/10/config-server/

config-server.iml

8.2 KB

pom.xml

1.9 KB

/10/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/10/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/10/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/10/docker-compose/

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

check-keycloak-server-started.sh

0.5 KB

common.yml

0.1 KB

elastic_cluster.yml

1.8 KB

env

0.3 KB

kafka_cluster.yml

2.7 KB

keycloak_authorization_server.yml

0.5 KB

services.yml

12.6 KB

/.../elastic-query-service-common/

elastic-query-service-common.iml

10.5 KB

pom.xml

1.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/exception/

ElasticQueryServiceException.java

0.4 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/transformer/

ElasticToResponseModelTransformer.java

1.1 KB

/.../elastic-query-service/

elastic-query-service.iml

23.0 KB

pom.xml

3.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

Constants.java

0.1 KB

ElasticQueryServiceApplication.java

0.5 KB

QueryType.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

7.6 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.6 KB

QueryUserService.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

5.8 KB

TwitterQueryUserService.java

1.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebClientConfig.java

2.4 KB

WebSecurityConfig.java

3.7 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/entity/

UserPermission.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/repository/

UserPermissionRepository.java

0.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceAnalyticsResponseModel.java

0.5 KB

ElasticQueryServiceResponseModelV2.java

0.5 KB

ElasticQueryServiceWordCountResponseModel.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/security/

AudienceValidator.java

1.4 KB

PermissionType.java

0.3 KB

QueryServicePermissionEvaluator.java

3.8 KB

TwitterQueryUser.java

1.3 KB

TwitterQueryUserDetailsService.java

1.5 KB

TwitterQueryUserJwtConverter.java

3.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

UserPermissionsToUserDetailTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

init-data.sql

1.8 KB

init-schema.sql

1.6 KB

logback.xml

0.2 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client-2/

elastic-query-web-client-2.iml

14.7 KB

pom.xml

3.3 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/config/

ElasticQueryServiceInstanceListSupplierConfig.java

1.6 KB

WebClientConfig.java

3.8 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.6 KB

/.../elastic-query-web-client-2/src/main/resources/

application.yml

0.2 KB

bootstrap.yml

0.4 KB

logback.xml

0.4 KB

/.../elastic-query-web-client-2/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client-common/

elastic-query-web-client-common.iml

3.6 KB

pom.xml

1.5 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/model/

ElasticQueryWebClientAnalyticsResponseModel.java

0.5 KB

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/

elastic-query-web-client.iml

14.8 KB

pom.xml

3.3 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.5 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

ElasticQueryServiceInstanceListSupplierConfig.java

1.6 KB

WebClientConfig.java

3.8 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.7 KB

/.../elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.4 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/10/elastic/elastic-config/

elastic-config.iml

9.0 KB

pom.xml

1.3 KB

/10/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.0 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/10/elastic/elastic-model/

elastic-model.iml

8.9 KB

pom.xml

0.9 KB

/10/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/10/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.2 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/10/elastic/

elastic.iml

0.6 KB

pom.xml

0.8 KB

/.../kafka-streams-service/

kafka-streams-service.iml

15.0 KB

pom.xml

3.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/

Constants.java

0.1 KB

KafkaStreamsServiceApplication.java

1.4 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/api/

KafkaStreamsController.java

2.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/config/

KafkaStreamsConfig.java

1.9 KB

WebSecurityConfig.java

3.7 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/

StreamsInitializer.java

0.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/impl/

KafkaStreamsInitializer.java

1.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/model/

KafkaStreamsResponseModel.java

0.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/

StreamsRunner.java

0.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/impl/

KafkaStreamsRunner.java

6.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/security/

AudienceValidator.java

1.4 KB

KafkaStreamsUser.java

1.2 KB

KafkaStreamsUserDetailsService.java

0.6 KB

KafkaStreamsUserJwtConverter.java

3.6 KB

/.../kafka-streams-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.2 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.6 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.3 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/10/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/10/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/10/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/10/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/10/kafka/kafka-consumer/

kafka-consumer.iml

3.1 KB

pom.xml

1.1 KB

/10/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/10/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/10/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAnalyticsAvroModel.java

16.6 KB

TwitterAvroModel.java

17.5 KB

/10/kafka/kafka-model/src/main/resources/avro/

twitter-analytics.avsc

0.3 KB

twitter.avsc

0.3 KB

/10/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/10/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/10/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/10/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/10/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/.../reactive-elastic-query-service/

pom.xml

2.8 KB

reactive-elastic-query-service.iml

17.2 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplication.java

0.5 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/api/

ElasticDocumentController.java

1.8 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/

ElasticQueryService.java

0.3 KB

ReactiveElasticQueryClient.java

0.4 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/impl/

TwitterElasticQueryService.java

1.7 KB

TwitterReactiveElasticQueryClient.java

1.6 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/config/

WebSecurityConfig.java

0.7 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/repository/

ElasticQueryRepository.java

0.5 KB

/.../reactive-elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-service/src/test/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplicationTests.java

0.3 KB

/.../reactive-elastic-query-web-client/

pom.xml

2.8 KB

reactive-elastic-query-web-client.iml

12.8 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplication.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/api/

QueryController.java

2.4 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/config/

WebClientConfig.java

2.1 KB

WebSecurityConfig.java

0.6 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.4 KB

/.../reactive-elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

1.1 KB

home.html

2.1 KB

index.html

0.2 KB

/.../reactive-elastic-query-web-client/src/test/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/11/

001 Analytics microservice configuration with Spring Boot Data JPA and PostgreSQL.mp4

11.7 MB

001 Analytics microservice configuration with Spring Boot Data JPA and PostgreSQL_en.srt

6.2 KB

002 Completing the Analytics microservice with Spring Data JPA and PostgreSQL.mp4

32.6 MB

002 Completing the Analytics microservice with Spring Data JPA and PostgreSQL_en.srt

8.5 KB

003 Creating an Rest API endpoint for analytics data.mp4

4.8 MB

003 Creating an Rest API endpoint for analytics data_en.srt

2.5 KB

004 Calling the analytics Rest API from query service.mp4

29.0 MB

004 Calling the analytics Rest API from query service_en.srt

6.5 KB

HELP.md

0.4 KB

README.md

0.4 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

10.1 KB

/11/analytics-service/

analytics-service.iml

16.7 KB

pom.xml

3.4 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/

AnalyticsApplication.java

0.5 KB

Constants.java

0.1 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/api/

AnalyticsController.java

2.2 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/

AnalyticsService.java

0.3 KB

KafkaConsumer.java

0.3 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/impl/

AnalyticsKafkaConsumer.java

3.5 KB

TwitterAnalyticsService.java

1.3 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/config/

WebSecurityConfig.java

3.6 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/entity/

AnalyticsEntity.java

1.3 KB

BaseEntity.java

0.1 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/

AnalyticsCustomRepository.java

0.5 KB

AnalyticsRepository.java

0.8 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/impl/

AnalyticsRepositoryImpl.java

2.7 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/model/

AnalyticsResponseModel.java

0.4 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/security/

AnalyticsUser.java

1.2 KB

AnalyticsUserDetailsService.java

0.6 KB

AnalyticsUserJwtConverter.java

3.4 KB

AudienceValidator.java

1.4 KB

/11/analytics-service/src/main/java/com/microservices/demo/analytics/service/transformer/

AvroToDbEntityModelTransformer.java

1.2 KB

EntityToResponseModelTransformer.java

0.8 KB

/11/analytics-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.3 KB

logback.xml

0.2 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

AnalyticsServiceConfigData.java

0.4 KB

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

1.0 KB

ElasticQueryWebClientConfigData.java

1.1 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

KafkaStreamsConfigData.java

0.5 KB

KafkaStreamsServiceConfigData.java

0.4 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/11/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/11/common-config/src/main/java/com/microservices/demo/common/config/

IdGeneratorConfig.java

0.4 KB

RetryConfig.java

1.4 KB

/11/common-util/

common-util.iml

0.7 KB

pom.xml

0.5 KB

/11/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-analytics.yml

2.0 KB

config-client-elastic_query.yml

2.4 KB

config-client-elastic_query_web.yml

1.6 KB

config-client-elastic_query_web_2.yml

1.6 KB

config-client-kafka_streams.yml

1.1 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-reactive_elastic_query.yml

0.8 KB

config-client-reactive_elastic_query_web.yml

0.6 KB

config-client-twitter_to_kafka.yml

1.1 KB

config-client.yml

0.1 KB

/11/config-server/

config-server.iml

8.2 KB

pom.xml

1.9 KB

/11/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/11/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/11/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/11/docker-compose/

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

check-keycloak-server-started.sh

0.5 KB

common.yml

0.1 KB

elastic_cluster.yml

1.8 KB

env

0.3 KB

kafka_cluster.yml

2.7 KB

keycloak_authorization_server.yml

0.5 KB

services.yml

12.6 KB

/.../elastic-query-service-common/

elastic-query-service-common.iml

10.5 KB

pom.xml

1.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/exception/

ElasticQueryServiceException.java

0.4 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/transformer/

ElasticToResponseModelTransformer.java

1.1 KB

/.../elastic-query-service/

elastic-query-service.iml

23.0 KB

pom.xml

3.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

Constants.java

0.1 KB

ElasticQueryServiceApplication.java

0.5 KB

QueryType.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

7.6 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.6 KB

QueryUserService.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

5.8 KB

TwitterQueryUserService.java

1.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebClientConfig.java

2.4 KB

WebSecurityConfig.java

3.7 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/entity/

UserPermission.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/repository/

UserPermissionRepository.java

0.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceAnalyticsResponseModel.java

0.5 KB

ElasticQueryServiceResponseModelV2.java

0.5 KB

ElasticQueryServiceWordCountResponseModel.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/security/

AudienceValidator.java

1.4 KB

PermissionType.java

0.3 KB

QueryServicePermissionEvaluator.java

3.8 KB

TwitterQueryUser.java

1.3 KB

TwitterQueryUserDetailsService.java

1.5 KB

TwitterQueryUserJwtConverter.java

3.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

UserPermissionsToUserDetailTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

init-data.sql

1.8 KB

init-schema.sql

1.6 KB

logback.xml

0.2 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client-2/

elastic-query-web-client-2.iml

14.7 KB

pom.xml

3.3 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/config/

ElasticQueryServiceInstanceListSupplierConfig.java

1.6 KB

WebClientConfig.java

3.8 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.6 KB

/.../elastic-query-web-client-2/src/main/resources/

application.yml

0.2 KB

bootstrap.yml

0.4 KB

logback.xml

0.4 KB

/.../elastic-query-web-client-2/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client-common/

elastic-query-web-client-common.iml

3.6 KB

pom.xml

1.5 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/model/

ElasticQueryWebClientAnalyticsResponseModel.java

0.5 KB

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/

elastic-query-web-client.iml

14.8 KB

pom.xml

3.3 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.5 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

ElasticQueryServiceInstanceListSupplierConfig.java

1.6 KB

WebClientConfig.java

3.8 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.7 KB

/.../elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.4 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/11/elastic/elastic-config/

elastic-config.iml

9.0 KB

pom.xml

1.3 KB

/11/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.0 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/11/elastic/elastic-model/

elastic-model.iml

8.9 KB

pom.xml

0.9 KB

/11/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/11/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.2 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/11/elastic/

elastic.iml

0.6 KB

pom.xml

0.8 KB

/.../kafka-streams-service/

kafka-streams-service.iml

15.0 KB

pom.xml

3.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/

Constants.java

0.1 KB

KafkaStreamsServiceApplication.java

1.4 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/api/

KafkaStreamsController.java

2.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/config/

KafkaStreamsConfig.java

1.9 KB

WebSecurityConfig.java

3.7 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/

StreamsInitializer.java

0.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/impl/

KafkaStreamsInitializer.java

1.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/model/

KafkaStreamsResponseModel.java

0.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/

StreamsRunner.java

0.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/impl/

KafkaStreamsRunner.java

6.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/security/

AudienceValidator.java

1.4 KB

KafkaStreamsUser.java

1.2 KB

KafkaStreamsUserDetailsService.java

0.6 KB

KafkaStreamsUserJwtConverter.java

3.6 KB

/.../kafka-streams-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.2 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.6 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.3 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/11/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/11/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/11/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/11/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/11/kafka/kafka-consumer/

kafka-consumer.iml

3.1 KB

pom.xml

1.1 KB

/11/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/api/

KafkaConsumer.java

0.3 KB

/11/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/11/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/11/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAnalyticsAvroModel.java

16.6 KB

TwitterAvroModel.java

17.5 KB

/11/kafka/kafka-model/src/main/resources/avro/

twitter-analytics.avsc

0.3 KB

twitter.avsc

0.3 KB

/11/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/11/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/11/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/11/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/11/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/.../reactive-elastic-query-service/

pom.xml

2.8 KB

reactive-elastic-query-service.iml

17.2 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplication.java

0.5 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/api/

ElasticDocumentController.java

1.8 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/

ElasticQueryService.java

0.3 KB

ReactiveElasticQueryClient.java

0.4 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/impl/

TwitterElasticQueryService.java

1.7 KB

TwitterReactiveElasticQueryClient.java

1.6 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/config/

WebSecurityConfig.java

0.7 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/repository/

ElasticQueryRepository.java

0.5 KB

/.../reactive-elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-service/src/test/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplicationTests.java

0.3 KB

/.../reactive-elastic-query-web-client/

pom.xml

2.8 KB

reactive-elastic-query-web-client.iml

12.8 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplication.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/api/

QueryController.java

2.4 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/config/

WebClientConfig.java

2.1 KB

WebSecurityConfig.java

0.6 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.4 KB

/.../reactive-elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

1.1 KB

home.html

2.1 KB

index.html

0.2 KB

/.../reactive-elastic-query-web-client/src/test/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/12/

001 Introduction to service registry and service discovery with Spring Eureka.mp4

8.7 MB

001 Introduction to service registry and service discovery with Spring Eureka_en.srt

2.7 KB

002 Integrating Spring eureka discovery service with microservices.mp4

25.6 MB

002 Integrating Spring eureka discovery service with microservices_en.srt

8.8 KB

32579286-discovery-service.pptx

64.1 KB

HELP.md

0.4 KB

README.md

0.5 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

10.6 KB

/12/analytics-service/

analytics-service.iml

23.5 KB

pom.xml

3.6 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/

AnalyticsApplication.java

0.6 KB

Constants.java

0.1 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/api/

AnalyticsController.java

2.2 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/

AnalyticsService.java

0.3 KB

KafkaConsumer.java

0.3 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/impl/

AnalyticsKafkaConsumer.java

3.7 KB

TwitterAnalyticsService.java

1.3 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/config/

WebSecurityConfig.java

3.6 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/entity/

AnalyticsEntity.java

1.3 KB

BaseEntity.java

0.1 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/

AnalyticsCustomRepository.java

0.5 KB

AnalyticsRepository.java

0.8 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/impl/

AnalyticsRepositoryImpl.java

2.6 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/model/

AnalyticsResponseModel.java

0.4 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/security/

AnalyticsUser.java

1.2 KB

AnalyticsUserDetailsService.java

0.6 KB

AnalyticsUserJwtConverter.java

3.4 KB

AudienceValidator.java

1.4 KB

/12/analytics-service/src/main/java/com/microservices/demo/analytics/service/transformer/

AvroToDbEntityModelTransformer.java

1.2 KB

EntityToResponseModelTransformer.java

0.8 KB

/12/analytics-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.2 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

AnalyticsServiceConfigData.java

0.4 KB

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

1.0 KB

ElasticQueryWebClientConfigData.java

1.1 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

KafkaStreamsConfigData.java

0.5 KB

KafkaStreamsServiceConfigData.java

0.4 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/12/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/12/common-config/src/main/java/com/microservices/demo/common/config/

IdGeneratorConfig.java

0.4 KB

RetryConfig.java

1.4 KB

/12/common-util/

common-util.iml

0.7 KB

pom.xml

0.5 KB

/12/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-analytics.yml

2.2 KB

config-client-elastic_query.yml

2.7 KB

config-client-elastic_query_web.yml

1.5 KB

config-client-elastic_query_web_2.yml

1.5 KB

config-client-kafka_streams.yml

1.2 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-reactive_elastic_query.yml

0.8 KB

config-client-reactive_elastic_query_web.yml

0.6 KB

config-client-twitter_to_kafka.yml

1.1 KB

config-client.yml

0.1 KB

/12/config-server/

config-server.iml

8.2 KB

pom.xml

1.9 KB

/12/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/12/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/12/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/12/discovery-service/

discovery-service.iml

15.8 KB

pom.xml

1.7 KB

/12/discovery-service/src/main/java/com/microservices/demo/discovery/service/

ServiceRegistrationAndDiscoveryServiceApplication.java

0.5 KB

/12/discovery-service/src/main/resources/

application-singleserver.yml

0.2 KB

application.yml

0.9 KB

logback.xml

1.5 KB

/12/docker-compose/

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

check-keycloak-server-started.sh

0.5 KB

common.yml

0.1 KB

elastic_cluster.yml

1.8 KB

env

0.3 KB

kafka_cluster.yml

2.7 KB

keycloak_authorization_server.yml

0.5 KB

services.yml

15.7 KB

/.../elastic-query-service-common/

elastic-query-service-common.iml

10.5 KB

pom.xml

1.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/exception/

ElasticQueryServiceException.java

0.4 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/transformer/

ElasticToResponseModelTransformer.java

1.1 KB

/.../elastic-query-service/

elastic-query-service.iml

29.6 KB

pom.xml

4.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

Constants.java

0.1 KB

ElasticQueryServiceApplication.java

0.6 KB

QueryType.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

7.6 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.6 KB

QueryUserService.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

6.4 KB

TwitterQueryUserService.java

1.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebClientConfig.java

2.4 KB

WebSecurityConfig.java

3.7 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/entity/

UserPermission.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/repository/

UserPermissionRepository.java

0.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceAnalyticsResponseModel.java

0.5 KB

ElasticQueryServiceResponseModelV2.java

0.5 KB

ElasticQueryServiceWordCountResponseModel.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/security/

AudienceValidator.java

1.4 KB

PermissionType.java

0.3 KB

QueryServicePermissionEvaluator.java

3.8 KB

TwitterQueryUser.java

1.3 KB

TwitterQueryUserDetailsService.java

1.5 KB

TwitterQueryUserJwtConverter.java

3.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

UserPermissionsToUserDetailTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

init-data.sql

1.8 KB

init-schema.sql

1.6 KB

logback.xml

0.2 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client-2/

elastic-query-web-client-2.iml

21.8 KB

pom.xml

3.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.7 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.6 KB

/.../elastic-query-web-client-2/src/main/resources/

application.yml

0.2 KB

bootstrap.yml

0.5 KB

logback.xml

0.4 KB

/.../elastic-query-web-client-2/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client-common/

elastic-query-web-client-common.iml

3.6 KB

pom.xml

1.5 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/model/

ElasticQueryWebClientAnalyticsResponseModel.java

0.5 KB

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/

elastic-query-web-client.iml

21.9 KB

pom.xml

3.5 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.7 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.7 KB

/.../elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.4 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/12/elastic/elastic-config/

elastic-config.iml

9.0 KB

pom.xml

1.3 KB

/12/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.0 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/12/elastic/elastic-model/

elastic-model.iml

8.9 KB

pom.xml

0.9 KB

/12/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/12/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.2 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/12/elastic/

elastic.iml

0.6 KB

pom.xml

0.8 KB

/.../kafka-streams-service/

kafka-streams-service.iml

22.0 KB

pom.xml

3.5 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/

Constants.java

0.1 KB

KafkaStreamsServiceApplication.java

1.4 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/api/

KafkaStreamsController.java

2.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/config/

KafkaStreamsConfig.java

1.9 KB

WebSecurityConfig.java

3.7 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/

StreamsInitializer.java

0.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/impl/

KafkaStreamsInitializer.java

1.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/model/

KafkaStreamsResponseModel.java

0.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/

StreamsRunner.java

0.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/impl/

KafkaStreamsRunner.java

6.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/security/

AudienceValidator.java

1.4 KB

KafkaStreamsUser.java

1.2 KB

KafkaStreamsUserDetailsService.java

0.6 KB

KafkaStreamsUserJwtConverter.java

3.6 KB

/.../kafka-streams-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.2 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.6 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.3 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/12/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/12/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/12/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/12/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/12/kafka/kafka-consumer/

kafka-consumer.iml

3.1 KB

pom.xml

1.1 KB

/12/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/12/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/12/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAnalyticsAvroModel.java

16.6 KB

TwitterAvroModel.java

17.5 KB

/12/kafka/kafka-model/src/main/resources/avro/

twitter-analytics.avsc

0.3 KB

twitter.avsc

0.3 KB

/12/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/12/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/12/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/12/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/12/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/.../reactive-elastic-query-service/

pom.xml

2.8 KB

reactive-elastic-query-service.iml

17.2 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplication.java

0.5 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/api/

ElasticDocumentController.java

1.8 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/

ElasticQueryService.java

0.3 KB

ReactiveElasticQueryClient.java

0.4 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/impl/

TwitterElasticQueryService.java

1.7 KB

TwitterReactiveElasticQueryClient.java

1.6 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/config/

WebSecurityConfig.java

0.7 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/repository/

ElasticQueryRepository.java

0.5 KB

/.../reactive-elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-service/src/test/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplicationTests.java

0.3 KB

/.../reactive-elastic-query-web-client/

pom.xml

2.8 KB

reactive-elastic-query-web-client.iml

12.8 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplication.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/api/

QueryController.java

2.4 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/config/

WebClientConfig.java

2.1 KB

WebSecurityConfig.java

0.6 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.4 KB

/.../reactive-elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

1.1 KB

home.html

2.1 KB

index.html

0.2 KB

/.../reactive-elastic-query-web-client/src/test/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/13/

001 Introduction to Api Gateway_ Resilience4J Circuit Breaker and Redis Rate Limiter.mp4

55.2 MB

001 Introduction to Api Gateway_ Resilience4J Circuit Breaker and Redis Rate Limiter_en.srt

8.5 KB

002 Implementing Api Gateway with Springcloud gateway, Redis and Resilience4J.mp4

47.9 MB

002 Implementing Api Gateway with Springcloud gateway, Redis and Resilience4J_en.srt

12.6 KB

003 Integrate Spring Cloud Api Gateway Circuit Breaker & Rate limiting with services.mp4

40.0 MB

003 Integrate Spring Cloud Api Gateway Circuit Breaker & Rate limiting with services_en.srt

9.8 KB

32579294-gateway.pptx

79.5 KB

HELP.md

0.4 KB

README.md

0.5 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

11.4 KB

/13/analytics-service/

analytics-service.iml

23.5 KB

pom.xml

3.6 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/

AnalyticsApplication.java

0.6 KB

Constants.java

0.1 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/api/

AnalyticsController.java

2.2 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/

AnalyticsService.java

0.3 KB

KafkaConsumer.java

0.3 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/impl/

AnalyticsKafkaConsumer.java

3.7 KB

TwitterAnalyticsService.java

1.3 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/config/

WebSecurityConfig.java

3.6 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/entity/

AnalyticsEntity.java

1.3 KB

BaseEntity.java

0.1 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/

AnalyticsCustomRepository.java

0.5 KB

AnalyticsRepository.java

0.8 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/impl/

AnalyticsRepositoryImpl.java

2.6 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/model/

AnalyticsResponseModel.java

0.4 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/security/

AnalyticsUser.java

1.2 KB

AnalyticsUserDetailsService.java

0.6 KB

AnalyticsUserJwtConverter.java

3.4 KB

AudienceValidator.java

1.4 KB

/13/analytics-service/src/main/java/com/microservices/demo/analytics/service/transformer/

AvroToDbEntityModelTransformer.java

1.2 KB

EntityToResponseModelTransformer.java

0.8 KB

/13/analytics-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

AnalyticsServiceConfigData.java

0.4 KB

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

1.0 KB

ElasticQueryWebClientConfigData.java

1.1 KB

GatewayServiceConfigData.java

0.6 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

KafkaStreamsConfigData.java

0.5 KB

KafkaStreamsServiceConfigData.java

0.4 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/13/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/13/common-config/src/main/java/com/microservices/demo/common/config/

IdGeneratorConfig.java

0.4 KB

RetryConfig.java

1.4 KB

/13/common-util/

common-util.iml

0.7 KB

pom.xml

0.5 KB

/13/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-analytics.yml

2.2 KB

config-client-elastic_query.yml

2.6 KB

config-client-elastic_query_web.yml

1.5 KB

config-client-elastic_query_web_2.yml

1.5 KB

config-client-gateway.yml

2.4 KB

config-client-kafka_streams.yml

1.2 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-reactive_elastic_query.yml

0.8 KB

config-client-reactive_elastic_query_web.yml

0.6 KB

config-client-twitter_to_kafka.yml

1.1 KB

config-client.yml

0.1 KB

/13/config-server/

config-server.iml

8.2 KB

pom.xml

1.9 KB

/13/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/13/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/13/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/13/discovery-service/

discovery-service.iml

15.8 KB

pom.xml

1.7 KB

/13/discovery-service/src/main/java/com/microservices/demo/discovery/service/

ServiceRegistrationAndDiscoveryServiceApplication.java

0.5 KB

/13/discovery-service/src/main/resources/

application-singleserver.yml

0.2 KB

application.yml

1.1 KB

logback.xml

1.5 KB

/13/docker-compose/

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

check-keycloak-server-started.sh

0.5 KB

common.yml

0.1 KB

elastic_cluster.yml

1.8 KB

env

0.3 KB

kafka_cluster.yml

2.7 KB

keycloak_authorization_server.yml

0.5 KB

redis_cluster.yml

0.5 KB

services.yml

15.3 KB

/.../elastic-query-service-common/

elastic-query-service-common.iml

10.5 KB

pom.xml

1.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/exception/

ElasticQueryServiceException.java

0.4 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/transformer/

ElasticToResponseModelTransformer.java

1.1 KB

/.../elastic-query-service/

elastic-query-service.iml

29.6 KB

pom.xml

4.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

Constants.java

0.1 KB

ElasticQueryServiceApplication.java

0.6 KB

QueryType.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

7.6 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.6 KB

QueryUserService.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

6.4 KB

TwitterQueryUserService.java

1.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebClientConfig.java

2.4 KB

WebSecurityConfig.java

3.7 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/entity/

UserPermission.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/repository/

UserPermissionRepository.java

0.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceAnalyticsResponseModel.java

0.5 KB

ElasticQueryServiceResponseModelV2.java

0.5 KB

ElasticQueryServiceWordCountResponseModel.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/security/

AudienceValidator.java

1.4 KB

PermissionType.java

0.3 KB

QueryServicePermissionEvaluator.java

3.8 KB

TwitterQueryUser.java

1.3 KB

TwitterQueryUserDetailsService.java

1.5 KB

TwitterQueryUserJwtConverter.java

3.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

UserPermissionsToUserDetailTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

init-data.sql

1.8 KB

init-schema.sql

1.6 KB

logback.xml

0.2 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client-2/

elastic-query-web-client-2.iml

21.8 KB

pom.xml

3.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.7 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.6 KB

/.../elastic-query-web-client-2/src/main/resources/

application.yml

0.2 KB

bootstrap.yml

0.5 KB

logback.xml

0.4 KB

/.../elastic-query-web-client-2/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client-common/

elastic-query-web-client-common.iml

3.6 KB

pom.xml

1.5 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/model/

ElasticQueryWebClientAnalyticsResponseModel.java

0.5 KB

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/

elastic-query-web-client.iml

21.9 KB

pom.xml

3.5 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.2 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.7 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.7 KB

/.../elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.5 KB

logback.xml

0.4 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.3 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/13/elastic/elastic-config/

elastic-config.iml

9.0 KB

pom.xml

1.3 KB

/13/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.0 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/13/elastic/elastic-model/

elastic-model.iml

8.9 KB

pom.xml

0.9 KB

/13/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/13/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.2 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/13/elastic/

elastic.iml

0.6 KB

pom.xml

0.8 KB

/13/gateway-service/

gateway-service.iml

18.1 KB

pom.xml

2.8 KB

/13/gateway-service/src/main/java/com/microservices/demo/gateway/service/

GatewayServiceApplication.java

0.6 KB

/13/gateway-service/src/main/java/com/microservices/demo/gateway/service/config/

GatewayConfig.java

2.9 KB

WebSecurityConfig.java

0.7 KB

/13/gateway-service/src/main/java/com/microservices/demo/gateway/service/controller/

FallbackController.java

1.7 KB

/13/gateway-service/src/main/java/com/microservices/demo/gateway/service/model/

AnalyticsDataFallbackModel.java

0.3 KB

QueryServiceFallbackModel.java

0.3 KB

/13/gateway-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/.../kafka-streams-service/

kafka-streams-service.iml

22.0 KB

pom.xml

3.5 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/

Constants.java

0.1 KB

KafkaStreamsServiceApplication.java

1.4 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/api/

KafkaStreamsController.java

2.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/config/

KafkaStreamsConfig.java

1.9 KB

WebSecurityConfig.java

3.7 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/

StreamsInitializer.java

0.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/impl/

KafkaStreamsInitializer.java

1.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/model/

KafkaStreamsResponseModel.java

0.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/

StreamsRunner.java

0.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/impl/

KafkaStreamsRunner.java

6.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/security/

AudienceValidator.java

1.4 KB

KafkaStreamsUser.java

1.2 KB

KafkaStreamsUserDetailsService.java

0.6 KB

KafkaStreamsUserJwtConverter.java

3.6 KB

/.../kafka-streams-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.6 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.3 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/13/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/13/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/13/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/13/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/13/kafka/kafka-consumer/

kafka-consumer.iml

3.1 KB

pom.xml

1.1 KB

/13/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/13/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/13/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAnalyticsAvroModel.java

16.6 KB

TwitterAvroModel.java

17.5 KB

/13/kafka/kafka-model/src/main/resources/avro/

twitter-analytics.avsc

0.3 KB

twitter.avsc

0.3 KB

/13/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/13/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/13/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/13/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/13/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/.../reactive-elastic-query-service/

pom.xml

2.8 KB

reactive-elastic-query-service.iml

17.2 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplication.java

0.5 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/api/

ElasticDocumentController.java

1.8 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/

ElasticQueryService.java

0.3 KB

ReactiveElasticQueryClient.java

0.4 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/impl/

TwitterElasticQueryService.java

1.7 KB

TwitterReactiveElasticQueryClient.java

1.6 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/config/

WebSecurityConfig.java

0.7 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/repository/

ElasticQueryRepository.java

0.5 KB

/.../reactive-elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-service/src/test/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplicationTests.java

0.3 KB

/.../reactive-elastic-query-web-client/

pom.xml

2.8 KB

reactive-elastic-query-web-client.iml

12.8 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplication.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/api/

QueryController.java

2.4 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/config/

WebClientConfig.java

2.1 KB

WebSecurityConfig.java

0.6 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.4 KB

/.../reactive-elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

1.1 KB

home.html

2.1 KB

index.html

0.2 KB

/.../reactive-elastic-query-web-client/src/test/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/14/

001 Configure microservices with Spring boot actuator, Prometheues and Micrometer.mp4

8.4 MB

001 Configure microservices with Spring boot actuator, Prometheues and Micrometer_en.srt

2.5 KB

002 Adding monitoring and creating dashboards with Grafana.mp4

14.9 MB

002 Adding monitoring and creating dashboards with Grafana_en.srt

6.6 KB

HELP.md

0.4 KB

README.md

0.4 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

11.8 KB

/14/analytics-service/

analytics-service.iml

24.4 KB

pom.xml

4.0 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/

AnalyticsApplication.java

0.6 KB

Constants.java

0.1 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/api/

AnalyticsController.java

2.2 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/

AnalyticsService.java

0.3 KB

KafkaConsumer.java

0.3 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/impl/

AnalyticsKafkaConsumer.java

3.7 KB

TwitterAnalyticsService.java

1.3 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/config/

WebSecurityConfig.java

3.6 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/entity/

AnalyticsEntity.java

1.3 KB

BaseEntity.java

0.1 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/

AnalyticsCustomRepository.java

0.5 KB

AnalyticsRepository.java

0.8 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/impl/

AnalyticsRepositoryImpl.java

2.6 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/model/

AnalyticsResponseModel.java

0.4 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/security/

AnalyticsUser.java

1.2 KB

AnalyticsUserDetailsService.java

0.6 KB

AnalyticsUserJwtConverter.java

3.4 KB

AudienceValidator.java

1.4 KB

/14/analytics-service/src/main/java/com/microservices/demo/analytics/service/transformer/

AvroToDbEntityModelTransformer.java

1.2 KB

EntityToResponseModelTransformer.java

0.8 KB

/14/analytics-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

AnalyticsServiceConfigData.java

0.4 KB

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

1.0 KB

ElasticQueryWebClientConfigData.java

1.1 KB

GatewayServiceConfigData.java

0.6 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

KafkaStreamsConfigData.java

0.5 KB

KafkaStreamsServiceConfigData.java

0.4 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/14/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/14/common-config/src/main/java/com/microservices/demo/common/config/

IdGeneratorConfig.java

0.4 KB

RetryConfig.java

1.4 KB

/14/common-util/

common-util.iml

0.7 KB

pom.xml

0.5 KB

/14/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-analytics.yml

2.4 KB

config-client-elastic_query.yml

2.9 KB

config-client-elastic_query_web.yml

1.5 KB

config-client-elastic_query_web_2.yml

1.5 KB

config-client-gateway.yml

2.7 KB

config-client-kafka_streams.yml

1.4 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-reactive_elastic_query.yml

0.8 KB

config-client-reactive_elastic_query_web.yml

0.6 KB

config-client-twitter_to_kafka.yml

1.1 KB

config-client.yml

0.1 KB

/14/config-server/

config-server.iml

8.2 KB

pom.xml

1.9 KB

/14/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/14/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/14/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/14/discovery-service/

discovery-service.iml

15.8 KB

pom.xml

1.7 KB

/14/discovery-service/src/main/java/com/microservices/demo/discovery/service/

ServiceRegistrationAndDiscoveryServiceApplication.java

0.5 KB

/14/discovery-service/src/main/resources/

application-singleserver.yml

0.2 KB

application.yml

1.1 KB

logback.xml

1.5 KB

/14/docker-compose/

DS_Store

6.1 KB

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

check-keycloak-server-started.sh

0.5 KB

common.yml

0.1 KB

elastic_cluster.yml

1.8 KB

env

0.4 KB

kafka_cluster.yml

2.7 KB

keycloak_authorization_server.yml

0.5 KB

monitoring.yml

0.6 KB

redis_cluster.yml

0.5 KB

services.yml

16.0 KB

/14/docker-compose/config/

DS_Store

6.1 KB

prometheus.yml

1.1 KB

/.../elastic-query-service-common/

elastic-query-service-common.iml

10.5 KB

pom.xml

1.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/exception/

ElasticQueryServiceException.java

0.4 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/transformer/

ElasticToResponseModelTransformer.java

1.1 KB

/.../elastic-query-service/

elastic-query-service.iml

30.5 KB

pom.xml

4.4 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

Constants.java

0.1 KB

ElasticQueryServiceApplication.java

0.6 KB

QueryType.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

7.6 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.6 KB

QueryUserService.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

6.4 KB

TwitterQueryUserService.java

1.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebClientConfig.java

2.4 KB

WebSecurityConfig.java

3.7 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/entity/

UserPermission.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/repository/

UserPermissionRepository.java

0.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceAnalyticsResponseModel.java

0.5 KB

ElasticQueryServiceResponseModelV2.java

0.5 KB

ElasticQueryServiceWordCountResponseModel.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/security/

AudienceValidator.java

1.4 KB

PermissionType.java

0.3 KB

QueryServicePermissionEvaluator.java

3.8 KB

TwitterQueryUser.java

1.3 KB

TwitterQueryUserDetailsService.java

1.5 KB

TwitterQueryUserJwtConverter.java

3.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

UserPermissionsToUserDetailTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

init-data.sql

1.8 KB

init-schema.sql

1.6 KB

logback.xml

0.2 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client-2/

elastic-query-web-client-2.iml

21.8 KB

pom.xml

3.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.7 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.6 KB

/.../elastic-query-web-client-2/src/main/resources/

application.yml

0.2 KB

bootstrap.yml

0.5 KB

logback.xml

0.4 KB

/.../elastic-query-web-client-2/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client-common/

elastic-query-web-client-common.iml

3.6 KB

pom.xml

1.5 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/model/

ElasticQueryWebClientAnalyticsResponseModel.java

0.5 KB

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/

elastic-query-web-client.iml

21.9 KB

pom.xml

3.5 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.2 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.6 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.7 KB

/.../elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.5 KB

logback.xml

0.4 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.3 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/14/elastic/elastic-config/

elastic-config.iml

9.0 KB

pom.xml

1.3 KB

/14/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.0 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/14/elastic/elastic-model/

elastic-model.iml

8.9 KB

pom.xml

0.9 KB

/14/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/14/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.2 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/14/elastic/

elastic.iml

0.6 KB

pom.xml

0.8 KB

/14/gateway-service/

gateway-service.iml

19.0 KB

pom.xml

3.1 KB

/14/gateway-service/src/main/java/com/microservices/demo/gateway/service/

GatewayServiceApplication.java

0.6 KB

/14/gateway-service/src/main/java/com/microservices/demo/gateway/service/config/

GatewayConfig.java

2.9 KB

WebSecurityConfig.java

0.7 KB

/14/gateway-service/src/main/java/com/microservices/demo/gateway/service/controller/

FallbackController.java

1.7 KB

/14/gateway-service/src/main/java/com/microservices/demo/gateway/service/model/

AnalyticsDataFallbackModel.java

0.3 KB

QueryServiceFallbackModel.java

0.3 KB

/14/gateway-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/.../kafka-streams-service/

kafka-streams-service.iml

22.9 KB

pom.xml

3.8 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/

Constants.java

0.1 KB

KafkaStreamsServiceApplication.java

1.4 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/api/

KafkaStreamsController.java

2.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/config/

KafkaStreamsConfig.java

1.9 KB

WebSecurityConfig.java

3.7 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/

StreamsInitializer.java

0.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/impl/

KafkaStreamsInitializer.java

1.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/model/

KafkaStreamsResponseModel.java

0.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/

StreamsRunner.java

0.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/impl/

KafkaStreamsRunner.java

6.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/security/

AudienceValidator.java

1.4 KB

KafkaStreamsUser.java

1.2 KB

KafkaStreamsUserDetailsService.java

0.6 KB

KafkaStreamsUserJwtConverter.java

3.6 KB

/.../kafka-streams-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.6 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.3 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/14/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/14/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/14/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/14/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/14/kafka/kafka-consumer/

kafka-consumer.iml

3.1 KB

pom.xml

1.1 KB

/14/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/14/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/14/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAnalyticsAvroModel.java

16.6 KB

TwitterAvroModel.java

17.5 KB

/14/kafka/kafka-model/src/main/resources/avro/

twitter-analytics.avsc

0.3 KB

twitter.avsc

0.3 KB

/14/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/14/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/14/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/14/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/14/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/.../reactive-elastic-query-service/

pom.xml

2.8 KB

reactive-elastic-query-service.iml

17.2 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplication.java

0.5 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/api/

ElasticDocumentController.java

1.8 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/

ElasticQueryService.java

0.3 KB

ReactiveElasticQueryClient.java

0.4 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/impl/

TwitterElasticQueryService.java

1.7 KB

TwitterReactiveElasticQueryClient.java

1.6 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/config/

WebSecurityConfig.java

0.7 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/repository/

ElasticQueryRepository.java

0.5 KB

/.../reactive-elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-service/src/test/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplicationTests.java

0.3 KB

/.../reactive-elastic-query-web-client/

pom.xml

2.8 KB

reactive-elastic-query-web-client.iml

12.8 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplication.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/api/

QueryController.java

2.4 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/config/

WebClientConfig.java

2.1 KB

WebSecurityConfig.java

0.6 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.4 KB

/.../reactive-elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

1.1 KB

home.html

2.1 KB

index.html

0.2 KB

/.../reactive-elastic-query-web-client/src/test/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/15/

001 Configuring microservices to work with Logstash.mp4

13.3 MB

001 Configuring microservices to work with Logstash_en.srt

6.7 KB

002 Adding Logstash and Kibana into application_ Complete ELK stack.mp4

18.1 MB

002 Adding Logstash and Kibana into application_ Complete ELK stack_en.srt

3.2 KB

003 Making gateway and config server high available and improve log file naming.mp4

22.7 MB

003 Making gateway and config server high available and improve log file naming_en.srt

4.9 KB

HELP.md

0.4 KB

README.md

0.5 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

12.3 KB

/15/analytics-service/

analytics-service.iml

24.7 KB

pom.xml

4.1 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/

AnalyticsApplication.java

0.6 KB

Constants.java

0.1 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/api/

AnalyticsController.java

2.2 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/

AnalyticsService.java

0.3 KB

KafkaConsumer.java

0.3 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/impl/

AnalyticsKafkaConsumer.java

3.7 KB

TwitterAnalyticsService.java

1.3 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/config/

WebSecurityConfig.java

3.6 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/entity/

AnalyticsEntity.java

1.3 KB

BaseEntity.java

0.1 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/

AnalyticsCustomRepository.java

0.5 KB

AnalyticsRepository.java

0.8 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/impl/

AnalyticsRepositoryImpl.java

2.6 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/model/

AnalyticsResponseModel.java

0.4 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/security/

AnalyticsUser.java

1.2 KB

AnalyticsUserDetailsService.java

0.6 KB

AnalyticsUserJwtConverter.java

3.4 KB

AudienceValidator.java

1.4 KB

/15/analytics-service/src/main/java/com/microservices/demo/analytics/service/transformer/

AvroToDbEntityModelTransformer.java

1.2 KB

EntityToResponseModelTransformer.java

0.8 KB

/15/analytics-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.6 KB

logback-spring.xml

0.3 KB

logback.xml

0.2 KB

/.../app-config-data/

app-config-data.iml

2.1 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

AnalyticsServiceConfigData.java

0.4 KB

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

1.0 KB

ElasticQueryWebClientConfigData.java

1.1 KB

GatewayServiceConfigData.java

0.6 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

KafkaStreamsConfigData.java

0.5 KB

KafkaStreamsServiceConfigData.java

0.4 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

2.4 KB

/15/common-config/

common-config.iml

3.6 KB

pom.xml

1.2 KB

/15/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/15/common-util/

common-util.iml

1.1 KB

pom.xml

0.5 KB

/15/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-analytics.yml

2.4 KB

config-client-elastic_query.yml

2.9 KB

config-client-elastic_query_web.yml

1.5 KB

config-client-elastic_query_web_2.yml

1.5 KB

config-client-gateway.yml

2.7 KB

config-client-kafka_streams.yml

1.4 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-reactive_elastic_query.yml

0.8 KB

config-client-reactive_elastic_query_web.yml

0.6 KB

config-client-twitter_to_kafka.yml

1.1 KB

config-client.yml

0.1 KB

/15/config-server/

config-server.iml

8.4 KB

pom.xml

1.9 KB

/15/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/15/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/15/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback-spring.xml

0.3 KB

logback.xml

0.2 KB

/15/discovery-service/

discovery-service.iml

15.9 KB

pom.xml

1.7 KB

/15/discovery-service/src/main/java/com/microservices/demo/discovery/service/

ServiceRegistrationAndDiscoveryServiceApplication.java

0.5 KB

/15/discovery-service/src/main/resources/

application-singleserver.yml

0.3 KB

application.yml

1.1 KB

logback-spring.xml

2.5 KB

logback.xml

1.5 KB

/15/docker-compose/

DS_Store

6.1 KB

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

check-keycloak-server-started.sh

0.5 KB

common.yml

0.1 KB

elastic_cluster.yml

2.6 KB

env

0.4 KB

kafka_cluster.yml

2.7 KB

keycloak_authorization_server.yml

0.5 KB

monitoring.yml

0.6 KB

redis_cluster.yml

0.5 KB

services.yml

17.7 KB

/15/docker-compose/config/

logback.conf

0.2 KB

prometheus.yml

1.1 KB

/.../elastic-query-service-common/

elastic-query-service-common.iml

10.6 KB

pom.xml

1.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/exception/

ElasticQueryServiceException.java

0.4 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/transformer/

ElasticToResponseModelTransformer.java

1.1 KB

/.../elastic-query-service/

elastic-query-service.iml

30.8 KB

pom.xml

4.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

Constants.java

0.1 KB

ElasticQueryServiceApplication.java

0.6 KB

QueryType.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

7.6 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.6 KB

QueryUserService.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

6.7 KB

TwitterQueryUserService.java

1.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebClientConfig.java

2.6 KB

WebSecurityConfig.java

3.7 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/entity/

UserPermission.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/repository/

UserPermissionRepository.java

0.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceAnalyticsResponseModel.java

0.5 KB

ElasticQueryServiceResponseModelV2.java

0.5 KB

ElasticQueryServiceWordCountResponseModel.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/security/

AudienceValidator.java

1.4 KB

PermissionType.java

0.3 KB

QueryServicePermissionEvaluator.java

3.8 KB

TwitterQueryUser.java

1.3 KB

TwitterQueryUserDetailsService.java

1.5 KB

TwitterQueryUserJwtConverter.java

3.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

UserPermissionsToUserDetailTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.6 KB

init-data.sql

1.8 KB

init-schema.sql

1.6 KB

logback-spring.xml

0.3 KB

logback.xml

0.2 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client-2/

elastic-query-web-client-2.iml

21.9 KB

pom.xml

3.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.7 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.6 KB

/.../elastic-query-web-client-2/src/main/resources/

application.yml

0.2 KB

bootstrap.yml

0.6 KB

logback-spring.xml

0.3 KB

logback.xml

0.4 KB

/.../elastic-query-web-client-2/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client-common/

elastic-query-web-client-common.iml

4.1 KB

pom.xml

1.5 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/model/

ElasticQueryWebClientAnalyticsResponseModel.java

0.5 KB

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/

elastic-query-web-client.iml

22.1 KB

pom.xml

3.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.2 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.8 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

4.0 KB

/.../elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.6 KB

logback-spring.xml

0.3 KB

logback.xml

0.4 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.3 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/15/elastic/elastic-config/

elastic-config.iml

9.1 KB

pom.xml

1.3 KB

/15/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.1 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/15/elastic/elastic-model/

elastic-model.iml

9.1 KB

pom.xml

0.9 KB

/15/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/15/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.3 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/15/elastic/

elastic.iml

1.0 KB

pom.xml

0.8 KB

/15/gateway-service/

gateway-service.iml

19.1 KB

pom.xml

3.1 KB

/15/gateway-service/src/main/java/com/microservices/demo/gateway/service/

GatewayServiceApplication.java

0.6 KB

/15/gateway-service/src/main/java/com/microservices/demo/gateway/service/config/

GatewayConfig.java

3.4 KB

WebSecurityConfig.java

0.7 KB

/15/gateway-service/src/main/java/com/microservices/demo/gateway/service/controller/

FallbackController.java

1.9 KB

/15/gateway-service/src/main/java/com/microservices/demo/gateway/service/model/

AnalyticsDataFallbackModel.java

0.3 KB

QueryServiceFallbackModel.java

0.3 KB

/15/gateway-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.5 KB

logback-spring.xml

0.3 KB

logback.xml

0.2 KB

/.../kafka-streams-service/

kafka-streams-service.iml

23.2 KB

pom.xml

4.0 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/

Constants.java

0.1 KB

KafkaStreamsServiceApplication.java

1.4 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/api/

KafkaStreamsController.java

2.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/config/

KafkaStreamsConfig.java

1.9 KB

WebSecurityConfig.java

3.7 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/

StreamsInitializer.java

0.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/impl/

KafkaStreamsInitializer.java

1.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/model/

KafkaStreamsResponseModel.java

0.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/

StreamsRunner.java

0.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/impl/

KafkaStreamsRunner.java

6.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/security/

AudienceValidator.java

1.4 KB

KafkaStreamsUser.java

1.2 KB

KafkaStreamsUserDetailsService.java

0.6 KB

KafkaStreamsUserJwtConverter.java

3.6 KB

/.../kafka-streams-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.6 KB

logback-spring.xml

0.3 KB

logback.xml

0.2 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.7 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.3 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback-spring.xml

0.3 KB

logback.xml

0.3 KB

/15/kafka/kafka-admin/

kafka-admin.iml

7.2 KB

pom.xml

1.2 KB

/15/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/15/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/15/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/15/kafka/kafka-consumer/

kafka-consumer.iml

3.2 KB

pom.xml

1.1 KB

/15/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/15/kafka/kafka-model/

kafka-model.iml

1.5 KB

pom.xml

1.7 KB

/15/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAnalyticsAvroModel.java

16.6 KB

TwitterAvroModel.java

17.5 KB

/15/kafka/kafka-model/src/main/resources/avro/

twitter-analytics.avsc

0.3 KB

twitter.avsc

0.3 KB

/15/kafka/kafka-producer/

kafka-producer.iml

4.5 KB

pom.xml

1.2 KB

/15/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/15/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/15/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/15/kafka/

kafka.iml

1.0 KB

pom.xml

0.5 KB

/15/mdc-interceptor/

mdc-interceptor.iml

2.2 KB

pom.xml

1.3 KB

/15/mdc-interceptor/src/main/java/com/microservices/demo/mdc/

Constants.java

0.2 KB

/15/mdc-interceptor/src/main/java/com/microservices/demo/mdc/config/

IdGeneratorConfig.java

0.4 KB

WebMvcConfig.java

0.7 KB

/15/mdc-interceptor/src/main/java/com/microservices/demo/mdc/interceptor/

MDCHandlerInterceptor.java

1.5 KB

/.../reactive-elastic-query-service/

pom.xml

2.8 KB

reactive-elastic-query-service.iml

17.3 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplication.java

0.5 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/api/

ElasticDocumentController.java

1.8 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/

ElasticQueryService.java

0.3 KB

ReactiveElasticQueryClient.java

0.4 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/impl/

TwitterElasticQueryService.java

1.7 KB

TwitterReactiveElasticQueryClient.java

1.6 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/config/

WebSecurityConfig.java

0.7 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/repository/

ElasticQueryRepository.java

0.5 KB

/.../reactive-elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-service/src/test/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplicationTests.java

0.3 KB

/.../reactive-elastic-query-web-client/

pom.xml

2.8 KB

reactive-elastic-query-web-client.iml

12.9 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplication.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/api/

QueryController.java

2.4 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/config/

WebClientConfig.java

2.1 KB

WebSecurityConfig.java

0.6 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.4 KB

/.../reactive-elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

1.1 KB

home.html

2.1 KB

index.html

0.2 KB

/.../reactive-elastic-query-web-client/src/test/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.3 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback-spring.xml

0.3 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/16/

001 Introducing Spring Cloud Sleuth and Zipkin.mp4

21.3 MB

001 Introducing Spring Cloud Sleuth and Zipkin_en.srt

5.9 KB

002 Integrating Spring Cloud Sleuth and Zipkin.mp4

85.1 MB

002 Integrating Spring Cloud Sleuth and Zipkin_en.srt

13.3 KB

32579314-sleuth-zipkin.pptx

101.2 KB

32826616-push-docker-image-to-registry.mp4

34.4 MB

HELP.md

0.4 KB

README.md

0.6 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

12.7 KB

/16/analytics-service/

analytics-service.iml

27.7 KB

pom.xml

4.4 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/

AnalyticsApplication.java

0.6 KB

Constants.java

0.1 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/api/

AnalyticsController.java

2.2 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/

AnalyticsService.java

0.3 KB

KafkaConsumer.java

0.3 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/impl/

AnalyticsKafkaConsumer.java

3.7 KB

TwitterAnalyticsService.java

1.3 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/config/

WebSecurityConfig.java

3.6 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/entity/

AnalyticsEntity.java

1.3 KB

BaseEntity.java

0.1 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/

AnalyticsCustomRepository.java

0.5 KB

AnalyticsRepository.java

0.8 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/impl/

AnalyticsRepositoryImpl.java

2.6 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/model/

AnalyticsResponseModel.java

0.4 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/security/

AnalyticsUser.java

1.2 KB

AnalyticsUserDetailsService.java

0.6 KB

AnalyticsUserJwtConverter.java

3.4 KB

AudienceValidator.java

1.4 KB

/16/analytics-service/src/main/java/com/microservices/demo/analytics/service/transformer/

AvroToDbEntityModelTransformer.java

1.2 KB

EntityToResponseModelTransformer.java

0.8 KB

/16/analytics-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.6 KB

logback-spring.xml

0.3 KB

/.../app-config-data/

app-config-data.iml

2.1 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

AnalyticsServiceConfigData.java

0.4 KB

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

1.0 KB

ElasticQueryWebClientConfigData.java

1.1 KB

GatewayServiceConfigData.java

0.6 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

KafkaStreamsConfigData.java

0.5 KB

KafkaStreamsServiceConfigData.java

0.4 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

2.4 KB

/16/common-config/

common-config.iml

3.6 KB

pom.xml

1.2 KB

/16/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/16/common-util/

common-util.iml

1.1 KB

pom.xml

0.5 KB

/16/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-analytics.yml

2.4 KB

config-client-elastic_query.yml

2.9 KB

config-client-elastic_query_web.yml

1.5 KB

config-client-elastic_query_web_2.yml

1.5 KB

config-client-gateway.yml

2.7 KB

config-client-kafka_streams.yml

1.4 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-reactive_elastic_query.yml

0.8 KB

config-client-reactive_elastic_query_web.yml

0.6 KB

config-client-twitter_to_kafka.yml

1.1 KB

config-client.yml

0.1 KB

/16/config-server/

config-server.iml

8.4 KB

pom.xml

1.9 KB

/16/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/16/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/16/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback-spring.xml

0.3 KB

/16/discovery-service/

discovery-service.iml

15.9 KB

pom.xml

1.7 KB

/16/discovery-service/src/main/java/com/microservices/demo/discovery/service/

ServiceRegistrationAndDiscoveryServiceApplication.java

0.5 KB

/16/discovery-service/src/main/resources/

application-singleserver.yml

0.3 KB

application.yml

1.1 KB

logback-spring.xml

2.5 KB

/16/docker-compose/

DS_Store

6.1 KB

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

check-keycloak-server-started.sh

0.5 KB

common.yml

0.1 KB

elastic_cluster.yml

2.6 KB

env

0.4 KB

kafka_cluster.yml

2.7 KB

keycloak_authorization_server.yml

0.5 KB

monitoring.yml

0.6 KB

redis_cluster.yml

0.5 KB

services.yml

19.4 KB

zipkin.yml

0.7 KB

/16/docker-compose/config/

logback.conf

0.2 KB

prometheus.yml

1.1 KB

/.../elastic-query-service-common/

elastic-query-service-common.iml

10.6 KB

pom.xml

1.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/exception/

ElasticQueryServiceException.java

0.4 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/transformer/

ElasticToResponseModelTransformer.java

1.1 KB

/.../elastic-query-service/

elastic-query-service.iml

34.7 KB

pom.xml

5.0 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

Constants.java

0.1 KB

ElasticQueryServiceApplication.java

0.6 KB

QueryType.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

7.6 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.6 KB

QueryUserService.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

6.7 KB

TwitterQueryUserService.java

1.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebClientConfig.java

2.6 KB

WebSecurityConfig.java

3.7 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/entity/

UserPermission.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/repository/

UserPermissionRepository.java

0.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceAnalyticsResponseModel.java

0.5 KB

ElasticQueryServiceResponseModelV2.java

0.5 KB

ElasticQueryServiceWordCountResponseModel.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/security/

AudienceValidator.java

1.4 KB

PermissionType.java

0.3 KB

QueryServicePermissionEvaluator.java

3.8 KB

TwitterQueryUser.java

1.3 KB

TwitterQueryUserDetailsService.java

1.5 KB

TwitterQueryUserJwtConverter.java

3.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

UserPermissionsToUserDetailTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.6 KB

init-data.sql

1.8 KB

init-schema.sql

1.6 KB

logback-spring.xml

0.3 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client-2/

elastic-query-web-client-2.iml

21.9 KB

pom.xml

3.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.7 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.6 KB

/.../elastic-query-web-client-2/src/main/resources/

application.yml

0.2 KB

bootstrap.yml

0.6 KB

logback-spring.xml

0.3 KB

/.../elastic-query-web-client-2/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client-common/

elastic-query-web-client-common.iml

4.1 KB

pom.xml

1.5 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/model/

ElasticQueryWebClientAnalyticsResponseModel.java

0.5 KB

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/

elastic-query-web-client.iml

26.1 KB

pom.xml

4.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.2 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.6 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

4.0 KB

/.../elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.6 KB

logback-spring.xml

0.3 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.3 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/16/elastic/elastic-config/

elastic-config.iml

9.1 KB

pom.xml

1.3 KB

/16/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.1 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/16/elastic/elastic-model/

elastic-model.iml

9.1 KB

pom.xml

0.9 KB

/16/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/16/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.3 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/16/elastic/

elastic.iml

1.0 KB

pom.xml

0.8 KB

/16/gateway-service/

gateway-service.iml

23.0 KB

pom.xml

3.6 KB

/16/gateway-service/src/main/java/com/microservices/demo/gateway/service/

GatewayServiceApplication.java

0.6 KB

/16/gateway-service/src/main/java/com/microservices/demo/gateway/service/config/

GatewayConfig.java

3.4 KB

WebSecurityConfig.java

0.7 KB

/16/gateway-service/src/main/java/com/microservices/demo/gateway/service/controller/

FallbackController.java

1.9 KB

/16/gateway-service/src/main/java/com/microservices/demo/gateway/service/model/

AnalyticsDataFallbackModel.java

0.3 KB

QueryServiceFallbackModel.java

0.3 KB

/16/gateway-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.5 KB

logback-spring.xml

0.3 KB

/.../kafka-streams-service/

kafka-streams-service.iml

26.2 KB

pom.xml

4.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/

Constants.java

0.1 KB

KafkaStreamsServiceApplication.java

1.4 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/api/

KafkaStreamsController.java

2.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/config/

KafkaStreamsConfig.java

1.9 KB

WebSecurityConfig.java

3.7 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/

StreamsInitializer.java

0.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/impl/

KafkaStreamsInitializer.java

1.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/model/

KafkaStreamsResponseModel.java

0.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/

StreamsRunner.java

0.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/impl/

KafkaStreamsRunner.java

6.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/security/

AudienceValidator.java

1.4 KB

KafkaStreamsUser.java

1.2 KB

KafkaStreamsUserDetailsService.java

0.6 KB

KafkaStreamsUserJwtConverter.java

3.6 KB

/.../kafka-streams-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.6 KB

logback-spring.xml

0.3 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

18.7 KB

pom.xml

3.3 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.3 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback-spring.xml

0.3 KB

/16/kafka/kafka-admin/

kafka-admin.iml

7.2 KB

pom.xml

1.2 KB

/16/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/16/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/16/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/16/kafka/kafka-consumer/

kafka-consumer.iml

3.2 KB

pom.xml

1.1 KB

/16/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/16/kafka/kafka-model/

kafka-model.iml

1.5 KB

pom.xml

1.7 KB

/16/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAnalyticsAvroModel.java

16.6 KB

TwitterAvroModel.java

17.5 KB

/16/kafka/kafka-model/src/main/resources/avro/

twitter-analytics.avsc

0.3 KB

twitter.avsc

0.3 KB

/16/kafka/kafka-producer/

kafka-producer.iml

4.5 KB

pom.xml

1.2 KB

/16/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/16/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/16/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/16/kafka/

kafka.iml

1.0 KB

pom.xml

0.5 KB

/16/mdc-interceptor/

mdc-interceptor.iml

2.2 KB

pom.xml

1.3 KB

/16/mdc-interceptor/src/main/java/com/microservices/demo/mdc/

Constants.java

0.2 KB

/16/mdc-interceptor/src/main/java/com/microservices/demo/mdc/config/

IdGeneratorConfig.java

0.4 KB

WebMvcConfig.java

0.7 KB

/16/mdc-interceptor/src/main/java/com/microservices/demo/mdc/interceptor/

MDCHandlerInterceptor.java

1.5 KB

/.../reactive-elastic-query-service/

pom.xml

2.8 KB

reactive-elastic-query-service.iml

17.3 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplication.java

0.5 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/api/

ElasticDocumentController.java

1.8 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/

ElasticQueryService.java

0.3 KB

ReactiveElasticQueryClient.java

0.4 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/impl/

TwitterElasticQueryService.java

1.7 KB

TwitterReactiveElasticQueryClient.java

1.6 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/config/

WebSecurityConfig.java

0.7 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/repository/

ElasticQueryRepository.java

0.5 KB

/.../reactive-elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-service/src/test/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplicationTests.java

0.3 KB

/.../reactive-elastic-query-web-client/

pom.xml

2.8 KB

reactive-elastic-query-web-client.iml

12.9 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplication.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/api/

QueryController.java

2.4 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/config/

WebClientConfig.java

2.1 KB

WebSecurityConfig.java

0.6 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.4 KB

/.../reactive-elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

1.1 KB

home.html

2.1 KB

index.html

0.2 KB

/.../reactive-elastic-query-web-client/src/test/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/

pom.xml

2.9 KB

twitter-to-kafka-service.iml

17.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback-spring.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/17/

001 Update to spring boot 2.5.0.mp4

89.5 MB

001 Update to spring boot 2.5.0_en.srt

9.3 KB

001 Update to spring boot 2.5.0_en.vtt

13.5 KB

002 Update to spring boot 2.5.3 & Update other dependencies and docker images.mp4

184.8 MB

002 Update to spring boot 2.5.3 & Update other dependencies and docker images_en.srt

17.6 KB

003 Update to spring boot 2.5.6.mp4

50.3 MB

003 Update to spring boot 2.5.6_en.srt

6.9 KB

HELP.md

0.4 KB

README.md

0.6 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

12.8 KB

/17/analytics-service/

analytics-service.iml

27.7 KB

pom.xml

4.4 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/

AnalyticsApplication.java

0.6 KB

Constants.java

0.1 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/api/

AnalyticsController.java

2.2 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/

AnalyticsService.java

0.3 KB

KafkaConsumer.java

0.3 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/business/impl/

AnalyticsKafkaConsumer.java

3.7 KB

TwitterAnalyticsService.java

1.3 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/config/

WebSecurityConfig.java

3.6 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/entity/

AnalyticsEntity.java

1.3 KB

BaseEntity.java

0.1 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/

AnalyticsCustomRepository.java

0.5 KB

AnalyticsRepository.java

0.8 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/dataaccess/repository/impl/

AnalyticsRepositoryImpl.java

2.6 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/model/

AnalyticsResponseModel.java

0.4 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/security/

AnalyticsUser.java

1.2 KB

AnalyticsUserDetailsService.java

0.6 KB

AnalyticsUserJwtConverter.java

3.4 KB

AudienceValidator.java

1.4 KB

/17/analytics-service/src/main/java/com/microservices/demo/analytics/service/transformer/

AvroToDbEntityModelTransformer.java

1.2 KB

EntityToResponseModelTransformer.java

0.8 KB

/17/analytics-service/src/main/resources/

application.yml

0.6 KB

logback-spring.xml

0.3 KB

/.../app-config-data/

app-config-data.iml

2.1 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

AnalyticsServiceConfigData.java

0.4 KB

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

1.0 KB

ElasticQueryWebClientConfigData.java

1.1 KB

GatewayServiceConfigData.java

0.6 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

KafkaStreamsConfigData.java

0.5 KB

KafkaStreamsServiceConfigData.java

0.4 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

2.4 KB

/17/common-config/

common-config.iml

3.6 KB

pom.xml

1.2 KB

/17/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/17/common-util/

common-util.iml

1.1 KB

pom.xml

0.5 KB

/17/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-analytics.yml

2.4 KB

config-client-elastic_query.yml

2.9 KB

config-client-elastic_query_web.yml

1.5 KB

config-client-elastic_query_web_2.yml

1.5 KB

config-client-gateway.yml

2.7 KB

config-client-kafka_streams.yml

1.4 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-reactive_elastic_query.yml

0.8 KB

config-client-reactive_elastic_query_web.yml

0.6 KB

config-client-twitter_to_kafka.yml

1.1 KB

config-client.yml

0.1 KB

/17/config-server/

config-server.iml

8.3 KB

pom.xml

1.9 KB

/17/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/17/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/17/config-server/src/main/resources/

application.yml

0.6 KB

logback-spring.xml

0.3 KB

/17/discovery-service/

discovery-service.iml

15.9 KB

pom.xml

1.7 KB

/17/discovery-service/src/main/java/com/microservices/demo/discovery/service/

ServiceRegistrationAndDiscoveryServiceApplication.java

0.5 KB

/17/discovery-service/src/main/resources/

application-singleserver.yml

0.3 KB

application.yml

1.1 KB

logback-spring.xml

2.5 KB

/17/docker-compose/

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

check-keycloak-server-started.sh

0.5 KB

common.yml

0.1 KB

elastic_cluster.yml

2.7 KB

env

0.4 KB

kafka_cluster.yml

2.7 KB

keycloak_authorization_server.yml

0.5 KB

monitoring.yml

0.6 KB

redis_cluster.yml

0.5 KB

services.yml

19.4 KB

zipkin.yml

0.7 KB

/17/docker-compose/config/

logback.conf

0.2 KB

prometheus.yml

1.1 KB

/.../elastic-query-service-common/

elastic-query-service-common.iml

10.6 KB

pom.xml

1.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/exception/

ElasticQueryServiceException.java

0.4 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/transformer/

ElasticToResponseModelTransformer.java

1.1 KB

/.../elastic-query-service/

elastic-query-service.iml

34.7 KB

pom.xml

5.0 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

Constants.java

0.1 KB

ElasticQueryServiceApplication.java

0.6 KB

QueryType.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

7.6 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.6 KB

QueryUserService.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

6.7 KB

TwitterQueryUserService.java

1.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebClientConfig.java

2.6 KB

WebSecurityConfig.java

3.7 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/entity/

UserPermission.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/repository/

UserPermissionRepository.java

0.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceAnalyticsResponseModel.java

0.5 KB

ElasticQueryServiceResponseModelV2.java

0.5 KB

ElasticQueryServiceWordCountResponseModel.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/security/

AudienceValidator.java

1.4 KB

PermissionType.java

0.3 KB

QueryServicePermissionEvaluator.java

3.8 KB

TwitterQueryUser.java

1.3 KB

TwitterQueryUserDetailsService.java

1.5 KB

TwitterQueryUserJwtConverter.java

3.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

UserPermissionsToUserDetailTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.6 KB

init-data.sql

1.8 KB

init-schema.sql

1.6 KB

logback-spring.xml

0.3 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client-2/

elastic-query-web-client-2.iml

21.9 KB

pom.xml

3.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.7 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.6 KB

/.../elastic-query-web-client-2/src/main/resources/

application.yml

0.2 KB

bootstrap.yml

0.6 KB

logback-spring.xml

0.3 KB

/.../elastic-query-web-client-2/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client-common/

elastic-query-web-client-common.iml

4.1 KB

pom.xml

1.5 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/model/

ElasticQueryWebClientAnalyticsResponseModel.java

0.5 KB

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/

elastic-query-web-client.iml

26.1 KB

pom.xml

4.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.2 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

WebClientConfig.java

3.6 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.6 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

4.0 KB

/.../elastic-query-web-client/src/main/resources/

application.yml

0.6 KB

logback-spring.xml

0.3 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.3 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/17/elastic/elastic-config/

elastic-config.iml

9.1 KB

pom.xml

1.3 KB

/17/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.1 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.4 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/17/elastic/elastic-model/

elastic-model.iml

9.0 KB

pom.xml

0.9 KB

/17/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/17/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.3 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/17/elastic/

elastic.iml

1.0 KB

pom.xml

0.8 KB

/17/gateway-service/

gateway-service.iml

23.0 KB

pom.xml

3.6 KB

/17/gateway-service/src/main/java/com/microservices/demo/gateway/service/

GatewayServiceApplication.java

0.6 KB

/17/gateway-service/src/main/java/com/microservices/demo/gateway/service/config/

GatewayConfig.java

3.4 KB

WebSecurityConfig.java

0.7 KB

/17/gateway-service/src/main/java/com/microservices/demo/gateway/service/controller/

FallbackController.java

1.9 KB

/17/gateway-service/src/main/java/com/microservices/demo/gateway/service/model/

AnalyticsDataFallbackModel.java

0.3 KB

QueryServiceFallbackModel.java

0.3 KB

/17/gateway-service/src/main/resources/

application.yml

0.6 KB

logback-spring.xml

0.3 KB

/.../kafka-streams-service/

kafka-streams-service.iml

26.2 KB

pom.xml

4.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/

Constants.java

0.1 KB

KafkaStreamsServiceApplication.java

1.4 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/api/

KafkaStreamsController.java

2.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/config/

KafkaStreamsConfig.java

1.9 KB

WebSecurityConfig.java

3.7 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/

StreamsInitializer.java

0.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/init/impl/

KafkaStreamsInitializer.java

1.1 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/model/

KafkaStreamsResponseModel.java

0.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/

StreamsRunner.java

0.2 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/runner/impl/

KafkaStreamsRunner.java

6.3 KB

/.../kafka-streams-service/src/main/java/com/microservices/demo/kafka/streams/service/security/

AudienceValidator.java

1.4 KB

KafkaStreamsUser.java

1.2 KB

KafkaStreamsUserDetailsService.java

0.6 KB

KafkaStreamsUserJwtConverter.java

3.6 KB

/.../kafka-streams-service/src/main/resources/

application.yml

0.6 KB

logback-spring.xml

0.3 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

18.7 KB

pom.xml

3.4 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.3 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.4 KB

logback-spring.xml

0.3 KB

/17/kafka/kafka-admin/

kafka-admin.iml

7.2 KB

pom.xml

1.2 KB

/17/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/17/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/17/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/17/kafka/kafka-consumer/

kafka-consumer.iml

3.2 KB

pom.xml

1.1 KB

/17/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/17/kafka/kafka-model/

kafka-model.iml

1.5 KB

pom.xml

1.7 KB

/17/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAnalyticsAvroModel.java

16.6 KB

TwitterAvroModel.java

17.5 KB

/17/kafka/kafka-model/src/main/resources/avro/

twitter-analytics.avsc

0.3 KB

twitter.avsc

0.3 KB

/17/kafka/kafka-producer/

kafka-producer.iml

4.5 KB

pom.xml

1.2 KB

/17/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/17/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/17/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/17/kafka/

kafka.iml

1.0 KB

pom.xml

0.5 KB

/17/mdc-interceptor/

mdc-interceptor.iml

2.2 KB

pom.xml

1.3 KB

/17/mdc-interceptor/src/main/java/com/microservices/demo/mdc/

Constants.java

0.2 KB

/17/mdc-interceptor/src/main/java/com/microservices/demo/mdc/config/

IdGeneratorConfig.java

0.4 KB

WebMvcConfig.java

0.7 KB

/17/mdc-interceptor/src/main/java/com/microservices/demo/mdc/interceptor/

MDCHandlerInterceptor.java

1.5 KB

/.../reactive-elastic-query-service/

pom.xml

2.8 KB

reactive-elastic-query-service.iml

17.3 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplication.java

0.5 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/api/

ElasticDocumentController.java

1.8 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/

ElasticQueryService.java

0.3 KB

ReactiveElasticQueryClient.java

0.4 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/impl/

TwitterElasticQueryService.java

1.7 KB

TwitterReactiveElasticQueryClient.java

1.6 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/config/

WebSecurityConfig.java

0.7 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/repository/

ElasticQueryRepository.java

0.5 KB

/.../reactive-elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-service/src/test/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplicationTests.java

0.3 KB

/.../reactive-elastic-query-web-client/

pom.xml

2.8 KB

reactive-elastic-query-web-client.iml

12.9 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplication.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/api/

QueryController.java

2.4 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/config/

WebClientConfig.java

2.1 KB

WebSecurityConfig.java

0.6 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.4 KB

/.../reactive-elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

1.1 KB

home.html

2.1 KB

index.html

0.2 KB

/.../reactive-elastic-query-web-client/src/test/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/

pom.xml

3.0 KB

twitter-to-kafka-service.iml

17.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.4 KB

logback-spring.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/logs/logstash/

twitter-to-kafka-service.log

414.9 KB

/.../twitter-to-kafka-service/logs/

twitter-to-kafka-service.log

381.1 KB

/2/

001 Setting up the environment.mp4

30.6 MB

001 Setting up the environment_en.srt

6.5 KB

32579140-setup.pptx

308.0 KB

/3/

001 Introduction to Spring boot.mp4

21.1 MB

001 Introduction to Spring boot_en.srt

4.6 KB

002 Creating the base Spring boot project.mp4

37.2 MB

002 Creating the base Spring boot project_en.srt

13.3 KB

003 The very first microservice.mp4

99.7 MB

003 The very first microservice_en.srt

19.1 KB

004 Streaming tweets with Twitter4j_ The command component in CQRS & Event sourcing.mp4

137.9 MB

004 Streaming tweets with Twitter4j_ The command component in CQRS & Event sourcing_en.srt

14.2 KB

005 Adding mock twitter stream as an alternative.mp4

113.0 MB

005 Adding mock twitter stream as an alternative_en.srt

14.8 KB

006 Introducing Apache Kafka_Event sourcing, topics, partitions, producer & consumer.mp4

95.4 MB

006 Introducing Apache Kafka_Event sourcing, topics, partitions, producer & consumer_en.srt

17.1 KB

007 Adding common config module.mp4

22.6 MB

007 Adding common config module_en.srt

6.8 KB

008 Running Apache Kafka cluster with docker_ Kafka, Zookeeper and Schema Registry.mp4

28.9 MB

008 Running Apache Kafka cluster with docker_ Kafka, Zookeeper and Schema Registry_en.srt

11.0 KB

009 Creating kafka-model module.mp4

10.9 MB

009 Creating kafka-model module_en.srt

3.3 KB

010 Creating kafka-admin module - Part 1_ Configuration and dependencies.mp4

56.7 MB

010 Creating kafka-admin module - Part 1_ Configuration and dependencies_en.srt

10.2 KB

011 Creating kafka-admin module - Part 2_ Creating Kafka topics programmatically.mp4

51.5 MB

011 Creating kafka-admin module - Part 2_ Creating Kafka topics programmatically_en.srt

14.3 KB

012 Creating kafka-producer module_ Configuration of Kafka producer.mp4

30.7 MB

012 Creating kafka-producer module_ Configuration of Kafka producer_en.srt

6.3 KB

013 Creating kafka-producer module_ Produce events to store in Kafka event store.mp4

24.8 MB

013 Creating kafka-producer module_ Produce events to store in Kafka event store_en.srt

7.3 KB

014 Integrate Kafka modules with Microservice_ Use Kafka as event store for service.mp4

36.1 MB

014 Integrate Kafka modules with Microservice_ Use Kafka as event store for service_en.srt

8.9 KB

015 Containerization of microservice with docker image_ Run all with docker compose.mp4

52.6 MB

015 Containerization of microservice with docker image_ Run all with docker compose_en.srt

9.7 KB

31895130-microservices-demo.zip

28.5 KB

32579146-spring-boot.pptx

98.1 KB

32579160-kafka.pptx

145.5 KB

mvnw

10.1 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

KafkaConfigData.java

0.6 KB

KafkaProducerConfigData.java

0.6 KB

RetryConfigData.java

0.5 KB

/3/common-config/

common-config.iml

1.7 KB

pom.xml

1.0 KB

/3/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/3/docker-compose/

common.yml

0.1 KB

env

0.2 KB

kafka_cluster.yml

2.7 KB

services.yml

0.8 KB

/3/kafka/kafka-admin/

kafka-admin.iml

0.6 KB

pom.xml

0.6 KB

/3/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/3/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

WebClientConfiguration.java

0.4 KB

/3/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/client/

KafkaAdminClient.java

1.1 KB

/3/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/3/kafka/kafka-model/

kafka-model.iml

0.6 KB

pom.xml

0.6 KB

/3/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAvroModel.java

17.5 KB

/3/kafka/kafka-model/src/main/resources/avro/

twitter.avsc

0.3 KB

/3/kafka/kafka-producer/

kafka-producer.iml

0.6 KB

pom.xml

0.6 KB

/3/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/3/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/3/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/3/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/3/kafka/target/

kafka-0.0.1-SNAPSHOT.jar

1.5 KB

/3/kafka/target/maven-archiver/

pom.properties

0.1 KB

/.../twitter-to-kafka-service/

pom.xml

1.5 KB

twitter-to-kafka-service.iml

11.8 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.6 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/config/

TwitterToKafkaServiceConfigData.java

0.6 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.0 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

0.5 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.3 KB

logback.xml

1.7 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/4/

001 Creating Config Server Repository.mp4

5.5 MB

001 Creating Config Server Repository_en.srt

3.0 KB

002 Creating Spring Cloud Config Server as a Microservice.mp4

12.1 MB

002 Creating Spring Cloud Config Server as a Microservice_en.srt

5.4 KB

003 Using a common logback file for all microservices.mp4

5.9 MB

003 Using a common logback file for all microservices_en.srt

3.3 KB

004 Changing twitter-to-kafka-service to work with config server.mp4

12.9 MB

004 Changing twitter-to-kafka-service to work with config server_en.srt

3.9 KB

005 Using remote GitHub repository.mp4

29.9 MB

005 Using remote GitHub repository_en.srt

5.2 KB

006 Adding security to config server and encrypt passwords.mp4

5.4 MB

006 Adding security to config server and encrypt passwords_en.srt

2.5 KB

007 Using Jasypt to encrypt sensitive data.mp4

25.9 MB

007 Using Jasypt to encrypt sensitive data_en.srt

8.3 KB

008 Using JCE to encrypt sensitive data.mp4

23.0 MB

008 Using JCE to encrypt sensitive data_en.srt

6.5 KB

009 JCE vs Jasypt.mp4

14.8 MB

009 JCE vs Jasypt_en.srt

5.1 KB

010 Containerization of config server by creating the docker image.mp4

25.1 MB

010 Containerization of config server by creating the docker image_en.srt

7.9 KB

32537100-lecture-23-run-project.mp4

25.3 MB

HELP.md

0.4 KB

README.md

0.3 KB

gitignore

0.4 KB

microservices-demo.iml

0.6 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

5.4 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

KafkaConfigData.java

0.6 KB

KafkaProducerConfigData.java

0.6 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/4/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/4/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/.../config-server-repository/

config-client-twitter_to_kafka.yml

1.0 KB

config-client.yml

0.1 KB

/4/config-server/

config-server.iml

7.7 KB

pom.xml

1.0 KB

/4/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/4/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.6 KB

/4/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.2 KB

logback.xml

0.2 KB

/4/docker-compose/

check-config-server-started.sh

0.5 KB

common.yml

0.1 KB

env

0.2 KB

kafka_cluster.yml

2.7 KB

services.yml

0.8 KB

/4/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/4/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/4/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/4/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/4/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/4/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAvroModel.java

17.5 KB

/4/kafka/kafka-model/src/main/resources/avro/

twitter.avsc

0.3 KB

/4/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/4/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/4/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/4/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/4/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/4/playground/

playground.iml

1.0 KB

pom.xml

0.7 KB

/4/playground/src/main/java/jasypt/

TestJasypt.java

0.7 KB

/4/playground/target/classes/jasypt/

TestJasypt.class

1.1 KB

/.../twitter-to-kafka-service/

DS_Store

6.1 KB

pom.xml

2.3 KB

twitter-to-kafka-service.iml

12.3 KB

/.../twitter-to-kafka-service/src/

DS_Store

6.1 KB

/.../twitter-to-kafka-service/src/main/

DS_Store

6.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.2 KB

logback.xml

1.7 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/5/

001 Introduction to Kafka Consumer_ Reading data events from Kafka using messaging.mp4

26.4 MB

001 Introduction to Kafka Consumer_ Reading data events from Kafka using messaging_en.srt

7.8 KB

002 Adding kafka-consumer module.mp4

34.5 MB

002 Adding kafka-consumer module_en.srt

11.1 KB

003 Creating the microservice_ kafka-to-elastic-service.mp4

39.2 MB

003 Creating the microservice_ kafka-to-elastic-service_en.srt

10.6 KB

004 Adding initialization check.mp4

8.0 MB

004 Adding initialization check_en.srt

2.0 KB

005 Introducing Elasticsearch.mp4

17.1 MB

005 Introducing Elasticsearch_en.srt

3.8 KB

006 Running elastic search with docker.mp4

28.9 MB

006 Running elastic search with docker_en.srt

5.9 KB

007 Creating elastic-model module.mp4

29.4 MB

007 Creating elastic-model module_en.srt

5.3 KB

008 Creating elastic-config module.mp4

10.5 MB

008 Creating elastic-config module_en.srt

2.9 KB

009 Creating elastic-index-client module.mp4

15.1 MB

009 Creating elastic-index-client module_en.srt

5.7 KB

010 Using Elasticsearch repositories for indexing.mp4

41.5 MB

010 Using Elasticsearch repositories for indexing_en.srt

6.4 KB

011 Integrating elastic modules with microservice.mp4

44.8 MB

011 Integrating elastic modules with microservice_en.srt

6.1 KB

012 Containerization of microservice with docker image_ Run all with docker compose.mp4

36.9 MB

012 Containerization of microservice with docker image_ Run all with docker compose_en.srt

7.1 KB

32579174-kafka-consumer.pptx

164.8 KB

32579196-elastic.pptx

135.6 KB

33881814-elastic-mapping.json

0.8 KB

HELP.md

0.4 KB

README.md

0.4 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

7.7 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

ElasticConfigData.java

0.4 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/5/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/5/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/.../config-server-repository/

config-client-kafka_to_elastic.yml

1.2 KB

config-client-twitter_to_kafka.yml

1.0 KB

config-client.yml

0.1 KB

/5/config-server/

DS_Store

6.1 KB

config-server.iml

8.2 KB

pom.xml

1.9 KB

/5/config-server/src/

DS_Store

6.1 KB

/5/config-server/src/main/

DS_Store

6.1 KB

/5/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/5/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/5/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/5/docker-compose/

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

common.yml

0.1 KB

elastic_cluster.yml

1.8 KB

env

0.2 KB

kafka_cluster.yml

2.7 KB

services.yml

2.8 KB

/5/elastic/elastic-config/

elastic-config.iml

9.0 KB

pom.xml

1.3 KB

/5/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.2 KB

/.../elastic-index-client/

elastic-index-client.iml

9.0 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/5/elastic/elastic-model/

elastic-model.iml

8.9 KB

pom.xml

0.9 KB

/5/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/5/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/5/elastic/

elastic.iml

0.6 KB

pom.xml

0.7 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.6 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.4 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/5/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/5/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/5/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/5/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/5/kafka/kafka-consumer/

kafka-consumer.iml

3.1 KB

pom.xml

1.1 KB

/5/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/5/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/5/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAvroModel.java

17.5 KB

/5/kafka/kafka-model/src/main/resources/avro/

twitter.avsc

0.3 KB

/5/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/5/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/5/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/5/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/5/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/.../twitter-to-kafka-service/

DS_Store

6.1 KB

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.2 KB

/.../twitter-to-kafka-service/src/

DS_Store

6.1 KB

/.../twitter-to-kafka-service/src/main/

DS_Store

6.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/6/

001 Introduction to Elastic Query Api.mp4

76.0 MB

001 Introduction to Elastic Query Api_en.srt

8.5 KB

002 Creating elastic-query-client module.mp4

36.4 MB

002 Creating elastic-query-client module_en.srt

6.9 KB

003 Using spring data elasticsearch repository for querying.mp4

11.5 MB

003 Using spring data elasticsearch repository for querying_en.srt

6.5 KB

004 Elastic query microservice_ The query component in CQRS & Event sourcing.mp4

26.4 MB

004 Elastic query microservice_ The query component in CQRS & Event sourcing_en.srt

4.8 KB

005 Creating web controller.mp4

60.7 MB

005 Creating web controller_en.srt

15.8 KB

006 Creating business layer to return elastic data in controller.mp4

10.6 MB

006 Creating business layer to return elastic data in controller_en.srt

3.8 KB

007 Creating validation and controller advice.mp4

8.9 MB

007 Creating validation and controller advice_en.srt

4.6 KB

008 Introduction to Hateoas (Hypermedia as the Engine of Application State).mp4

8.6 MB

008 Introduction to Hateoas (Hypermedia as the Engine of Application State)_en.srt

2.5 KB

009 Adding Hateoas capability to Rest API with Spring Hateoas.mp4

22.8 MB

009 Adding Hateoas capability to Rest API with Spring Hateoas_en.srt

3.4 KB

010 Introduction to Api versioning of Rest API.mp4

26.7 MB

010 Introduction to Api versioning of Rest API_en.srt

6.8 KB

011 Implementing Api versioning for elastic query service Rest API.mp4

18.6 MB

011 Implementing Api versioning for elastic query service Rest API_en.srt

6.7 KB

012 Enabling Open Api v3 for documentation of RESTful API with Swagger v3.mp4

47.1 MB

012 Enabling Open Api v3 for documentation of RESTful API with Swagger v3_en.srt

6.2 KB

013 Containerization of microservice by creating the docker image.mp4

5.1 MB

013 Containerization of microservice by creating the docker image_en.srt

1.9 KB

30806306-section-6-lecture-6.mp4

121.3 MB

32579200-elastic-query.pptx

156.2 KB

32579204-hateoas.pptx

69.5 KB

32579222-api-versioning.pptx

72.1 KB

32579240-api-docs.pptx

74.4 KB

HELP.md

0.4 KB

README.md

0.5 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

8.4 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

0.4 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/6/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/6/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/6/common-util/

common-util.iml

0.7 KB

pom.xml

0.5 KB

/6/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-elastic_query.yml

0.5 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-twitter_to_kafka.yml

1.0 KB

config-client.yml

0.1 KB

/6/config-server/

config-server.iml

8.2 KB

pom.xml

1.9 KB

/6/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/6/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/6/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/6/docker-compose/

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

common.yml

0.1 KB

elastic_cluster.yml

1.8 KB

env

0.2 KB

kafka_cluster.yml

2.7 KB

services.yml

3.9 KB

/.../elastic-query-service/

elastic-query-service.iml

17.7 KB

pom.xml

3.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplication.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

6.0 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.4 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

2.2 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebSecurityConfig.java

2.2 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

ElasticQueryServiceResponseModelV2.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

ElasticToResponseModelTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.2 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/6/elastic/elastic-config/

elastic-config.iml

9.0 KB

pom.xml

1.3 KB

/6/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.0 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/6/elastic/elastic-model/

elastic-model.iml

8.9 KB

pom.xml

0.9 KB

/6/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/6/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.2 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/6/elastic/

elastic.iml

0.6 KB

pom.xml

0.8 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.6 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.4 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/6/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/6/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/6/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/6/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/6/kafka/kafka-consumer/

kafka-consumer.iml

3.3 KB

pom.xml

1.1 KB

/6/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/6/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/6/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAvroModel.java

17.5 KB

/6/kafka/kafka-model/src/main/resources/avro/

twitter.avsc

0.3 KB

/6/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/6/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/6/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/6/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/6/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/.../twitter-to-kafka-service/

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/7/

001 Introduction to Web clients.mp4

5.2 MB

001 Introduction to Web clients_en.srt

1.8 KB

002 Starting to implement elastic-query-web-client.mp4

7.5 MB

002 Starting to implement elastic-query-web-client_en.srt

3.9 KB

003 Creating Thymeleaf templates with Bootstrap.mp4

8.2 MB

003 Creating Thymeleaf templates with Bootstrap_en.srt

4.6 KB

004 Creating Rest API controller.mp4

11.5 MB

004 Creating Rest API controller_en.srt

6.5 KB

005 Creating configurations for web client and security.mp4

11.6 MB

005 Creating configurations for web client and security_en.srt

6.1 KB

006 Creating Webclient implementation.mp4

19.2 MB

006 Creating Webclient implementation_en.srt

6.7 KB

007 Adding client side load balancer with Spring Cloud Load Balancer.mp4

31.0 MB

007 Adding client side load balancer with Spring Cloud Load Balancer_en.srt

6.9 KB

008 Containerization of microservice by creating the docker image.mp4

10.5 MB

008 Containerization of microservice by creating the docker image_en.srt

1.8 KB

32579246-web-client.pptx

63.8 KB

HELP.md

0.4 KB

README.md

0.4 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

8.4 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

0.4 KB

ElasticQueryWebClientConfigData.java

0.7 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/.../app-config-data/target/classes/com/microservices/demo/config/

ElasticConfigData.class

3.6 KB

ElasticQueryConfigData.class

2.1 KB

ElasticQueryServiceConfigData.class

2.1 KB

ElasticQueryWebClientConfigData$Instance.class

2.9 KB

ElasticQueryWebClientConfigData$Query.class

2.8 KB

ElasticQueryWebClientConfigData$WebClient.class

6.5 KB

ElasticQueryWebClientConfigData.class

3.4 KB

KafkaConfigData.class

5.5 KB

KafkaConsumerConfigData.class

10.5 KB

KafkaProducerConfigData.class

6.1 KB

RetryConfigData.class

4.1 KB

TwitterToKafkaServiceConfigData.class

5.1 KB

UserConfigData.class

3.0 KB

/.../app-config-data/target/classes/

logback-common.xml

1.5 KB

/7/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/7/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/7/common-util/

common-util.iml

0.7 KB

pom.xml

0.5 KB

/7/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/7/common-util/target/classes/com/microservices/demo/common/util/

CollectionsUtil$CollectionsUtilHolder.class

0.7 KB

CollectionsUtil.class

1.9 KB

/.../config-server-repository/

config-client-elastic_query.yml

0.5 KB

config-client-elastic_query_web.yml

0.6 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-twitter_to_kafka.yml

1.0 KB

config-client.yml

0.1 KB

/7/config-server/

config-server.iml

8.2 KB

pom.xml

1.9 KB

/7/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/7/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/7/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/7/docker-compose/

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

common.yml

0.1 KB

elastic_cluster.yml

1.8 KB

env

0.2 KB

kafka_cluster.yml

2.7 KB

services.yml

3.9 KB

/.../elastic-query-service/

elastic-query-service.iml

17.7 KB

pom.xml

3.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplication.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

6.0 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.4 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

2.2 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebSecurityConfig.java

2.2 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

ElasticQueryServiceResponseModelV2.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

ElasticToResponseModelTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.2 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client/

DS_Store

6.1 KB

elastic-query-web-client.iml

13.4 KB

pom.xml

2.2 KB

/.../elastic-query-web-client/src/

DS_Store

6.1 KB

/.../elastic-query-web-client/src/main/

DS_Store

6.1 KB

/.../elastic-query-web-client/src/main/java/

DS_Store

6.1 KB

/.../elastic-query-web-client/src/main/java/com/

DS_Store

6.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/

DS_Store

6.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/

DS_Store

6.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/

DS_Store

6.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/

DS_Store

6.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/

DS_Store

6.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

DS_Store

6.1 KB

ElasticQueryWebClientApplication.java

0.5 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

DS_Store

6.1 KB

QueryController.java

1.9 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/error/

DS_Store

6.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

ElasticQueryServiceInstanceListSupplierConfig.java

1.6 KB

WebClientConfig.java

2.9 KB

WebSecurityConfig.java

2.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/model/

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.4 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.5 KB

/.../elastic-query-web-client/src/main/resources/

DS_Store

6.1 KB

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.1 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/7/elastic/elastic-config/

elastic-config.iml

9.0 KB

pom.xml

1.3 KB

/7/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/7/elastic/elastic-config/target/classes/com/microservices/demo/elastic/config/

ElasticsearchConfig.class

4.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.0 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/7/elastic/elastic-model/

elastic-model.iml

8.9 KB

pom.xml

0.9 KB

/7/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/7/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/7/elastic/elastic-model/target/classes/com/microservices/demo/elastic/model/index/

IndexModel.class

0.2 KB

/7/elastic/elastic-model/target/classes/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel$TwitterIndexModelBuilder.class

2.8 KB

TwitterIndexModel.class

4.7 KB

/.../elastic-query-client/

elastic-query-client.iml

9.2 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/.../elastic-query-client/target/classes/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.class

0.8 KB

/.../elastic-query-client/target/classes/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.class

0.8 KB

/.../elastic-query-client/target/classes/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.class

0.7 KB

/.../elastic-query-client/target/classes/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.class

8.0 KB

TwitterElasticRepositoryQueryClient.class

5.1 KB

/.../elastic-query-client/target/classes/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.class

2.4 KB

/7/elastic/

elastic.iml

0.6 KB

pom.xml

0.8 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.6 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.4 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/7/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/7/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/7/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/7/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/7/kafka/kafka-consumer/

kafka-consumer.iml

3.2 KB

pom.xml

1.1 KB

/7/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/7/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/7/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAvroModel.java

17.5 KB

/7/kafka/kafka-model/src/main/resources/avro/

twitter.avsc

0.3 KB

/7/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/7/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/7/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/7/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/7/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/.../twitter-to-kafka-service/

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/8/

001 Creating common service and web client modules to re-use them with DRY principle.mp4

10.4 MB

001 Creating common service and web client modules to re-use them with DRY principle_en.srt

4.5 KB

002 Creating reactive elastic query service_ Reactive Spring and Flux reactive type.mp4

37.3 MB

002 Creating reactive elastic query service_ Reactive Spring and Flux reactive type_en.srt

9.6 KB

003 Creating reactive elastic web client_ Reactive Spring, WebFlux and WebClient.mp4

28.9 MB

003 Creating reactive elastic web client_ Reactive Spring, WebFlux and WebClient_en.srt

7.1 KB

HELP.md

0.4 KB

README.md

0.4 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

9.2 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

0.4 KB

ElasticQueryWebClientConfigData.java

1.1 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/8/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/8/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/8/common-util/

common-util.iml

0.7 KB

pom.xml

0.5 KB

/8/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-elastic_query.yml

0.5 KB

config-client-elastic_query_web.yml

0.9 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-reactive_elastic_query.yml

0.8 KB

config-client-reactive_elastic_query_web.yml

0.6 KB

config-client-twitter_to_kafka.yml

1.0 KB

config-client.yml

0.1 KB

/8/config-server/

config-server.iml

8.2 KB

pom.xml

1.9 KB

/8/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/8/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/8/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/8/docker-compose/

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

common.yml

0.1 KB

elastic_cluster.yml

1.8 KB

env

0.2 KB

kafka_cluster.yml

2.7 KB

services.yml

6.3 KB

/.../elastic-query-service-common/

elastic-query-service-common.iml

10.5 KB

pom.xml

1.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/transformer/

ElasticToResponseModelTransformer.java

1.1 KB

/.../elastic-query-service/

elastic-query-service.iml

17.7 KB

pom.xml

3.2 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplication.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

6.2 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.4 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebSecurityConfig.java

2.2 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceResponseModelV2.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.2 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client-common/

DS_Store

6.1 KB

elastic-query-web-client-common.iml

3.6 KB

pom.xml

1.5 KB

/.../elastic-query-web-client-common/src/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/

DS_Store

6.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/model/

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/

elastic-query-web-client.iml

13.8 KB

pom.xml

3.3 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.5 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

ElasticQueryServiceInstanceListSupplierConfig.java

1.6 KB

WebClientConfig.java

3.1 KB

WebSecurityConfig.java

1.8 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.5 KB

/.../elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.4 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/8/elastic/elastic-config/

elastic-config.iml

9.0 KB

pom.xml

1.3 KB

/8/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.0 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/8/elastic/elastic-model/

elastic-model.iml

8.9 KB

pom.xml

0.9 KB

/8/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/8/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.2 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/8/elastic/

elastic.iml

0.6 KB

pom.xml

0.8 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.6 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.4 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/8/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/8/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/8/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/8/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/8/kafka/kafka-consumer/

kafka-consumer.iml

3.2 KB

pom.xml

1.1 KB

/8/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/8/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/8/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAvroModel.java

17.5 KB

/8/kafka/kafka-model/src/main/resources/avro/

twitter.avsc

0.3 KB

/8/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/8/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/8/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/8/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/8/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/.../reactive-elastic-query-service/

pom.xml

2.8 KB

reactive-elastic-query-service.iml

17.2 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplication.java

0.5 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/api/

ElasticDocumentController.java

1.8 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/

ElasticQueryService.java

0.3 KB

ReactiveElasticQueryClient.java

0.4 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/impl/

TwitterElasticQueryService.java

1.7 KB

TwitterReactiveElasticQueryClient.java

1.6 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/config/

WebSecurityConfig.java

0.7 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/repository/

ElasticQueryRepository.java

0.5 KB

/.../reactive-elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-service/src/test/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplicationTests.java

0.3 KB

/.../reactive-elastic-query-web-client/

DS_Store

6.1 KB

pom.xml

2.8 KB

reactive-elastic-query-web-client.iml

12.8 KB

/.../reactive-elastic-query-web-client/src/

DS_Store

6.1 KB

/.../reactive-elastic-query-web-client/src/main/

DS_Store

6.1 KB

/.../reactive-elastic-query-web-client/src/main/java/

DS_Store

6.1 KB

/.../reactive-elastic-query-web-client/src/main/java/com/

DS_Store

6.1 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/

DS_Store

6.1 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/

DS_Store

6.1 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/

DS_Store

6.1 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/

DS_Store

6.1 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/

DS_Store

6.1 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/

DS_Store

6.1 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/

DS_Store

6.1 KB

ReactiveElasticQueryWebClientApplication.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/api/

QueryController.java

2.4 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/config/

WebClientConfig.java

2.1 KB

WebSecurityConfig.java

0.6 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.4 KB

/.../reactive-elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

1.1 KB

home.html

2.1 KB

index.html

0.2 KB

/.../reactive-elastic-query-web-client/src/test/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/9/

001 Introduction to Oauth and Keycloak authorization server.mp4

44.8 MB

001 Introduction to Oauth and Keycloak authorization server_en.srt

11.6 KB

002 Run and configure Keycloak authorization server with OIDC for authentication.mp4

23.4 MB

002 Run and configure Keycloak authorization server with OIDC for authentication_en.srt

15.6 KB

003 Understanding Spring security with Spring Security OAuth 2.0 resource server.mp4

12.1 MB

003 Understanding Spring security with Spring Security OAuth 2.0 resource server_en.srt

3.9 KB

004 Configuring query service with Spring security Oauth 2.0, OpenId Connect and JWT.mp4

95.7 MB

004 Configuring query service with Spring security Oauth 2.0, OpenId Connect and JWT_en.srt

18.0 KB

005 Adding user permissions with Spring security by reading from database.mp4

92.1 MB

005 Adding user permissions with Spring security by reading from database_en.srt

19.9 KB

006 Configuring web client security with Spring boot security Oauth2, OIDC and JWT.mp4

75.2 MB

006 Configuring web client security with Spring boot security Oauth2, OIDC and JWT_en.srt

11.7 KB

007 Implementing SSO with Keycloak.mp4

28.0 MB

007 Implementing SSO with Keycloak_en.srt

10.7 KB

32579258-oauth2-openid.pptx

90.7 KB

32579266-oauth2-resource-server.pptx

69.5 KB

32579276-oauth2-client.pptx

64.3 KB

34624860-microservices-realm-export.json

80.1 KB

HELP.md

0.4 KB

README.md

0.4 KB

gitignore

0.4 KB

mvnw

10.1 KB

mvnw.cmd

6.6 KB

pom.xml

9.4 KB

/.../app-config-data/

app-config-data.iml

1.6 KB

pom.xml

0.9 KB

/.../app-config-data/src/main/java/com/microservices/demo/config/

ElasticConfigData.java

0.4 KB

ElasticQueryConfigData.java

0.3 KB

ElasticQueryServiceConfigData.java

0.4 KB

ElasticQueryWebClientConfigData.java

1.1 KB

KafkaConfigData.java

0.6 KB

KafkaConsumerConfigData.java

0.9 KB

KafkaProducerConfigData.java

0.6 KB

RetryConfigData.java

0.5 KB

TwitterToKafkaServiceConfigData.java

0.6 KB

UserConfigData.java

0.4 KB

/.../app-config-data/src/main/resources/

logback-common.xml

1.5 KB

/9/common-config/

common-config.iml

3.1 KB

pom.xml

1.2 KB

/9/common-config/src/main/java/com/microservices/demo/common/config/

RetryConfig.java

1.4 KB

/9/common-util/

common-util.iml

0.7 KB

pom.xml

0.5 KB

/9/common-util/src/main/java/com/microservices/demo/common/util/

CollectionsUtil.java

0.6 KB

/.../config-server-repository/

config-client-elastic_query.yml

1.5 KB

config-client-elastic_query_web.yml

1.6 KB

config-client-elastic_query_web_2.yml

1.6 KB

config-client-kafka_to_elastic.yml

1.2 KB

config-client-reactive_elastic_query.yml

0.8 KB

config-client-reactive_elastic_query_web.yml

0.6 KB

config-client-twitter_to_kafka.yml

1.0 KB

config-client.yml

0.1 KB

/9/config-server/

config-server.iml

8.2 KB

pom.xml

1.9 KB

/9/config-server/src/main/java/com/microservices/demo/config/server/

ConfigServer.java

0.4 KB

/9/config-server/src/main/java/com/microservices/demo/config/server/config/

SecurityConfig.java

0.7 KB

/9/config-server/src/main/resources/

application.yml

0.1 KB

bootstrap.yml

0.5 KB

logback.xml

0.2 KB

/9/docker-compose/

check-config-server-started.sh

0.5 KB

check-kafka-topics-created.sh

0.4 KB

check-keycloak-server-started.sh

0.5 KB

common.yml

0.1 KB

elastic_cluster.yml

1.8 KB

env

0.3 KB

kafka_cluster.yml

2.7 KB

keycloak_authorization_server.yml

0.5 KB

services.yml

10.3 KB

/.../elastic-query-service-common/

elastic-query-service-common.iml

10.5 KB

pom.xml

1.6 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/api/error/handler/

ElasticQueryServiceErrorHandler.java

2.3 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/model/

ElasticQueryServiceRequestModel.java

0.4 KB

ElasticQueryServiceResponseModel.java

0.5 KB

/.../elastic-query-service-common/src/main/java/com/microservices/demo/elastic/query/service/common/transformer/

ElasticToResponseModelTransformer.java

1.1 KB

/.../elastic-query-service/

elastic-query-service.iml

20.9 KB

pom.xml

3.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/

Constants.java

0.1 KB

ElasticQueryServiceApplication.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/api/

ElasticDocumentController.java

6.7 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/

ElasticQueryService.java

0.4 KB

QueryUserService.java

0.3 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/business/impl/

TwitterElasticQueryService.java

2.1 KB

TwitterQueryUserService.java

1.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/config/

WebSecurityConfig.java

3.7 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/entity/

UserPermission.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/dataaccess/repository/

UserPermissionRepository.java

0.9 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/

ElasticQueryServiceResponseModelV2.java

0.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/model/assembler/

ElasticQueryServiceResponseModelAssembler.java

2.1 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/security/

AudienceValidator.java

1.4 KB

PermissionType.java

0.3 KB

QueryServicePermissionEvaluator.java

3.7 KB

TwitterQueryUser.java

1.3 KB

TwitterQueryUserDetailsService.java

1.5 KB

TwitterQueryUserJwtConverter.java

3.5 KB

/.../elastic-query-service/src/main/java/com/microservices/demo/elastic/query/service/transformer/

UserPermissionsToUserDetailTransformer.java

1.0 KB

/.../elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

init-data.sql

1.8 KB

init-schema.sql

1.6 KB

logback.xml

0.2 KB

/.../elastic-query-service/src/test/java/com/microservices/demo/elastic/query/service/

ElasticQueryServiceApplicationTests.java

0.3 KB

/.../elastic-query-web-client-2/

elastic-query-web-client-2.iml

14.7 KB

pom.xml

3.3 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/config/

ElasticQueryServiceInstanceListSupplierConfig.java

1.6 KB

WebClientConfig.java

3.8 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client-2/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.6 KB

/.../elastic-query-web-client-2/src/main/resources/

application.yml

0.2 KB

bootstrap.yml

0.4 KB

logback.xml

0.4 KB

/.../elastic-query-web-client-2/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client-common/

elastic-query-web-client-common.iml

3.6 KB

pom.xml

1.5 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/api/error/handler/

ElasticQueryWebClientErrorHandler.java

3.1 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/exception/

ElasticQueryWebClientException.java

0.4 KB

/.../elastic-query-web-client-common/src/main/java/com/microservices/demo/elastic/query/web/client/common/model/

ElasticQueryWebClientRequestModel.java

0.4 KB

ElasticQueryWebClientResponseModel.java

0.4 KB

/.../elastic-query-web-client/

elastic-query-web-client.iml

14.8 KB

pom.xml

3.3 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplication.java

0.5 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/api/

QueryController.java

2.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/config/

ElasticQueryServiceInstanceListSupplierConfig.java

1.6 KB

WebClientConfig.java

3.8 KB

WebSecurityConfig.java

4.0 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../elastic-query-web-client/src/main/java/com/microservices/demo/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.6 KB

/.../elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.4 KB

/.../elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

2.0 KB

home.html

2.2 KB

index.html

0.5 KB

/.../elastic-query-web-client/src/test/java/com/microservices/demo/elastic/query/web/client/

ElasticQueryWebClientApplicationTests.java

0.3 KB

/9/elastic/elastic-config/

elastic-config.iml

9.0 KB

pom.xml

1.3 KB

/9/elastic/elastic-config/src/main/java/com/microservices/demo/elastic/config/

ElasticsearchConfig.java

2.1 KB

/.../elastic-index-client/

elastic-index-client.iml

9.0 KB

pom.xml

1.0 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/repository/

TwitterElasticsearchIndexRepository.java

0.4 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/

ElasticIndexClient.java

0.3 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/service/impl/

TwitterElasticIndexClient.java

2.2 KB

TwitterElasticRepositoryIndexClient.java

1.6 KB

/.../elastic-index-client/src/main/java/com/microservices/demo/elastic/index/client/util/

ElasticIndexUtil.java

0.8 KB

/9/elastic/elastic-model/

elastic-model.iml

8.9 KB

pom.xml

0.9 KB

/9/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/

IndexModel.java

0.1 KB

/9/elastic/elastic-model/src/main/java/com/microservices/demo/elastic/model/index/impl/

TwitterIndexModel.java

1.1 KB

/.../elastic-query-client/

elastic-query-client.iml

9.2 KB

pom.xml

1.2 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/exception/

ElasticQueryClientException.java

0.4 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/repository/

TwitterElasticsearchQueryRepository.java

0.5 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/

ElasticQueryClient.java

0.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/service/impl/

TwitterElasticQueryClient.java

3.6 KB

TwitterElasticRepositoryQueryClient.java

2.3 KB

/.../elastic-query-client/src/main/java/com/microservices/demo/elastic/query/client/util/

ElasticQueryUtil.java

1.2 KB

/9/elastic/

elastic.iml

0.6 KB

pom.xml

0.8 KB

/.../kafka-to-elastic-service/

kafka-to-elastic-service.iml

15.6 KB

pom.xml

3.0 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/

KafkaToElasticServiceApplication.java

0.5 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/

KafkaConsumer.java

0.4 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/consumer/impl/

TwitterKafkaConsumer.java

3.7 KB

/.../kafka-to-elastic-service/src/main/java/com/microservices/demo/kafka/to/elastic/service/transformer/

AvroToElasticModelTransformer.java

1.1 KB

/.../kafka-to-elastic-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/9/kafka/kafka-admin/

kafka-admin.iml

7.1 KB

pom.xml

1.2 KB

/9/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/client/

KafkaAdminClient.java

6.0 KB

/9/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/config/

KafkaAdminConfig.java

0.8 KB

WebClientConfig.java

0.4 KB

/9/kafka/kafka-admin/src/main/java/com/microservices/demo/kafka/admin/exception/

KafkaClientException.java

0.4 KB

/9/kafka/kafka-consumer/

kafka-consumer.iml

3.1 KB

pom.xml

1.1 KB

/9/kafka/kafka-consumer/src/main/java/com/microservices/demo/kafka/consumer/config/

KafkaConsumerConfig.java

3.7 KB

/9/kafka/kafka-model/

kafka-model.iml

1.4 KB

pom.xml

1.7 KB

/9/kafka/kafka-model/src/main/java/com/microservices/demo/kafka/avro/model/

TwitterAvroModel.java

17.5 KB

/9/kafka/kafka-model/src/main/resources/avro/

twitter.avsc

0.3 KB

/9/kafka/kafka-producer/

kafka-producer.iml

4.4 KB

pom.xml

1.2 KB

/9/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/

KafkaProducerConfig.java

2.6 KB

/9/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/

KafkaProducer.java

0.3 KB

/9/kafka/kafka-producer/src/main/java/com/microservices/demo/kafka/producer/config/service/impl/

TwitterKafkaProducer.java

2.6 KB

/9/kafka/

kafka.iml

0.6 KB

pom.xml

0.5 KB

/.../reactive-elastic-query-service/

pom.xml

2.8 KB

reactive-elastic-query-service.iml

17.2 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplication.java

0.5 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/api/

ElasticDocumentController.java

1.8 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/

ElasticQueryService.java

0.3 KB

ReactiveElasticQueryClient.java

0.4 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/business/impl/

TwitterElasticQueryService.java

1.7 KB

TwitterReactiveElasticQueryClient.java

1.6 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/config/

WebSecurityConfig.java

0.7 KB

/.../reactive-elastic-query-service/src/main/java/com/microservices/demo/reactive/elastic/query/service/repository/

ElasticQueryRepository.java

0.5 KB

/.../reactive-elastic-query-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-service/src/test/java/com/microservices/demo/reactive/elastic/query/service/

ReactiveElasticQueryServiceApplicationTests.java

0.3 KB

/.../reactive-elastic-query-web-client/

pom.xml

2.8 KB

reactive-elastic-query-web-client.iml

12.8 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplication.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/api/

QueryController.java

2.4 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/config/

WebClientConfig.java

2.1 KB

WebSecurityConfig.java

0.6 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/

ElasticQueryWebClient.java

0.5 KB

/.../reactive-elastic-query-web-client/src/main/java/com/microservices/demo/reactive/elastic/query/web/client/service/impl/

TwitterElasticQueryWebClient.java

3.4 KB

/.../reactive-elastic-query-web-client/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

/.../reactive-elastic-query-web-client/src/main/resources/templates/

error.html

0.4 KB

footer.html

0.7 KB

header.html

1.1 KB

home.html

2.1 KB

index.html

0.2 KB

/.../reactive-elastic-query-web-client/src/test/java/com/microservices/demo/reactive/elastic/query/web/client/

ReactiveElasticQueryWebClientApplicationTests.java

0.3 KB

/.../twitter-to-kafka-service/

pom.xml

2.6 KB

twitter-to-kafka-service.iml

14.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplication.java

1.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/exception/

TwitterToKafkaServiceException.java

0.4 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/

StreamInitializer.java

0.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/init/impl/

KafkaStreamInitializer.java

1.1 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/listener/

TwitterKafkaStatusListener.java

1.7 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/

StreamRunner.java

0.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/runner/impl/

MockKafkaStreamRunner.java

5.7 KB

TwitterKafkaStreamRunner.java

2.2 KB

/.../twitter-to-kafka-service/src/main/java/com/microservices/demo/twitter/to/kafka/service/transformer/

TwitterStatusToAvroTransformer.java

0.6 KB

/.../twitter-to-kafka-service/src/main/resources/

application.yml

0.0 KB

bootstrap.yml

0.4 KB

logback.xml

0.3 KB

twitter4j.properties

0.1 KB

/.../twitter-to-kafka-service/src/test/java/com/microservices/demo/twitter/to/kafka/service/

TwitterToKafkaServiceApplicationTests.java

0.3 KB

/~Get Your Files Here !/

Bonus Resources.txt

0.4 KB

 

Total files 3550


Copyright © 2024 FileMood.com