@@ -94,7 +94,7 @@ public function testSetPartitioner(): void
9494 $ producer ->flush (KAFKA_TEST_LONG_TIMEOUT_MS );
9595
9696 $ consumer = new Consumer ($ conf );
97- $ consumerTopic = $ consumer ->newTopic (KAFKA_TEST_TOPIC_PARTITIONS , $ topicConf );
97+ $ consumerTopic = $ consumer ->newTopic (KAFKA_TEST_TOPIC_PARTITIONS );
9898
9999 $ consumerTopic ->consumeStart (1 , rd_kafka_offset_tail (2 ));
100100 $ messages = $ this ->consumeMessagesWithConsumerTopic ($ consumerTopic , 1 , 2 );
@@ -144,7 +144,7 @@ function ($key, $partitionCount) {
144144 $ producer ->flush (KAFKA_TEST_LONG_TIMEOUT_MS );
145145
146146 $ consumer = new Consumer ($ conf );
147- $ consumerTopic = $ consumer ->newTopic (KAFKA_TEST_TOPIC_PARTITIONS , $ topicConf );
147+ $ consumerTopic = $ consumer ->newTopic (KAFKA_TEST_TOPIC_PARTITIONS );
148148
149149 $ consumerTopic ->consumeStart (2 , rd_kafka_offset_tail (4 ));
150150 $ messages = $ this ->consumeMessagesWithConsumerTopic ($ consumerTopic , 2 , 4 );
@@ -187,7 +187,7 @@ function (?string $key, int $partitionCount, ?object $topic_opaque = null, ?obje
187187 $ producer ->flush (KAFKA_TEST_LONG_TIMEOUT_MS );
188188
189189 $ consumer = new Consumer ($ conf );
190- $ consumerTopic = $ consumer ->newTopic (KAFKA_TEST_TOPIC_PARTITIONS , $ topicConf );
190+ $ consumerTopic = $ consumer ->newTopic (KAFKA_TEST_TOPIC_PARTITIONS );
191191
192192 $ consumerTopic ->consumeStart (2 , rd_kafka_offset_tail (1 ));
193193 $ messages = $ this ->consumeMessagesWithConsumerTopic ($ consumerTopic , 2 , 1 );
0 commit comments