Avoid Running Long processes when consuming Kafka Messages
TODO. :Add information
Sample spring-boot project with mongo db integration is available at https://github.com/akashmahakode/mongodb-demo
Sample spring-boot project with kafka integration is available at https://github.com/akashmahakode/kafka-demo
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.annotation.After;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;
/**
* Aspect to log the message when object is saved
*/
@Slf4j
@Aspect
@Component
public class MyLoggerAspect {
// "obj" is object_which_is_saved_in_save_method i.e in com.foo.save(*)
@After("execution(* com.foo.save(*)) && args(obj)")
public void logAfterSavingTheObject(CustomObject obj) {
log.info("Logging after the CustomObject is saved, id : {}", obj.getId())
}
}
com.amazonaws.services.dynamodbv2.model.AmazonDynamoDBException:
The request signature we calculated does not match the signature you provided.
Check your AWS Secret Access Key and signing method. Consult the service documentation for details.