vpugar/mtp

MTP - My Test Project - example Java applications with Spring Boot, Apache Spark Streaming, Apache Cassandra, Apache Kafka, Akka, AngularJS (work in progress)

mtp's Issues

Getting Bean Initialization Error in MTP Consumption application

Below error is encountered while trying to execute the Consumption Application.

WARN  [main-AnnotationConfigApplicationContext] Exception encountered during context initialization - cancelling refresh attempt
org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cassandraTransactionDao' defined in file [/u02/craft/mtp-master/mtp-model/bin/com/vedri/mtp/core/transaction/dao/CassandraTransactionDao.class]: Unsatisfied dependency expressed through constructor argument with index 0 of type [com.datastax.driver.core.Session]: : Error creating bean with name 'session' defined in com.vedri.mtp.core.support.cassandra.CassandraConfiguration: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.datastax.driver.core.Session]: Factory method 'session' threw exception; nested exception is java.lang.NullPointerException; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'session' defined in com.vedri.mtp.core.support.cassandra.CassandraConfiguration: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.datastax.driver.core.Session]: Factory method 'session' threw exception; nested exception is java.lang.NullPointerException
	at org.springframework.beans.factory.support.ConstructorResolver.createArgumentArray(ConstructorResolver.java:749) ~[spring-beans-4.2.2.RELEASE.jar:4.2.2.RELEASE]

What is the advantage of using both Akka Actor and Kafka Streaming ?

I have gone through the architecture. This is really interesting that you have used both Akka Actors and Kafka streaming to process the events. Is it not too much overhead to create an Akka cluster as well as Embedded Kafka inside the application. Either one of them could have solved the event processing use case. Any rationale behind using both?