Commit 3f742e4

authored

fix rename (#2)

* fix rename * small fixes * remove example

1 parent a15a17e commit 3f742e4Copy full SHA for 3f742e4

File tree

+11

-19

lines changed

+11

-19

lines changed

Lines changed: 2 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`<?php`
`2`	`2`
`3`		`-use Kafka\Configuration;`
`4`		`-use Kafka\Consumer;`
	`3`	`+use SimpleKafkaClient\Configuration;`
	`4`	`+use SimpleKafkaClient\Consumer;`
`5`	`5`
`6`	`6`	`$conf = new Configuration();`
`7`	`7`	`// will be visible in broker logs`
`@@ -16,11 +16,6 @@`
`16`	`16`	`$conf->set('auto.offset.reset', 'earliest');`
`17`	`17`	`// Get eof code instead of null`
`18`	`18`	`$conf->set('enable.partition.eof', 'true');`
`19`		`-$conf->setOffsetCommitCb(`
`20`		`- function($kafka, $err, $partitions) {`
`21`		`- echo var_dump($x);`
`22`		`- }`
`23`		`-);`
`24`	`19`
`25`	`20`	`// SASL Authentication`
`26`	`21`	`//$conf->set('sasl.mechanisms', '');`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`<?php`
`2`	`2`
`3`		`-use Kafka\Configuration;`
`4`		`-use Kafka\Producer;`
	`3`	`+use SimpleKafkaClient\Configuration;`
	`4`	`+use SimpleKafkaClient\Producer;`
`5`	`5`
`6`	`6`	`error_reporting(E_ALL);`
`7`	`7`

Lines changed: 3 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,8 +1,8 @@`
`1`	`1`	`<?php`
`2`	`2`
`3`		`-use Kafka\Configuration;`
`4`		`-use Kafka\Message;`
`5`		`-use Kafka\Producer;`
	`3`	`+use SimpleKafkaClient\Configuration;`
	`4`	`+use SimpleKafkaClient\Message;`
	`5`	`+use SimpleKafkaClient\Producer;`
`6`	`6`
`7`	`7`	`error_reporting(E_ALL);`
`8`	`8`
`@@ -26,7 +26,6 @@`
`26`	`26`
`27`	`27`	`echo sprintf('Message FAILED (%s, %s) to send with payload => %s', $message->err, $errorStr, $message->payload) . PHP_EOL;`
`28`	`28`	`} else {`
`29`		`- // message successfully delivered`
`30`	`29`	`echo sprintf('Message sent SUCCESSFULLY with payload => %s', $message->payload) . PHP_EOL;`
`31`	`30`	`}`
`32`	`31`	`});`

Lines changed: 4 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,11 +1,9 @@`
`1`	`1`	`<?php`
`2`	`2`
`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;`
`9`	`7`
`10`	`8`	`error_reporting(E_ALL);`
`11`	`9`

Comments

(0)