* @param array $records List of records to append
*/
protected function addMessages( $channel, array $records ) {
* @param array $records List of records to append
*/
protected function addMessages( $channel, array $records ) {
$partition = $this->getRandomPartition( $topic );
if ( $partition !== null ) {
$this->produce->setMessages( $topic, $partition, $records );
$partition = $this->getRandomPartition( $topic );
if ( $partition !== null ) {
$this->produce->setMessages( $topic, $partition, $records );