| 
18 | 18 | 
 
  | 
19 | 19 | import com.amazonaws.services.kinesis.producer.KinesisProducer;  | 
20 | 20 | import com.amazonaws.services.kinesis.producer.UserRecord;  | 
 | 21 | +import com.amazonaws.services.schemaregistry.common.Schema;  | 
21 | 22 | import org.junit.jupiter.api.AfterEach;  | 
22 | 23 | import org.junit.jupiter.api.Test;  | 
23 | 24 | import org.mockito.ArgumentCaptor;  | 
 | 
58 | 59 | @DirtiesContext  | 
59 | 60 | public class KplMessageHandlerTests {  | 
60 | 61 | 
 
  | 
 | 62 | +	@Autowired  | 
 | 63 | +	protected Schema schema;  | 
 | 64 | + | 
61 | 65 | 	@Autowired  | 
62 | 66 | 	protected KinesisProducer kinesisProducer;  | 
63 | 67 | 
 
  | 
@@ -89,6 +93,7 @@ void kplMessageHandlerWithRawPayloadBackpressureDisabledSuccess() {  | 
89 | 93 | 		assertThat(userRecord.getStreamName()).isEqualTo("someStream");  | 
90 | 94 | 		assertThat(userRecord.getPartitionKey()).isEqualTo("somePartitionKey");  | 
91 | 95 | 		assertThat(userRecord.getExplicitHashKey()).isNull();  | 
 | 96 | +		assertThat(userRecord.getSchema()).isSameAs(this.schema);  | 
92 | 97 | 	}  | 
93 | 98 | 
 
  | 
94 | 99 | 	@Test  | 
@@ -116,6 +121,7 @@ void kplMessageHandlerWithRawPayloadBackpressureEnabledCapacityAvailable() {  | 
116 | 121 | 		assertThat(userRecord.getStreamName()).isEqualTo("someStream");  | 
117 | 122 | 		assertThat(userRecord.getPartitionKey()).isEqualTo("somePartitionKey");  | 
118 | 123 | 		assertThat(userRecord.getExplicitHashKey()).isNull();  | 
 | 124 | +		assertThat(userRecord.getSchema()).isSameAs(this.schema);  | 
119 | 125 | 	}  | 
120 | 126 | 
 
  | 
121 | 127 | 	@Test  | 
@@ -174,9 +180,14 @@ public MessageHandler kplMessageHandler(KinesisProducer kinesisProducer) {  | 
174 | 180 | 			KplMessageHandler kplMessageHandler = new KplMessageHandler(kinesisProducer);  | 
175 | 181 | 			kplMessageHandler.setAsync(true);  | 
176 | 182 | 			kplMessageHandler.setStream("someStream");  | 
 | 183 | +			kplMessageHandler.setGlueSchema(schema());  | 
177 | 184 | 			return kplMessageHandler;  | 
178 | 185 | 		}  | 
179 | 186 | 
 
  | 
 | 187 | +		@Bean  | 
 | 188 | +		public Schema schema() {  | 
 | 189 | +			return new Schema("syntax=\"proto2\";", "PROTOBUF", "testschema");  | 
 | 190 | +		}  | 
180 | 191 | 	}  | 
181 | 192 | 
 
  | 
182 | 193 | }  | 
0 commit comments