Chris Richardson

https://github.com/eventuate-tram/eventuate-tram-core/blob/355563c5f0f859053236c6b7067c389ec83eed52/docker-compose-mysql-binlog-kafka.yml#L28 @dartartem

> But there are many additional operations + validation. Might be useful for some users. I have a vague memory that the CDC requires modification because the Binlog value is...

Need to implement OptimisticLockingDecoratorConfiguration for Micronaut

1

`eventuate-tram-optimistic-locking` must be renamed to `...-spring-`. Need to implement the micronaut equivalent. Define @Bean that tests whether an exception represents an optimistic locking exception? https://github.com/eventuate-tram/eventuate-tram-core/blob/cecda838bfa69c0dfe79c3d9d3af0ebb4cef2499/eventuate-tram-optimistic-locking/src/main/java/io/eventuate/tram/optimisticlocking/OptimisticLockingDecoratorConfiguration.java#L7

Rethink transactional.noop.duplicate.message.detector.factory.enabled

2

This seems pretty ugly: https://github.com/eventuate-tram/eventuate-tram-docs/blob/master/src/docs/asciidoc/getting-started-eventuate-tram.adoc#micronaut-3 I understand that Micronaut searches the classpath for beans/factories - no @Import This is the fallback `NoopDuplicateMessageDetector` and is only defined if there is no...

":eventuate-tram-spring-consumer-common" should not be a direct dependency of `eventuate--jdbc-`. https://github.com/eventuate-tram/eventuate-tram-core/blob/a6ecb6121847cf86282baf1021cfad36cc8b5d69/eventuate-tram-spring-jdbc-kafka/build.gradle#L7 It's already in eventuate-spring-consumer-kafka so this particular one is a duplicate. But I don't think it's in other `eventuate-spring-consumer-`, which...

Currently, an application has to `@Import`: * TramConsumerCommonConfiguration * MessageConsumerKafkaConfiguration * EventuateTramKafkaMessageConsumerConfiguration it should only need to import `EventuateTramKafkaMessageConsumerConfiguration`

new CDC service seems to be outputting a long list of ConsumerConfig values every 5 seconds.

1

This is the result of `KafkaHealthCheck` creating a `KafkaConsumer` each time it is called (every 5 seconds).

A rarely occurring problem. I suspect that it's because `TracingMessagingInterceptor` is calling Message.setHeader() which is modifying the headers map in place instead of copy on write. ``` 2019-05-22 14:54:27.839 INFO...

Implement a strategy class that maps between Event class and event-type header.

1

The default implementation uses the class name.

The message-broker specific test can enable the appropriate message broker-specific profile