Skip to content

Commit 1ce15dd

Browse files
committed
refactoring
1 parent 1f53582 commit 1ce15dd

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

tests/0154-metadata_refresh.c

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -91,8 +91,7 @@ static void test_metadata_log_cb(const rd_kafka_t *rk,
9191

9292
static rd_kafka_t *create_consumer(
9393
const char *topic,
94-
const char *group,
95-
void (*log_cb)(const rd_kafka_t *, int, const char *, const char *)) {
94+
const char *group) {
9695
rd_kafka_conf_t *conf;
9796
test_conf_init(&conf, NULL, 60);
9897
test_conf_set(conf, "group.id", group);
@@ -117,8 +116,8 @@ static void setup_and_run_metadata_refresh_test(void) {
117116
test_create_topic(NULL, topic, initial_partitions, 1);
118117

119118
TEST_SAY("Creating consumers\n");
120-
c1 = create_consumer(topic, group, test_metadata_log_cb);
121-
c2 = create_consumer(topic, group, test_metadata_log_cb);
119+
c1 = create_consumer(topic, group);
120+
c2 = create_consumer(topic, group);
122121

123122
rk = test_create_handle(RD_KAFKA_PRODUCER, NULL);
124123

0 commit comments

Comments
 (0)