Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Sign up
Appearance settings

Commit c25eb9a

Browse files
committed
add comments for additional log output
1 parent 218b538 commit c25eb9a

File tree

7 files changed

+28
-0
lines changed

7 files changed

+28
-0
lines changed

‎src/ext-php-rdkafka/php-kafka-lib/avroHighLevelConsumer.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,10 @@
7979
//'ssl.endpoint.identification.algorithm' => 'https',
8080
//'sasl.username' => '',
8181
//'sasl.password' => '',
82+
83+
// Add additional output if you need to debug a problem
84+
// 'log_level' => (string) LOG_DEBUG,
85+
// 'debug' => 'all'
8286
]
8387
)
8488
->withAdditionalBroker('kafka:9096')

‎src/ext-php-rdkafka/php-kafka-lib/avroProducer.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,10 @@
6363
'client.id' => 'php-kafka-lib-producer-avro',
6464
// set compression (supported are: none,gzip,lz4,snappy,zstd)
6565
'compression.codec' => 'snappy',
66+
67+
// Add additional output if you need to debug a problem
68+
// 'log_level' => (string) LOG_DEBUG,
69+
// 'debug' => 'all'
6670
]
6771
)
6872
->withAdditionalBroker('kafka:9096')

‎src/ext-php-rdkafka/php-kafka-lib/highLevelConsumer.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,10 @@
3030
//'ssl.endpoint.identification.algorithm' => 'https',
3131
//'sasl.username' => '',
3232
//'sasl.password' => '',
33+
34+
// Add additional output if you need to debug a problem
35+
// 'log_level' => (string) LOG_DEBUG,
36+
// 'debug' => 'all'
3337
]
3438
)
3539
->withAdditionalBroker('kafka:9096')

‎src/ext-php-rdkafka/php-kafka-lib/producer.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,10 @@
1515
'client.id' => 'php-kafka-lib-producer',
1616
// set compression (supported are: none,gzip,lz4,snappy,zstd)
1717
'compression.codec' => 'snappy',
18+
19+
// Add additional output if you need to debug a problem
20+
// 'log_level' => (string) LOG_DEBUG,
21+
// 'debug' => 'all'
1822
]
1923
)
2024
->withAdditionalBroker('kafka:9096')

‎src/ext-php-rdkafka/pure-php/highLevelConsumer.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,10 @@
2929
//$conf->set('ssl.certificate.location', __DIR__.'/../../../keys/kafka.cert');
3030
//$conf->set('ssl.key.location', __DIR__.'/../../../keys/kafka.key');
3131

32+
// Add additional output if you need to debug a problem
33+
// $conf->set('log_level', (string) LOG_DEBUG);
34+
// $conf->set('debug', 'all');
35+
3236
// Create high level consumer
3337
$consumer = new KafkaConsumer($conf);
3438

‎src/ext-php-rdkafka/pure-php/producer.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,10 @@
4949
//$conf->set('ssl.certificate.location', __DIR__.'/../keys/kafka.cert');
5050
//$conf->set('ssl.key.location', __DIR__.'/../keys/kafka.key');
5151

52+
// Add additional output if you need to debug a problem
53+
// $conf->set('log_level', (string) LOG_DEBUG);
54+
// $conf->set('debug', 'all');
55+
5256
$producer = new Producer($conf);
5357
// initialize producer topic
5458
$topic = $producer->newTopic('pure-php-test-topic');

‎src/ext-php-rdkafka/pure-php/producer_transactional.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,10 @@ function echoTransactionError(KafkaErrorException $e) {
8383
//$conf->set('ssl.certificate.location', __DIR__.'/../keys/kafka.cert');
8484
//$conf->set('ssl.key.location', __DIR__.'/../keys/kafka.key');
8585

86+
// Add additional output if you need to debug a problem
87+
// $conf->set('log_level', (string) LOG_DEBUG);
88+
// $conf->set('debug', 'all');
89+
8690
$producer = new Producer($conf);
8791
// initialize producer topic
8892
$topic = $producer->newTopic('pure-php-transactional-test-topic');

0 commit comments

Comments
(0)

AltStyle によって変換されたページ (->オリジナル) /