asc-lab/micronaut-microservices-poc

Very simplified insurance sales system made in a microservices architecture using Micronaut

micronaut-microservices-poc's Issues

Add embedding Kafka in tests.

Script to build all services

For demo purposes, we need a script to build all the services.
This can be in form of parent pom.xml or regular script that uses maven to build each service.

Front-end Web UI not accessible

Hi,

Have followed the instructions in readme using automated setup scripts, but can't access the frontend on http://localhost:8080

All services are up in consul.
Please let me know what details I can provide for debugging.

Add integration tests with Testcontainers

Add tests to ensure all functionalities work properly, use Testcontaoners to provide dependencies such us: kafka, elasticsearch, consul, external HTTP services

Elasticsearch container doesn't start on kubernetes

Elasticsearch version:
docker.elastic.co/elasticsearch/elasticsearch:6.4.2

logs:

[2018-10-18T09:05:09,530][INFO ][o.e.n.Node               ] [BXSDDvd] starting ...
[2018-10-18T09:05:09,762][INFO ][o.e.t.TransportService   ] [BXSDDvd] publish_address {172.17.0.6:9300}, bound_addresses {0.0.0.0:9300}
[2018-10-18T09:05:09,806][INFO ][o.e.b.BootstrapChecks    ] [BXSDDvd] bound or publishing to a non-loopback address, enforcing bootstrap checks
ERROR: [1] bootstrap checks failed
[1]: memory locking requested for elasticsearch process but memory is not locked
[2018-10-18T09:05:09,850][INFO ][o.e.n.Node               ] [BXSDDvd] stopping ...
[2018-10-18T09:05:09,914][INFO ][o.e.n.Node               ] [BXSDDvd] stopped
[2018-10-18T09:05:09,921][INFO ][o.e.n.Node               ] [BXSDDvd] closing ...
[2018-10-18T09:05:09,971][INFO ][o.e.n.Node               ] [BXSDDvd] closed
[2018-10-18T09:05:09,976][INFO ][o.e.x.m.j.p.NativeController] Native controller process has stopped - no new native processes can be started

Upgrade to Java 14

Add CD pipeline

Docker network_mode: host supports only Linux

I am a Windows user.

When running docker-compose i can not access kafka manager via localhost:9000.

Here i found this info:

The host networking driver only works on Linux hosts, and is not supported on Docker Desktop for Mac, Docker Desktop for Windows, or Docker EE for Windows Server.

Is there an option to change docker files so they won't use network_mode: host ?

Also i found out - that i need to have Linux ending file (LF) instead of Windows default (CRLF) to keep container mn-web-vue running.

Elasticsearch container doesn't start on Kubernetes hosted in the cloud

Elasticsearch version:
docker.elastic.co/elasticsearch/elasticsearch:6.4.2

logs:

[2018-11-06T17:01:53,087][INFO ][o.e.n.Node               ] [yHdqr9S] starting ...
[2018-11-06T17:01:53,475][INFO ][o.e.t.TransportService   ] [yHdqr9S] publish_address {10.48.4.11:9300}, bound_addresses {[::]:9300}
[2018-11-06T17:01:53,510][INFO ][o.e.b.BootstrapChecks    ] [yHdqr9S] bound or publishing to a non-loopback address, enforcing bootstrap checks
ERROR: [1] bootstrap checks failed
[1]: max virtual memory areas vm.max_map_count [65530] is too low, increase to at least [262144]
[2018-11-06T17:01:53,556][INFO ][o.e.n.Node               ] [yHdqr9S] stopping ...
[2018-11-06T17:01:53,580][INFO ][o.e.n.Node               ] [yHdqr9S] stopped
[2018-11-06T17:01:53,581][INFO ][o.e.n.Node               ] [yHdqr9S] closing ...
[2018-11-06T17:01:53,605][INFO ][o.e.n.Node               ] [yHdqr9S] closed
[2018-11-06T17:01:53,609][INFO ][o.e.x.m.j.p.NativeController] Native controller process has stopped - no new native processes can be started

Better exception handling

[documents-service] org.hibernate.HibernateException: Could not obtain transaction-synchronized Session for current thread.

In documents-service, when a policy is paid, an error is raised: org.hibernate.HibernateException: Could not obtain transaction-synchronized Session for current thread. I've added the policy template in JSReport and committed.

14:28:54.569 [pool-2-thread-1] ERROR i.m.c.k.e.KafkaListenerExceptionHandler - Error processing record [Optional[ConsumerRecord(topic = policy-registered, partition = 0, leaderEpoch = null, offset = 3, CreateTime = 1598884133749, serialized key size = 36, serialized value size = 159, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@7dbe50be, value = pl.altkom.asc.lab.micronaut.poc.policy.service.api.v1.events.PolicyRegisteredEvent@7c3b26a3)]] for Kafka consumer [pl.altkom.asc.lab.micronaut.poc.documents.domain.PolicyRegisteredListener@3a66e52c] produced error: Could not obtain transaction-synchronized Session for current thread
org.hibernate.HibernateException: Could not obtain transaction-synchronized Session for current thread
	at io.micronaut.transaction.hibernate5.MicronautSessionContext.currentSession(MicronautSessionContext.java:100)
	at org.hibernate.internal.SessionFactoryImpl.getCurrentSession(SessionFactoryImpl.java:475)
	at io.micronaut.configuration.hibernate.jpa.TransactionalSessionInterceptor.intercept(TransactionalSessionInterceptor.java:56)
	at io.micronaut.aop.chain.MethodInterceptorChain.proceed(MethodInterceptorChain.java:69)
	at io.micronaut.configuration.hibernate.jpa.TransactionalSession$Intercepted.persist(Unknown Source)
	at pl.altkom.asc.lab.micronaut.poc.documents.infrastructure.adapters.db.PolicyDocumentDb.add(PolicyDocumentDb.kt:20)
	at pl.altkom.asc.lab.micronaut.poc.documents.domain.PolicyRegisteredListener.onPolicyRegistered(PolicyRegisteredListener.kt:24)
	at pl.altkom.asc.lab.micronaut.poc.documents.domain.$PolicyRegisteredListenerDefinition$$exec1.invokeInternal(Unknown Source)
	at io.micronaut.context.AbstractExecutableMethod.invoke(AbstractExecutableMethod.java:146)
	at io.micronaut.core.bind.DefaultExecutableBinder$1.invoke(DefaultExecutableBinder.java:109)
	at io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor.lambda$process$7(KafkaConsumerProcessor.java:498)
	at io.micronaut.scheduling.instrument.InvocationInstrumenterWrappedRunnable.run(InvocationInstrumenterWrappedRunnable.java:47)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

[Automated deployment] local machine problem with docker build step

I've found out that there is issue with command $ sh docker-run.sh

Building mn-documents-service
Step 1/4 : FROM openjdk:8u171-alpine3.7
8u171-alpine3.7: Pulling from library/openjdk
911c6d0c7995: Pull complete
4001add52a90: Pull complete
874028933da5: Pull complete
Digest: sha256:12e19d0dffa75ded3ab909e8c1966682b097f155ca0c2c88577445c64d6776d5
Status: Downloaded newer image for openjdk:8u171-alpine3.7
 ---> 1caad94162ef
Step 2/4 : RUN apk --no-cache add curl
 ---> Running in 7b456af061f8
fetch http://dl-cdn.alpinelinux.org/alpine/v3.7/main/x86_64/APKINDEX.tar.gz
fetch http://dl-cdn.alpinelinux.org/alpine/v3.7/community/x86_64/APKINDEX.tar.gz
(1/3) Installing libssh2 (1.8.2-r0)
(2/3) Installing libcurl (7.61.1-r2)
(3/3) Installing curl (7.61.1-r2)
Executing busybox-1.27.2-r11.trigger
OK: 100 MiB in 56 packages
Removing intermediate container 7b456af061f8
 ---> 8c3c977f7245
Step 3/4 : COPY target/documents-service*.jar documents-service.jar
ERROR: Service 'mn-documents-service' failed to build: COPY failed: no source files were specified

Is there any clue that can be helpful to fix it?

Get rid of Lombok dependency

It is more like question than issue. I would prefer the project without dependency on Lombok since it forces me to install additional IDE plugins.

Are you interested in PR that replaces Lombok with regular Java code?

Add login screen

Add login functionality that will use auth service

Error run docker-run.sh. Cannot start service mn-web-vue

Hi, I have a problem when i launch the docker-run:

ERROR: for mn-web-vue Cannot start service mn-web-vue: OCI runtime create failed: container_linux.go:349: starting container process caused "exec: "/entrypoint.sh": stat /entrypoint.sh: no such file or directory": unknown

ERROR: for mn-web-vue Cannot start service mn-web-vue: OCI runtime create failed: container_linux.go:349: starting container process caused "exec: "/entrypoint.sh": stat /entrypoint.sh: no such file or directory": unknown
ERROR: Encountered errors while bringing up the project.

ANy solutions for this problem? I have performed all the steps described

Thaks

Unable to setup Kafka Cluster

I had no issues building and running the program until it was time to add a Kafka cluster. When running the kafka-create-cluster.sh file I received the following message:

• Trying 127.0.0.1...
• TCP_NODELAY set
• Connection failed
• connect to 127.0.0.1 port 29092 failed: Connection refused
• Trying ::1...
• TCP_NODELAY set
• Connection failed
• connect to ::1 port 29092 failed: Connection refused
• Failed to connect to localhost port 29092: Connection refused
• Closing connection 0

Any suggestions? Thanks.

Contracts

Decouple services by removing shared libraries and applying API contracts.

GraalVM support

http://guides.micronaut.io/micronaut-creating-first-graal-app/guide/index.html

Great presentation on Warsaw JUG

Great job with code preparation and high quality of talk! Thank you!

Automate jsreport's template installation

Docker compose to run the whole solution

Docker compose file that will start all the required infrastructure and all services (including frontend) in docker containers

Can't download documents after creating policy

After going through the flow of converting an offer to policy, I get the following error from Vue TypeError: t.documentsList is undefined.

Upgrade to Micronaut 2.3.0

Move policy search to separate services and use ElasticSearch for it

Create monitoring dashboard for each service

Secure API Gateway with JWT

A minimal version is to secure api gateway with JWT tokens

Consul as config server

Multiple tenants support

Docker-compose does not expose 9000, 9092, 2181 ports

As documentation states now:

https://github.com/asc-lab/micronaut-microservices-poc#automated-deployment

Afterwards you need to add kafka cluster - either via web UI (Kafka Manager -> Cluster -> Add Cluster) or using provided script:

kafka-create-cluster.sh

To be able to do that you must have connection to kafka manager via localhost:9000.

If you execute now docker-compose up you see that this port is not exposed:

To expose this port remove:

network_mode: host

from kafka_manager container definition.

After this change you see that port 9000 is exposed:

I will make pull request regarding this issue. This also need to be fix for other containers like:
kafkaserver.

Still there is issue after visiting localhost:9200 and executing script kafka-create-cluster.sh

I am a Windows user.

Update readme with startup instruction and each service features description

Update readme with startup instruction and each service features description.

Each service should have a description that shows what are the interesting parts

Add WebSocket usage example - chat.

Add CI/CD

Add config for CI/CD (for example Azure DevOps).

Add ELK stack to gather logs from services

Upgrade to Micronaut 2.0

Secure microservices with JWT

Minimal version (API Gateway secured) has been created with issue #3
In this issue we should secure all microservices.