Commit 16a7a4ae authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia topic para enriquecimiento 

En lugar de enriquecer de snapshot, enriquece a partir del topic de
trabajo, de esta manera, garantizamos que el dato ya esté en el topic al
hacer join
parent 3639650c

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

+1 −1
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 + snapshotTopicSuffix;

		this.vesselTopic = vesselTopic;

		this.vesselTrackingAggByVesselTopic = vesselTrackingAggByVesselTopic;

		this.vesselUpdatedTopic = vesselUpdatedTopic;

		this.hashMapSerde = new HashMapSerde<String, AggregationVesselInVesselTrackingPostUpdateEvent>(schemaRegistry);