Избегание копии массива для оптимизации, также если мы снова используем Bytebuffer с пользовательским сериализатором, мы должны создать новый массив для отправки < /p>
// Create Kafka Producer
KafkaProducer producer = new KafkaProducer(props);
// Sample byte array {1,2,3,4,5,6,7,8,9,10}
byte[] byteArr = new byte[10];
for (int i = 0; i < 10; i++)
byteArr = (byte) (i + 1);
String topic = "byte-topic";
// sample Send message
ProducerRecord recordEx = new ProducerRecord(topic, "key1", byteArr);
// ????? want to send data from 5 pos to 10 pos without creating new Array
ProducerRecord recordReq = new ProducerRecord(topic, "key1", byteArr);
producer.send(record);
Подробнее здесь: https://stackoverflow.com/questions/797 ... -via-kafka