Skip to content

Commit b35d69e

Browse files
committed
fix producer
1 parent 743fb65 commit b35d69e

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ https://github.com/edenhill/librdkafka
88
and rdkafka extension for php
99
https://github.com/arnaud-lb/php-rdkafka
1010

11-
I hope you will help my Dockerfile
11+
You can use dockerfile to create docker image where librdkafka and PHP kafka extension already installed:
1212
https://github.com/danikdantist/Dockerfiles/blob/master/php/php5-fpm-nginx-kafka/Dockerfile
1313

1414
Consumer usage:

src/Drivers/Kafka/Producer.php

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,11 +43,9 @@ protected function init()
4343
{
4444
$this->logInfo('Initialize producer');
4545
$this->isInit = true;
46-
pcntl_sigprocmask(SIG_BLOCK, array(SIGIO));
4746

4847
$conf = new \RdKafka\Conf();
4948
$conf->set('receive.message.max.bytes',1000000);
50-
$conf->set('internal.termination.signal', SIGIO);
5149
$conf->set('topic.metadata.refresh.sparse',true);
5250
$conf->set('topic.metadata.refresh.interval.ms',600000);
5351
$conf->set('queued.max.messages.kbytes',100000000);

0 commit comments

Comments
 (0)