Commit 0216dd4b authored by Noel Alonso's avatar Noel Alonso
Browse files

Realiza un leftjoin para enriquecer 

De esta manara se puede enriquecer desde el topic de snapshot y si no se
encuentra el vessel, se inserta sin enriquecer.
parent 092956d3

vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselTrackingEventStreams.java

+2 −2
Original line number Diff line number Diff line
@@ -51,7 +51,7 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 
	public VesselTrackingEventStreams(StreamConfig config, String vesselTopic, String vesselTrackingAggByVesselTopic,

			String vesselUpdatedTopic, AlertService alertService) {

		super(config, alertService);

		this.vesselTopic = vesselTopic;

		this.vesselTopic = vesselTopic + snapshotTopicSuffix;

		this.vesselTrackingAggByVesselTopic = vesselTrackingAggByVesselTopic;

		this.vesselUpdatedTopic = vesselUpdatedTopic;

		this.hashMapSerde = new HashMapSerde<String, AggregationVesselInVesselTrackingPostUpdateEvent>(schemaRegistry);
@@ -101,7 +101,7 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 
				.selectKey((k, v) -> getVesselIdFromVesselTracking(v));



		enrichCreateEvents

				.join(vessel, (k, v) -> k,

				.leftJoin(vessel, (k, v) -> k,

						(enrichCreateEvent, vesselEvent) -> getEnrichCreateResultEvent(enrichCreateEvent, vesselEvent))

				.selectKey((k, v) -> v.getAggregateId()).to(topic);

	}