robinvish2794 commented on PR #648:
URL: https://github.com/apache/camel-karaf/pull/648#issuecomment-3388854750
I am trying to write ITest for Kafka compression but failing miserably with
kafka test container issue. I was wondering if someone could help me with ITest.
E.g. producer with compression codec -
```java
@Override
protected void configureProducer(RouteBuilder builder, RouteDefinition
producerRoute) {
producerRoute.log("calling kafka topic")
.setBody(builder.constant("OK"))
.toF("kafka://%s?compressionCodec=snappy", KAFKA_TOPIC)
.log("kafka topic called");
}
```
kafka test container works for compression test but fails for the next one -
CamelKafkaCompressionITest: testResultMock
bundle:list -s -t 0 | grep camel-kafka-test
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 57.73
s -- in org.apache.karaf.camel.itest.CamelKafkaCompressionITest
[INFO] Running org.apache.karaf.camel.itest.CamelKafkaITest
[tc.confluentinc/cp-kafka:7.6.1] ERROR : Could not start container
com.github.dockerjava.api.exception.NotFoundException: Status 404:
{"message":"No such image: confluentinc/cp-kafka:7.6.1"}
[ERROR] Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed:
0.004 s <<< FAILURE! -- in org.apache.karaf.camel.itest.CamelKafkaITest
[ERROR] org.apache.karaf.camel.itest.CamelKafkaITest.initializationError --
Time elapsed: 0 s <<< ERROR!
Somehow the previously ran container does not work for the next one. I took
reference from camel-netty-http example -
https://github.com/apache/camel-karaf/tree/main/tests/features/camel-netty-http
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
