File tree Expand file tree Collapse file tree 3 files changed +21
-25
lines changed Expand file tree Collapse file tree 3 files changed +21
-25
lines changed Original file line number Diff line number Diff line change 6565 <file role =" test" name =" allow_null_payload.phpt" />
6666 <file role =" test" name =" bugConfSetArgument.phpt" />
6767 <file role =" test" name =" conf.phpt" />
68- <file role =" test" name =" conf_callbacks.phpt" />
6968 <file role =" test" name =" conf_callbacks_integration.phpt" />
7069 <file role =" test" name =" constants.phpt" />
7170 <file role =" test" name =" consumer_topic_destruct.phpt" />
Original file line number Diff line number Diff line change @@ -43,6 +43,21 @@ $conf->setStatsCb(function () { });
4343$ dump = $ conf ->dump ();
4444var_dump (isset ($ dump ["stats_cb " ]));
4545
46+ echo "Setting offset_commit callback \n" ;
47+ $ conf ->setOffsetCommitCb (function () { });
48+ $ dump = $ conf ->dump ();
49+ var_dump (isset ($ dump ["offset_commit_cb " ]));
50+
51+ echo "Setting rebalance callback \n" ;
52+ $ conf ->setRebalanceCb (function () { });
53+ $ dump = $ conf ->dump ();
54+ var_dump (isset ($ dump ["rebalance_cb " ]));
55+
56+ echo "Setting log callback \n" ;
57+ $ conf ->setLogCb (function () { });
58+ $ dump = $ conf ->dump ();
59+ var_dump (isset ($ dump ["log_cb " ]));
60+
4661echo "Dumping conf \n" ;
4762var_dump (array_intersect_key ($ conf ->dump (), array (
4863 "client.id " => true ,
@@ -64,6 +79,12 @@ Setting dr_msg callback
6479bool (true )
6580Setting stats callback
6681bool(true)
82+ Setting offset_commit callback
83+ bool (true )
84+ Setting rebalance callback
85+ bool(true)
86+ Setting log callback
87+ bool (true )
6788Dumping conf
6889array (3 ) {
6990 ["client.id " ]=>
Load Diff This file was deleted.
You can’t perform that action at this time.
0 commit comments