fix AWS S3: bucket name not resolved when using URL configuration
@@ -34,7 +34,6 @@ import org.apache.camel.kafkaconnector.common.utils.TestUtils;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.Timeout;
import org.junit.jupiter.api.extension.RegisterExtension;
@@ -159,8 +158,6 @@ public class CamelSourceAWSS3ITCase extends AbstractKafkaTest {
runTest(connectorPropertyFactory);
}
-
- @Disabled("Disabled due to issue #260")
@Test
@Timeout(180)
public void testBasicSendReceiveUsingUrl() throws ExecutionException, InterruptedException {
@@ -169,8 +166,8 @@ public class CamelSourceAWSS3ITCase extends AbstractKafkaTest {
ConnectorPropertyFactory connectorPropertyFactory = CamelAWSS3PropertyFactory
.basic()
.withKafkaTopic(TestUtils.getDefaultTestTopic(this.getClass()))
+ .withConfiguration(TestS3Configuration.class.getName())
.withUrl(AWSCommon.DEFAULT_S3_BUCKET)
- .append("configuration", CamelAWSS3PropertyFactory.classRef(TestS3Configuration.class.getName()))
.append("accessKey", amazonProperties.getProperty(AWSConfigs.ACCESS_KEY))
.append("secretKey", amazonProperties.getProperty(AWSConfigs.SECRET_KEY))
.append("proxyProtocol", amazonProperties.getProperty(AWSConfigs.PROTOCOL))
