Skip to content

Commit 8ace348

Browse files
EricWittmannEricWittmann
authored
Added debugging to the protobuf serdes test (#5018)
* Added debugging to the protobuf serdes test * Code formatting using spotless
1 parent 4a4c33a commit 8ace348

File tree

1 file changed

+76
-49
lines changed

1 file changed

+76
-49
lines changed

‎integration-tests/src/test/java/io/apicurio/tests/serdes/apicurio/ProtobufSerdeIT.java

+76-49
Original file line numberDiff line numberDiff line change
@@ -61,10 +61,13 @@ void testTopicIdStrategyFindLatest() throws Exception {
6161
createArtifact("default", artifactId, ArtifactType.PROTOBUF, schema.generateSchemaString(),
6262
ContentTypes.APPLICATION_PROTOBUF, null, null);
6363

64-
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
65-
.withSerializer(serializer).withDeserializer(deserializer).withStrategy(TopicIdStrategy.class)
66-
.withDataGenerator(schema::generateMessage).withDataValidator(schema::validateMessage)
67-
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build().test();
64+
logRestClientError(() -> {
65+
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
66+
.withSerializer(serializer).withDeserializer(deserializer)
67+
.withStrategy(TopicIdStrategy.class).withDataGenerator(schema::generateMessage)
68+
.withDataValidator(schema::validateMessage)
69+
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build();
70+
});
6871
}
6972

7073
@Test
@@ -78,11 +81,13 @@ void testSimpleTopicIdStrategyFindLatest() throws Exception {
7881
createArtifact("default", artifactId, ArtifactType.PROTOBUF, schema.generateSchemaString(),
7982
ContentTypes.APPLICATION_PROTOBUF, null, null);
8083

81-
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
82-
.withSerializer(serializer).withDeserializer(deserializer)
83-
.withStrategy(SimpleTopicIdStrategy.class).withDataGenerator(schema::generateMessage)
84-
.withDataValidator(schema::validateMessage)
85-
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build().test();
84+
logRestClientError(() -> {
85+
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
86+
.withSerializer(serializer).withDeserializer(deserializer)
87+
.withStrategy(SimpleTopicIdStrategy.class).withDataGenerator(schema::generateMessage)
88+
.withDataValidator(schema::validateMessage)
89+
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build();
90+
});
8691
}
8792

8893
@Test
@@ -98,10 +103,12 @@ void testWrongSchema() throws Exception {
98103
createArtifact("default", artifactId, ArtifactType.PROTOBUF, schemaA.generateSchemaString(),
99104
ContentTypes.APPLICATION_PROTOBUF, null, null);
100105

101-
new WrongConfiguredSerdesTesterBuilder<TestCmmn.UUID>().withTopic(topicName)
102-
.withSerializer(serializer).withStrategy(TopicIdStrategy.class)
103-
// note, we use an incorrect wrong data generator in purpose
104-
.withDataGenerator(schemaB::generateMessage).build().test();
106+
logRestClientError(() -> {
107+
new WrongConfiguredSerdesTesterBuilder<TestCmmn.UUID>().withTopic(topicName)
108+
.withSerializer(serializer).withStrategy(TopicIdStrategy.class)
109+
// note, we use an incorrect wrong data generator in purpose
110+
.withDataGenerator(schemaB::generateMessage).build();
111+
});
105112
}
106113

107114
@Test
@@ -117,11 +124,13 @@ void testWrongSchemaFindLatest() throws Exception {
117124
createArtifact("default", artifactId, ArtifactType.PROTOBUF, schemaA.generateSchemaString(),
118125
ContentTypes.APPLICATION_PROTOBUF, null, null);
119126

120-
new WrongConfiguredSerdesTesterBuilder<TestCmmn.UUID>().withTopic(topicName)
121-
.withSerializer(serializer).withStrategy(TopicIdStrategy.class)
122-
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true")
123-
// note, we use an incorrect wrong data generator in purpose
124-
.withDataGenerator(schemaB::generateMessage).build().test();
127+
logRestClientError(() -> {
128+
new WrongConfiguredSerdesTesterBuilder<TestCmmn.UUID>().withTopic(topicName)
129+
.withSerializer(serializer).withStrategy(TopicIdStrategy.class)
130+
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true")
131+
// note, we use an incorrect wrong data generator in purpose
132+
.withDataGenerator(schemaB::generateMessage).build();
133+
});
125134
}
126135

127136
@Test
@@ -133,9 +142,11 @@ void testArtifactNotFound() throws Exception {
133142

134143
// note, we don't create any artifact
135144

136-
new WrongConfiguredSerdesTesterBuilder<ProtobufTestMessage>().withTopic(topicName)
137-
.withSerializer(serializer).withStrategy(TopicIdStrategy.class)
138-
.withDataGenerator(schema::generateMessage).build().test();
145+
logRestClientError(() -> {
146+
new WrongConfiguredSerdesTesterBuilder<ProtobufTestMessage>().withTopic(topicName)
147+
.withSerializer(serializer).withStrategy(TopicIdStrategy.class)
148+
.withDataGenerator(schema::generateMessage).build();
149+
});
139150
}
140151

141152
/**
@@ -208,12 +219,15 @@ void testConsumeDynamicMessage() throws Exception {
208219
createArtifact("default", artifactId, ArtifactType.PROTOBUF, schema.generateSchemaString(),
209220
ContentTypes.APPLICATION_PROTOBUF, null, null);
210221

211-
new SimpleSerdesTesterBuilder<ProtobufTestMessage, DynamicMessage>().withTopic(topicName)
212-
.withSerializer(serializer).withDeserializer(deserializer).withStrategy(TopicIdStrategy.class)
213-
.withDataGenerator(schema::generateMessage).withDataValidator(schema::validateDynamicMessage)
214-
.withConsumerProperty(SerdeConfig.DESERIALIZER_SPECIFIC_VALUE_RETURN_CLASS,
215-
DynamicMessage.class.getName())
216-
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build().test();
222+
logRestClientError(() -> {
223+
new SimpleSerdesTesterBuilder<ProtobufTestMessage, DynamicMessage>().withTopic(topicName)
224+
.withSerializer(serializer).withDeserializer(deserializer)
225+
.withStrategy(TopicIdStrategy.class).withDataGenerator(schema::generateMessage)
226+
.withDataValidator(schema::validateDynamicMessage)
227+
.withConsumerProperty(SerdeConfig.DESERIALIZER_SPECIFIC_VALUE_RETURN_CLASS,
228+
DynamicMessage.class.getName())
229+
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build();
230+
});
217231
}
218232

219233
@Test
@@ -227,12 +241,15 @@ void testConsumeReturnSpecificClass() throws Exception {
227241
createArtifact("default", artifactId, ArtifactType.PROTOBUF, schema.generateSchemaString(),
228242
ContentTypes.APPLICATION_PROTOBUF, null, null);
229243

230-
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
231-
.withSerializer(serializer).withDeserializer(deserializer).withStrategy(TopicIdStrategy.class)
232-
.withDataGenerator(schema::generateMessage).withDataValidator(schema::validateMessage)
233-
.withConsumerProperty(SerdeConfig.DESERIALIZER_SPECIFIC_VALUE_RETURN_CLASS,
234-
ProtobufTestMessage.class.getName())
235-
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build().test();
244+
logRestClientError(() -> {
245+
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
246+
.withSerializer(serializer).withDeserializer(deserializer)
247+
.withStrategy(TopicIdStrategy.class).withDataGenerator(schema::generateMessage)
248+
.withDataValidator(schema::validateMessage)
249+
.withConsumerProperty(SerdeConfig.DESERIALIZER_SPECIFIC_VALUE_RETURN_CLASS,
250+
ProtobufTestMessage.class.getName())
251+
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build();
252+
});
236253
}
237254

238255
@Test
@@ -246,11 +263,14 @@ void testFindLatestDeriveClassProtobufTypeTopicIdStrategy() throws Exception {
246263
createArtifact("default", artifactId, ArtifactType.PROTOBUF, schema.generateSchemaString(),
247264
ContentTypes.APPLICATION_PROTOBUF, null, null);
248265

249-
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
250-
.withSerializer(serializer).withDeserializer(deserializer).withStrategy(TopicIdStrategy.class)
251-
.withDataGenerator(schema::generateMessage).withDataValidator(schema::validateMessage)
252-
.withConsumerProperty(ProtobufKafkaDeserializerConfig.DERIVE_CLASS_FROM_SCHEMA, "true")
253-
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build().test();
266+
logRestClientError(() -> {
267+
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
268+
.withSerializer(serializer).withDeserializer(deserializer)
269+
.withStrategy(TopicIdStrategy.class).withDataGenerator(schema::generateMessage)
270+
.withDataValidator(schema::validateMessage)
271+
.withConsumerProperty(ProtobufKafkaDeserializerConfig.DERIVE_CLASS_FROM_SCHEMA, "true")
272+
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build();
273+
});
254274
}
255275

256276
@Test
@@ -264,12 +284,14 @@ public void testFindLatestDeriveClassProtobufTypeSimpleTopicIdStrategy() throws
264284
createArtifact("default", artifactId, ArtifactType.PROTOBUF, schema.generateSchemaString(),
265285
ContentTypes.APPLICATION_PROTOBUF, null, null);
266286

267-
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
268-
.withSerializer(serializer).withDeserializer(deserializer)
269-
.withStrategy(SimpleTopicIdStrategy.class).withDataGenerator(schema::generateMessage)
270-
.withDataValidator(schema::validateMessage)
271-
.withConsumerProperty(ProtobufKafkaDeserializerConfig.DERIVE_CLASS_FROM_SCHEMA, "true")
272-
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build().test();
287+
logRestClientError(() -> {
288+
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
289+
.withSerializer(serializer).withDeserializer(deserializer)
290+
.withStrategy(SimpleTopicIdStrategy.class).withDataGenerator(schema::generateMessage)
291+
.withDataValidator(schema::validateMessage)
292+
.withConsumerProperty(ProtobufKafkaDeserializerConfig.DERIVE_CLASS_FROM_SCHEMA, "true")
293+
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true").build();
294+
});
273295
}
274296

275297
@Test
@@ -286,21 +308,26 @@ public void testFindLatestSpecificProtobufType() throws Exception {
286308

287309
ProtobufTestMessageFactory schema = new ProtobufTestMessageFactory();
288310

289-
try {
311+
logRestClientError(() -> {
290312
new SimpleSerdesTesterBuilder<ProtobufTestMessage, ProtobufTestMessage>().withTopic(topicName)
291313
.withSerializer(serializer).withDeserializer(deserializer)
292314
.withStrategy(SimpleTopicIdStrategy.class).withDataGenerator(schema::generateMessage)
293315
.withDataValidator(schema::validateMessage)
294316
.withProducerProperty(SerdeConfig.FIND_LATEST_ARTIFACT, "true")
295-
.withProducerProperty(SerdeConfig.EXPLICIT_ARTIFACT_GROUP_ID, topicName).build().test();
317+
.withProducerProperty(SerdeConfig.EXPLICIT_ARTIFACT_GROUP_ID, topicName).build();
318+
});
319+
}
320+
321+
private void logRestClientError(Tester tester) throws Exception {
322+
try {
323+
tester.test();
296324
} catch (Error e) {
297-
java.lang.System.out.println("---------->>>");
325+
java.lang.System.out.println("---------->>> REST Client Error Detected");
298326
java.lang.System.out.println("Code: " + e.getResponseStatusCode());
299327
java.lang.System.out.println("Msg: " + e.getMessageEscaped());
300328
java.lang.System.out.println("Detail: " + e.getDetail());
301-
throw e;
329+
java.lang.System.out.println("----------");
302330
}
303-
304331
}
305332

306333
@Test

0 commit comments

Comments
 (0)