本文整理了Java中org.apache.kafka.common.utils.Utils.readBytes()方法的一些代码示例，展示了Utils.readBytes()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Utils.readBytes()方法的具体详情如下：
包路径：org.apache.kafka.common.utils.Utils
类名称：Utils
方法名：readBytes

Utils.readBytes介绍

[英]Read the given byte buffer into a Byte array
[中]将给定的字节缓冲区读入字节数组

代码示例

代码示例来源：origin: apache/kafka

/**
 * Read the given byte buffer into a Byte array
 */
public static byte[] readBytes(ByteBuffer buffer) {
  return Utils.readBytes(buffer, 0, buffer.limit());
}

代码示例来源：origin: apache/kafka

private void subTest(ByteBuffer buffer) {
  // The first byte should be 'A'
  assertEquals('A', (Utils.readBytes(buffer, 0, 1))[0]);
  // The offset is 2, so the first 2 bytes should be skipped.
  byte[] results = Utils.readBytes(buffer, 2, 3);
  assertEquals('y', results[0]);
  assertEquals(' ', results[1]);
  assertEquals('S', results[2]);
  assertEquals(3, results.length);
  // test readBytes without offset and length specified.
  results = Utils.readBytes(buffer);
  assertEquals('A', results[0]);
  assertEquals('t', results[buffer.limit() - 1]);
  assertEquals(buffer.limit(), results.length);
}

代码示例来源：origin: apache/kafka

private byte[] receiveToken() throws IOException {
  if (saslAuthenticateVersion == DISABLE_KAFKA_SASL_AUTHENTICATE_HEADER) {
    return receiveResponseOrToken();
  } else {
    SaslAuthenticateResponse response = (SaslAuthenticateResponse) receiveKafkaResponse();
    if (response != null) {
      Errors error = response.error();
      if (error != Errors.NONE) {
        setSaslState(SaslState.FAILED);
        String errMsg = response.errorMessage();
        throw errMsg == null ? error.exception() : error.exception(errMsg);
      }
      long sessionLifetimeMs = response.sessionLifetimeMs();
      if (sessionLifetimeMs > 0L)
        reauthInfo.positiveSessionLifetimeMs = sessionLifetimeMs;
      return Utils.readBytes(response.saslAuthBytes());
    } else
      return null;
  }
}

代码示例来源：origin: apache/kafka

byte[] responseToken = saslServer.evaluateResponse(Utils.readBytes(saslAuthenticateRequest.saslAuthBytes()));
if (reauthInfo.reauthenticating() && saslServer.isComplete())
  reauthInfo.ensurePrincipalUnchanged(principal());

代码示例来源：origin: org.apache.kafka/connect-api

byte[] bytes = Utils.readBytes((ByteBuffer) value);
  append(sb, bytes, embedded);
} else if (value instanceof List) {