You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I try setup eventuate to use database generated IDs. When I debug eventuate core I found that eventuate didn't save message ID in header column but cdc-service use it to publish message to somewhere. Please take a look.
Cdc-service exception:
Caused by: java.lang.RuntimeException: No such header: ID in this message io.eventuate.tram.cdc.connector.MessageWithDestination@1ef61ad 2021-09-24T18:20:00.435606302Z at io.eventuate.tram.cdc.connector.MessageWithDestination.getRequiredHeader(MessageWithDestination.java:52) 2021-09-24T18:20:00.435638102Z at io.eventuate.tram.cdc.connector.MessageWithDestination.getId(MessageWithDestination.java:62) 2021-09-24T18:20:00.435672999Z at java.util.Optional.orElseGet(Optional.java:267) 2021-09-24T18:20:00.435695927Z at io.eventuate.tram.cdc.connector.MessageWithDestinationPublishingStrategy.partitionKeyFor(MessageWithDestinationPublishingStrategy.java:11) 2021-09-24T18:20:00.435735256Z at io.eventuate.tram.cdc.connector.MessageWithDestinationPublishingStrategy.partitionKeyFor(MessageWithDestinationPublishingStrategy.java:7) 2021-09-24T18:20:00.435762111Z at io.eventuate.local.common.CdcDataPublisher.send(CdcDataPublisher.java:116) 2021-09-24T18:20:00.435792271Z at io.eventuate.local.common.CdcDataPublisher.sendMessage(CdcDataPublisher.java:100) 2021-09-24T18:20:00.435820526Z at io.eventuate.local.common.BinlogEntryHandler.publish(BinlogEntryHandler.java:34)
Problem code: io.eventuate.common.jdbc.EventuateCommonJdbcOperations#insertIntoMessageTableDatabaseId
The text was updated successfully, but these errors were encountered:
artemio77
changed the title
No such header: ID in this message headers when use database generated mode
No such header: ID in this message headers when use database generated ID mode
Sep 24, 2021
I try setup eventuate to use database generated IDs. When I debug eventuate core I found that eventuate didn't save message ID in header column but cdc-service use it to publish message to somewhere. Please take a look.
Cdc-service exception:
Caused by: java.lang.RuntimeException: No such header: ID in this message io.eventuate.tram.cdc.connector.MessageWithDestination@1ef61ad 2021-09-24T18:20:00.435606302Z at io.eventuate.tram.cdc.connector.MessageWithDestination.getRequiredHeader(MessageWithDestination.java:52) 2021-09-24T18:20:00.435638102Z at io.eventuate.tram.cdc.connector.MessageWithDestination.getId(MessageWithDestination.java:62) 2021-09-24T18:20:00.435672999Z at java.util.Optional.orElseGet(Optional.java:267) 2021-09-24T18:20:00.435695927Z at io.eventuate.tram.cdc.connector.MessageWithDestinationPublishingStrategy.partitionKeyFor(MessageWithDestinationPublishingStrategy.java:11) 2021-09-24T18:20:00.435735256Z at io.eventuate.tram.cdc.connector.MessageWithDestinationPublishingStrategy.partitionKeyFor(MessageWithDestinationPublishingStrategy.java:7) 2021-09-24T18:20:00.435762111Z at io.eventuate.local.common.CdcDataPublisher.send(CdcDataPublisher.java:116) 2021-09-24T18:20:00.435792271Z at io.eventuate.local.common.CdcDataPublisher.sendMessage(CdcDataPublisher.java:100) 2021-09-24T18:20:00.435820526Z at io.eventuate.local.common.BinlogEntryHandler.publish(BinlogEntryHandler.java:34)
Problem code: io.eventuate.common.jdbc.EventuateCommonJdbcOperations#insertIntoMessageTableDatabaseId
The text was updated successfully, but these errors were encountered: