生产者发送成功，kafka里却没有信息

[jhomephper]

Start sync metadata request
Start sync metadata request params:[]
Start Request ClientId: kafka-php ApiKey: MetadataRequest ApiVersion: 0
Send message start, params:{"required_ack":1,"timeout":5000,"data":{"test":{"partitions":[{"partition_id":0,"messages":["test....message."]}],"topic_name":"test"}}}
Start Request ClientId: kafka-php ApiKey: ProduceRequest ApiVersion: 2
Send message sucess, result: {"throttleTime":0,"data":[{"topicName":"test","partitions":[{"partition":0,"errorCode":0,"offset":22,"timestamp":-1}]}]}

[jhomephper]

Start sync metadata request
Start sync metadata request params:[]
Start Request ClientId: kafka-php ApiKey: MetadataRequest ApiVersion: 0
Send message start, params:{"required_ack":1,"timeout":5000,"data":{"test":{"partitions":[{"partition_id":0,"messages":["test....message."]}],"topic_name":"test"}}}
Start Request ClientId: kafka-php ApiKey: ProduceRequest ApiVersion: 2
Send message sucess, result: {"throttleTime":0,"data":[{"topicName":"test","partitions":[{"partition":0,"errorCode":0,"offset":22,"timestamp":-1}]}]}
array(2) {
["throttleTime"]=>
int(0)
["data"]=>
array(1) {
[0]=>
array(2) {
["topicName"]=>
string(4) "test"
["partitions"]=>
array(1) {
[0]=>
array(4) {
["partition"]=>
int(0)
["errorCode"]=>
int(0)
["offset"]=>
int(22)
["timestamp"]=>
int(-1)
}
}
}
}
}

[zhangdang254]

解决了吗 兄弟

[burningice529]

作者在ConsumeConfig把maxBytes写死了65536。修改一下，或者继承一下，实现set方法即可。已提交修复等作者处理

/**
     * @var mixed[]
     */
    protected static $defaults = [
        'groupId'          => '',
        'sessionTimeout'   => 30000,
        'rebalanceTimeout' => 30000,
        'topics'           => [],
        'offsetReset'      => 'latest', // earliest
        'maxBytes'         => 65536, // 64kb
        'maxWaitTime'      => 100,
    ];