Как передать несколько данных в кафку производителя?
Необходимо передать несколько данных (объект) вместе с данными файла,
Есть ли сериализатор для передачи объекта или какие-либо пути?
Вот код, который просто передает данные файла,
props.put("bootstrap.servers", "localhost:9092");
props.put("metadata.broker.list", "localhost:9093");
props.put("producer.type", "async");
props.put("batch.size", "500");
props.put("compression.codec", "1");
props.put("compression.topic", "WRA");
// props.put("key.serializer",
// "org.apache.kafka.common.serialization.StringSerializer");
props.put("key.serializer", "org.apache.kafka.common.serialization.IntegerSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer");
org.apache.kafka.clients.producer.Producer<Integer, byte[]> producer = new KafkaProducer<Integer, byte[]>(
props);
producer.send(new ProducerRecord<Integer, byte[]>("topic1", file.getBytes()));