Skip to content

Commit e59537c

Browse files
committed
fix: regression by 084b45d
1 parent 084b45d commit e59537c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ int main(int argc, char *argv[]) noexcept(false) {
115115

116116
auto *rk =
117117
rd_kafka_new(RD_KAFKA_PRODUCER, rk_conf, errstr.data(), errstr.size());
118-
if (rk != nullptr) {
118+
if (rk == nullptr) {
119119
fail("create producer");
120120
}
121121
GUARD(rk, rd_kafka_destroy);

0 commit comments

Comments
 (0)