-
Notifications
You must be signed in to change notification settings - Fork 13
Closed
Description
In case Kafka is down then Admin client will raise errors.
PSEUDOCODE
Setup Start process docker run kafka
Teardown Kill kafka docker process
*** Test Cases ***
Do something with Kafka
${kafka admin id}= Create Admin Client
# do anything as an admin
# there is no command to close admin client
After running test test will pass but there would also be some errors like
Do something with Kafka | PASS |
------------------------------------------------------------------------------
%6|1717586084.749|FAIL|rdkafka#producer-1| [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/1: Disconnected (after 8035ms in state UP)
My.Super.Kafka.TestSuite | PASS |
1 test, 1 passed, 0 failed
Could you add a method to close admin client in KafkaAdminClient class? Probably KafkaProducer class would also need one.
Metadata
Metadata
Assignees
Labels
No labels