avro

0зной

1ответ

protobuf в avro закодированном сообщении на kafka

Хотел бы узнать, есть ли лучший способ решить проблему, которая у нас есть. Вот поток: Наш клиентский код понимает только протокольные буферы (protobuf). На стороне сервера наш шлюз получает protobuf

0зной

1ответ

Должен ли я переходить из REST-HTTP в Rabbitmq-RPC для синхронного вызова?

Я читал много, многие люди не предлагали использовать AQMP-RPC для синхронного вызова. Размер моего ответа составляет 4 МБ, поэтому REST-HTTP занимает слишком много времени для отправки данных с серве

0зной

1ответ

Чтение в файле avro с boto3 и преобразование в строку (Python)

Я использую boto3 для чтения в файле avro из моего s3-ведра. Однако я зациклился на том, как фактически преобразовать avro в строку. avro_file = file_from_s3.get()['Body'].read() После получения это

1зной

1ответ

как отправить схему avro ТОЛЬКО один раз в kafka

Я использую следующий код (не совсем, но давайте предположим), чтобы создать схему и отправить ее кафке производителем. public static final String USER_SCHEMA = "{" + "\"type\":\"record\","

3зной

1ответ

почему Avro сгенерированный код Java имеет так много устаревших fileds

Я использую Авро-Maven-плагин 1.8.1 для создания Java-кода из схемы, и все поля являются общедоступными и осуждается, как это: public class data_elements extends org.apache.avro.specific.SpecificRecor