Skip to content
Pull Request

Improve catalog information synchronisation with GraphQL #50

Sign in to view logs

Improve catalog information synchronisation with GraphQL

Improve catalog information synchronisation with GraphQL #50

GitHub Actions / JUnit Test Report failed Feb 5, 2025 in 0s

651 tests run, 642 passed, 0 skipped, 9 failed.

Annotations

Check failure on line 558 in src/test/java/com/michelin/ns4kafka/integration/ConnectorIntegrationTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

ConnectorIntegrationTest.shouldPauseAndResumeConnector() 

java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopicsFromNames(TopicAsyncExecutor.java:439)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopics(TopicAsyncExecutor.java:241)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.synchronizeTopics(TopicAsyncExecutor.java:110)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.run(TopicAsyncExecutor.java:99)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at com.michelin.ns4kafka.integration.ConnectorIntegrationTest.shouldPauseAndResumeConnector(ConnectorIntegrationTest.java:558)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

Check failure on line 482 in src/test/java/com/michelin/ns4kafka/integration/ConnectorIntegrationTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

ConnectorIntegrationTest.shouldRestartConnector() 

java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopicsFromNames(TopicAsyncExecutor.java:439)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopics(TopicAsyncExecutor.java:241)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.synchronizeTopics(TopicAsyncExecutor.java:110)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.run(TopicAsyncExecutor.java:99)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at com.michelin.ns4kafka.integration.ConnectorIntegrationTest.shouldRestartConnector(ConnectorIntegrationTest.java:482)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

Check failure on line 272 in src/test/java/com/michelin/ns4kafka/integration/ConnectorIntegrationTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

ConnectorIntegrationTest.shouldDeployConnectors() 

java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopicsFromNames(TopicAsyncExecutor.java:439)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopics(TopicAsyncExecutor.java:241)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.synchronizeTopics(TopicAsyncExecutor.java:110)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.run(TopicAsyncExecutor.java:99)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at com.michelin.ns4kafka.integration.ConnectorIntegrationTest.shouldDeployConnectors(ConnectorIntegrationTest.java:272)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

Check failure on line 412 in src/test/java/com/michelin/ns4kafka/integration/ConnectorIntegrationTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

ConnectorIntegrationTest.shouldUpdateConnectorsWithNullProperty() 

java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopicsFromNames(TopicAsyncExecutor.java:439)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopics(TopicAsyncExecutor.java:241)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.synchronizeTopics(TopicAsyncExecutor.java:110)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.run(TopicAsyncExecutor.java:99)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at com.michelin.ns4kafka.integration.ConnectorIntegrationTest.shouldUpdateConnectorsWithNullProperty(ConnectorIntegrationTest.java:412)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

Check failure on line 545 in src/test/java/com/michelin/ns4kafka/integration/TopicIntegrationTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

TopicIntegrationTest.shouldDeleteRecords() 

java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopicsFromNames(TopicAsyncExecutor.java:439)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopics(TopicAsyncExecutor.java:241)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.synchronizeTopics(TopicAsyncExecutor.java:110)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.run(TopicAsyncExecutor.java:99)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at com.michelin.ns4kafka.integration.TopicIntegrationTest.forceTopicSynchronization(TopicIntegrationTest.java:720)
	at com.michelin.ns4kafka.integration.TopicIntegrationTest.shouldDeleteRecords(TopicIntegrationTest.java:545)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

Check failure on line 345 in src/test/java/com/michelin/ns4kafka/integration/TopicIntegrationTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

TopicIntegrationTest.shouldUpdateTopic() 

java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopicsFromNames(TopicAsyncExecutor.java:439)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopics(TopicAsyncExecutor.java:241)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.synchronizeTopics(TopicAsyncExecutor.java:110)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.run(TopicAsyncExecutor.java:99)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at com.michelin.ns4kafka.integration.TopicIntegrationTest.forceTopicSynchronization(TopicIntegrationTest.java:720)
	at com.michelin.ns4kafka.integration.TopicIntegrationTest.shouldUpdateTopic(TopicIntegrationTest.java:345)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

Check failure on line 289 in src/test/java/com/michelin/ns4kafka/integration/TopicIntegrationTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

TopicIntegrationTest.shouldCreateTopic() 

java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopicsFromNames(TopicAsyncExecutor.java:439)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopics(TopicAsyncExecutor.java:241)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.synchronizeTopics(TopicAsyncExecutor.java:110)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.run(TopicAsyncExecutor.java:99)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at com.michelin.ns4kafka.integration.TopicIntegrationTest.forceTopicSynchronization(TopicIntegrationTest.java:720)
	at com.michelin.ns4kafka.integration.TopicIntegrationTest.shouldCreateTopic(TopicIntegrationTest.java:289)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

Check failure on line 698 in src/test/java/com/michelin/ns4kafka/integration/TopicIntegrationTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

TopicIntegrationTest.shouldDeleteTopics() 

java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopicsFromNames(TopicAsyncExecutor.java:439)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopics(TopicAsyncExecutor.java:241)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.synchronizeTopics(TopicAsyncExecutor.java:110)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.run(TopicAsyncExecutor.java:99)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at com.michelin.ns4kafka.integration.TopicIntegrationTest.forceTopicSynchronization(TopicIntegrationTest.java:720)
	at com.michelin.ns4kafka.integration.TopicIntegrationTest.shouldDeleteTopics(TopicIntegrationTest.java:698)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

Check failure on line 615 in src/test/java/com/michelin/ns4kafka/integration/TopicIntegrationTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

TopicIntegrationTest.shouldDeleteRecordsOnCompactTopic() 

java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "com.michelin.ns4kafka.property.ConfluentCloudProperties$StreamCatalogProperties.isSyncCatalog()" because the return value of "com.michelin.ns4kafka.property.ConfluentCloudProperties.getStreamCatalog()" is null
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopicsFromNames(TopicAsyncExecutor.java:439)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.collectBrokerTopics(TopicAsyncExecutor.java:241)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.synchronizeTopics(TopicAsyncExecutor.java:110)
	at com.michelin.ns4kafka.service.executor.TopicAsyncExecutor.run(TopicAsyncExecutor.java:99)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at com.michelin.ns4kafka.integration.TopicIntegrationTest.forceTopicSynchronization(TopicIntegrationTest.java:720)
	at com.michelin.ns4kafka.integration.TopicIntegrationTest.shouldDeleteRecordsOnCompactTopic(TopicIntegrationTest.java:615)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
View more details on GitHub Actions