`kafka_franz` failing int. tests

[jem-davies]

internal/impl/kafka/input_kafka_franz_test.go

TestIntegrationFranzInputDetectUnknownTopicError

go test -run TestIntegrationFranzInputDetectUnknownTopicError -v                                                                                                                                                    33s
=== RUN   TestIntegrationFranzInputDetectUnknownTopicError
=== PAUSE TestIntegrationFranzInputDetectUnknownTopicError
=== CONT  TestIntegrationFranzInputDetectUnknownTopicError
    input_kafka_franz_test.go:272: connect should've stopped before timeout due to unknown topic error
--- FAIL: TestIntegrationFranzInputDetectUnknownTopicError (12.80s)

TestIntegrationFranzInputReconnectUnknownTopicError

go test -run TestIntegrationFranzInputReconnectUnknownTopicError -v 
=== RUN   TestIntegrationFranzInputReconnectUnknownTopicError
=== PAUSE TestIntegrationFranzInputReconnectUnknownTopicError
=== CONT  TestIntegrationFranzInputReconnectUnknownTopicError
INFO Sending inproc messages to ID: fb4d2fea-acac-4056-994c-0313adbe8160  @service=bento label="" path=root.output
INFO Input type kafka_franz is now active          @service=bento label="" path=root.input
    input_kafka_franz_test.go:390: 
                Error Trace:    /Users/jemdavies/Projects/bento_copy/bento/internal/impl/kafka/input_kafka_franz_test.go:390
                Error:          Condition never satisfied
                Test:           TestIntegrationFranzInputReconnectUnknownTopicError
--- FAIL: TestIntegrationFranzInputReconnectUnknownTopicError (20.78s)
FAIL
exit status 1
FAIL    github.com/warpstreamlabs/bento/internal/impl/kafka     21.281s