Struct resp = new Struct(ProtoUtils.currentResponseSchema(ApiKeys.PRODUCE.id));
resp.set("responses", new Object[0]);
int size = respHeader.sizeOf() + resp.sizeOf();
ByteBuffer buffer = ByteBuffer.allocate(size);
respHeader.writeTo(buffer);
resp.writeTo(buffer);
buffer.flip();
selector.completeReceive(new NetworkReceive(node.id(), buffer));
List<ClientResponse> responses = client.poll(new ArrayList<ClientRequest>(), 1, time.milliseconds());
assertEquals(1, responses.size());
ClientResponse response = responses.get(0);