Commit a34a3bcf authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia estrategia de versionado de elastic 

Por defecto se guardan los documentos con versión 0, de este modo si se
va a guardar un documento que ya está en elastic (por defecto con
versión > 0) dará un conflicto y no inserta el documento.

Se comenta el test que comprueba la estrategia antigua de versionado.
parent e86f86ab

src/main/java/io/confluent/connect/elasticsearch/DataConverter.java

+1 −2
Original line number Diff line number Diff line
@@ -175,9 +175,8 @@ public class DataConverter { 
				index = index + "-" + indexSuffix;

		}



		final Long version = ignoreKey ? null : record.kafkaOffset();

		final Long version = ignoreKey ? null : 0L;// record.kafkaOffset();



		System.out.println(".............. " + index + " " + type + " " + id);

		return new IndexableRecord(new Key(index, type, id), payload, version);

	}

src/test/java/io/confluent/connect/elasticsearch/ElasticsearchWriterTest.java

+2 −2
Original line number Diff line number Diff line
@@ -183,7 +183,7 @@ public class ElasticsearchWriterTest extends ElasticsearchSinkTestBase { 
    verifySearchResults(expected);

  }



  @Test

  /*-@Test

  public void testSafeRedeliveryRegularKey() throws Exception {

    Struct value0 = new Struct(schema);

    value0.put("user", "foo");
@@ -206,7 +206,7 @@ public class ElasticsearchWriterTest extends ElasticsearchSinkTestBase { 


    // last write should have been ignored due to version conflict

    verifySearchResults(Collections.singleton(sinkRecord1));

  }

  }-*/



  @Test

  public void testSafeRedeliveryOffsetInKey() throws Exception {