Loading vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselTrackingEventStreams.java +1 −1 Original line number Diff line number Diff line Loading @@ -53,7 +53,7 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { this.vesselTopic = vesselTopic; this.vesselTrackingAggByVesselTopic = vesselTrackingAggByVesselTopic; this.vesselUpdatedTopic = vesselUpdatedTopic; this.hashMapSerde = new HashMapSerde<>(schemaRegistry); this.hashMapSerde = new HashMapSerde<String, AggregationVesselInVesselTrackingPostUpdateEvent>(schemaRegistry); logger.info("Arrancado servicio de streaming para event sourcing de Vessel tracking con Id: " + this.serviceId); init(); Loading Loading
vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselTrackingEventStreams.java +1 −1 Original line number Diff line number Diff line Loading @@ -53,7 +53,7 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { this.vesselTopic = vesselTopic; this.vesselTrackingAggByVesselTopic = vesselTrackingAggByVesselTopic; this.vesselUpdatedTopic = vesselUpdatedTopic; this.hashMapSerde = new HashMapSerde<>(schemaRegistry); this.hashMapSerde = new HashMapSerde<String, AggregationVesselInVesselTrackingPostUpdateEvent>(schemaRegistry); logger.info("Arrancado servicio de streaming para event sourcing de Vessel tracking con Id: " + this.serviceId); init(); Loading