Tag: PROTOCOL-BUFFERS
Estoy tratando de leer e imprimir mensajes Protobuf desde Kafka utilizando Apache Flink. Seguí la documentación oficial sin éxito: https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/serialization/third-party-serializers/ El código consumidor de Flink es: “` def main(args: Array[String]): Unit = { val env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI() env.enableCheckpointing(5000) env.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE) env.getCheckpointConfig.setCheckpointStorage(s”$targetPath/checkpoints”) env.getConfig.registerTypeWithKryoSerializer(classOf[User], classOf[ProtobufSerializer]) val source = KafkaSource.builder[User] .setBootstrapServers(brokers) .setTopics(topic) .setGroupId(consumerGroupId) .setValueOnlyDeserializer(new . . . Read more
Tengo la siguiente estructura de directorios: pb/ ├─ service/ │ ├─ service.proto │ ├─ BUILD ├─ common/ │ ├─ common.proto │ ├─ BUILD Cada servicio define un objetivo “rules.proto.grpc” para la generación de código. “` load(“@rules_proto//proto:defs.bzl”, “proto_library”) load(“@rules_proto_grpc//python:python_proto_library.bzl”, PY_PROTO_DEPS = “PROTO_DEPS”) load(“@rules_python//python:defs.bzl”, “py_library”) gazelle: ignore gazelle: proto disable_global proto_library( name . . . Read more
Escenario Para un proyecto de mosaico de mapas (piensa en Google Earth) tengo un archivo .mbtile del que no sé nada excepto que contiene mucha información sobre ciudades del planeta. He estado investigando durante un par de días y he descubierto lo siguiente: – el archivo es una base de . . . Read more
Tengo una List en mi servidor y quiero enviarla a mis clientes utilizando gRPC. MyClass se ve así: public class MyClass { public long Value { get; set; } public DateTime Time { get; set; } public string Name { get; set; } } ¿Cómo defino esta lista en protobuf . . . Read more
Me decepcionó saber que Protobuf no puede deserializar y asignar un mensaje al tipo del que fue serializado: https://stackoverflow.com/questions/32639905/protobuf-determining-message-type-to-deserialize?rq=1 Por ejemplo, al enviar mensajes a través de una única conexión de socket, es posible que queramos enrutar el mensaje según su tipo. ¿Existen esquemas de serialización que puedan hacer esto?