Skip to content

Commit 3f742e4

Browse files
authored
fix rename (#2)
* fix rename * small fixes * remove example
1 parent a15a17e commit 3f742e4

File tree

4 files changed

+11
-19
lines changed

4 files changed

+11
-19
lines changed

Diff for: src/ext-php-kafka/pure-php/highLevelConsumer.php renamed to src/ext-php-simple-kafka-client/pure-php/highLevelConsumer.php

+2-7
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<?php
22

3-
use Kafka\Configuration;
4-
use Kafka\Consumer;
3+
use SimpleKafkaClient\Configuration;
4+
use SimpleKafkaClient\Consumer;
55

66
$conf = new Configuration();
77
// will be visible in broker logs
@@ -16,11 +16,6 @@
1616
$conf->set('auto.offset.reset', 'earliest');
1717
// Get eof code instead of null
1818
$conf->set('enable.partition.eof', 'true');
19-
$conf->setOffsetCommitCb(
20-
function($kafka, $err, $partitions) {
21-
echo var_dump($x);
22-
}
23-
);
2419

2520
// SASL Authentication
2621
//$conf->set('sasl.mechanisms', '');

Diff for: src/ext-php-kafka/pure-php/metadata.php renamed to src/ext-php-simple-kafka-client/pure-php/metadata.php

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<?php
22

3-
use Kafka\Configuration;
4-
use Kafka\Producer;
3+
use SimpleKafkaClient\Configuration;
4+
use SimpleKafkaClient\Producer;
55

66
error_reporting(E_ALL);
77

Diff for: src/ext-php-kafka/pure-php/producer.php renamed to src/ext-php-simple-kafka-client/pure-php/producer.php

+3-4
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
<?php
22

3-
use Kafka\Configuration;
4-
use Kafka\Message;
5-
use Kafka\Producer;
3+
use SimpleKafkaClient\Configuration;
4+
use SimpleKafkaClient\Message;
5+
use SimpleKafkaClient\Producer;
66

77
error_reporting(E_ALL);
88

@@ -26,7 +26,6 @@
2626

2727
echo sprintf('Message FAILED (%s, %s) to send with payload => %s', $message->err, $errorStr, $message->payload) . PHP_EOL;
2828
} else {
29-
// message successfully delivered
3029
echo sprintf('Message sent SUCCESSFULLY with payload => %s', $message->payload) . PHP_EOL;
3130
}
3231
});

Diff for: src/ext-php-kafka/pure-php/producer_transactional.php renamed to src/ext-php-simple-kafka-client/pure-php/producer_transactional.php

+4-6
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,9 @@
11
<?php
22

3-
// DISCLAIMER: this feature is not released yet and is subject to change
4-
5-
use Kafka\Configuration;
6-
use Kafka\Message;
7-
use Kafka\Producer;
8-
use Kafka\KafkaErrorException;
3+
use SimpleKafkaClient\Configuration;
4+
use SimpleKafkaClient\Message;
5+
use SimpleKafkaClient\Producer;
6+
use SimpleKafkaClient\KafkaErrorException;
97

108
error_reporting(E_ALL);
119

0 commit comments

Comments
 (0)