fix(enhancement): subjects & stream create/delete for test cases

[MustafaMunir123]

Issue description

I have noticed that in order to pass some of the test cases we need to either create the required subjects manually or to make changes in code of each test case to pass.

Subjects

• ConsumeTest:
  kestra.consumeSince.>, kestra.consumeMessageFromSubject.topic, kestra.consumeMessageFromSubject.anotherTopic

• TriggerTest:
  kestra.trigger

• RealtimeTriggerTest:
  kestra.realtime.trigger

• ProduceTest:
  kestra.produce.<uuid>

Test-cases should be able to setup environment for them to execute properly, so we can add methods in test classes to create subjects before testing the feature and a method that deletes the created subjects afterwards.

I would like to do this if this needs a PR.