luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Removing dependency on Glue SDK.

Browse source 
Adding dependency on the Glue Schema Registry common package.
This commit is contained in:
Ravindranath Kakarla 2020-11-19 10:47:07 -08:00
parent 99cb3356bb
commit a7a61616cb
2 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
amazon-kinesis-client/pom.xml
View file

@ -79,6 +79,11 @@
<artifactId>schema-registry-serde</artifactId> <artifactId>schema-registry-serde</artifactId>
<version>1.0.0</version> <version>1.0.0</version>
</dependency> </dependency>
<dependency>
<groupId>software.amazon.glue</groupId>
<artifactId>schema-registry-common</artifactId>
<version>1.0.0</version>
</dependency>
<dependency> <dependency>
<groupId>com.google.guava</groupId> <groupId>com.google.guava</groupId>
<artifactId>guava</artifactId> <artifactId>guava</artifactId>

3
amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/ProcessTaskTest.java
View file

@ -66,7 +66,6 @@ import com.google.protobuf.ByteString;
import lombok.Data; import lombok.Data;
import lombok.Getter; import lombok.Getter;
import software.amazon.awssdk.services.glue.model.DataFormat;
import software.amazon.awssdk.services.kinesis.model.HashKeyRange; import software.amazon.awssdk.services.kinesis.model.HashKeyRange;
import software.amazon.awssdk.services.kinesis.model.Shard; import software.amazon.awssdk.services.kinesis.model.Shard;
import software.amazon.kinesis.checkpoint.ShardRecordProcessorCheckpointer; import software.amazon.kinesis.checkpoint.ShardRecordProcessorCheckpointer;
@ -87,7 +86,7 @@ import software.amazon.kinesis.schemaregistry.SchemaRegistryDecoder;
@RunWith(MockitoJUnitRunner.class) @RunWith(MockitoJUnitRunner.class)
public class ProcessTaskTest { public class ProcessTaskTest {
private static final long IDLE_TIME_IN_MILLISECONDS = 100L; private static final long IDLE_TIME_IN_MILLISECONDS = 100L;
private static final Schema SCHEMA_REGISTRY_SCHEMA = new Schema("{}", DataFormat.AVRO.toString(), "demoSchema"); private static final Schema SCHEMA_REGISTRY_SCHEMA = new Schema("{}", "AVRO", "demoSchema");
private static final byte[] SCHEMA_REGISTRY_PAYLOAD = new byte[] {01, 05, 03, 05}; private static final byte[] SCHEMA_REGISTRY_PAYLOAD = new byte[] {01, 05, 03, 05};
private boolean shouldCallProcessRecordsEvenForEmptyRecordList = true; private boolean shouldCallProcessRecordsEvenForEmptyRecordList = true;