Commit 7ee6b27e authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia tipo de stream de VesselTypeEvent a Event 

Ya que no siempre es de este tipo y produce errores
parent 162dfd5d

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

+2 −2
Original line number Diff line number Diff line
@@ -224,9 +224,9 @@ public class VesselEventStreams extends EventStreams { 
				}, Materialized.with(Serdes.String(), new ArrayListSerde<>(schemaRegistry)));



		// Vesseltypes modificados

		KStream<String, VesselTypeEvent> vesselTypeEvents = builder.stream(vesselTypeTopic);

		KStream<String, Event> vesselTypeEvents = builder.stream(vesselTypeTopic);



		KStream<String, VesselTypeEvent> updateReferenceEvents = vesselTypeEvents

		KStream<String, Event> updateReferenceEvents = vesselTypeEvents

				.filter((id, event) -> (VesselTypeEventType.VESSELTYPE_UPDATED.toString().equals(event.getType())));



		KStream<String, ArrayList<VesselEvent>> join = updateReferenceEvents.join(vesselEventsTable,