"app.configuration-filepath=./src/test/resources/test_application_configuration.json", //
"app.pm-files-path=./src/test/resources/", //
"app.s3.locksBucket=ropfilelocks", //
- "app.pm-files-path=/tmp/dmaapadaptor", //
- "app.s3.bucket=dmaaptest", //
+ "app.pm-files-path=/tmp/pmproducer", //
+ "app.s3.bucket=pmproducertest", //
"app.auth-token-file=src/test/resources/jwtToken.b64", //
"app.kafka.use-oath-token=false"}) //
+/**
+ * Tests interwork with Kafka and Minio
+ * Requires that Kafka and ICS is started.
+ */
class IntegrationWithKafka {
final static String PM_TYPE_ID = "PmDataOverKafka";
@Test
void testHistoricalData() throws Exception {
- // test
+ // test that it works to get already fetched data
final String JOB_ID = "testHistoricalData";
DataStore fileStore = dataStore();