Commit 8f370286 authored by Noel Alonso's avatar Noel Alonso
Browse files

Merge branch 'dev' into 'master' 

Cambia estrategia de consumidor en los streams

See merge request redmic-project/server/library/commands-lib!10
parents bd6b295e 98462c37

src/main/java/es/redmic/commandslib/streaming/common/StreamUtils.java

+3 −3
Original line number Diff line number Diff line
@@ -51,7 +51,7 @@ public class StreamUtils { 
		config.put(StreamsConfig.APPLICATION_ID_CONFIG, appId);

		config.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);

		config.put(StreamsConfig.STATE_DIR_CONFIG, stateDir);

		config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");

		config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");



		config.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 50);

		config.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 300000);

src/test/java/es/redmic/commandslib/jsonschema/TestDTO.java

+4 −4
Original line number Diff line number Diff line
@@ -22,7 +22,7 @@ package es.redmic.commandslib.jsonschema; 


import com.fasterxml.jackson.databind.annotation.JsonDeserialize;

import com.fasterxml.jackson.databind.annotation.JsonSerialize;

import com.kjetland.jackson.jsonSchema.annotations.JsonSchemaUrl;

import com.kjetland.jackson.jsonSchema.annotations.JsonSchemaUrlUuid;



import es.redmic.brokerlib.deserializer.CustomRelationDeserializer;
@@ -39,7 +39,7 @@ public class TestDTO { 


	@JsonSerialize(as = TestTypeDTO.class)

	@JsonDeserialize(using = CustomRelationDeserializer.class)

	@JsonSchemaUrl(value = "controller.mapping.testtype")

	@JsonSchemaUrlUuid(value = "controller.mapping.testtype")

	private TestTypeDTO type;



	private String name;