如何在KSQLDB查询的行中使用protobuf反序列化？
在KSQLDB中使用protobuf反序列化查询行的过程如下：
- 首先，确保你已经在KSQLDB中创建了一个包含protobuf数据的流或表。
- 在查询中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。 - 使用
INSERT INTO语句将查询结果插入到新创建的流或表中。 - 在新创建的流或表中，使用
CREATE STREAM或CREATE TABLE语句定义一个包含protobuf数据的流或表，并指定protobuf消息的结构。 - 在查询中，使用
SELECT语句选择包含protobuf数据的列，并使用AS关键字为该列指定一个别名。 - 使用
CREATE STREAM或CREATE TABLE语句创建一个新的流或表，将protobuf数据列的别名指定为ROWKEY和ROWVALUE。
请注意，以上步骤仅为示例，具体的查询过程可能因实际需求和数据结构而有所不同。在实际应用中，你需要根据自己的情况进行相应的调整和修改。
相关·内容
1回答
我有主题post_users_t，当我在它上面使用PRINT命令时，我得到 rowtime: 4/2/20 2:03:48 PM UTC, key: <null>, value: {"userid": 6, "id": 8, "title": "testest", "body": "Testingmoreand more"}
rowtime: 4/2/20 2:03:48 PM UTC, key: <null>, value: {"userid": 7, &
浏览 13提问于2020-04-02得票数 0
回答已采纳
很抱歉，如果这在文档中很清楚，但我没有找到它。我目前正在学习本教程，并根据我的需要对其进行调整，我面临着一些问题，我想知道这是否适合我。 我想要做的和想象一下我现在的情况非常非常相似。，https://medium.com/@tomershaiman/tutorial-building-a-s3-parquet-datalake-without-a-single-line-of-code-5ea4455edc1e。 TL/DR:我在Kafka中有一个Protobuf格式的主题中的数据，我想创建一个流，将protobuf转换为Avro格式的新主题，一旦它转换为avro格式，我将有一个连接器来使
浏览 22提问于2020-09-19得票数 0
1回答
我正在使用一个Kafka部署，它是，而不是使用任何的。
所有主题中的事件都是Avro。我可以访问模式，它只是没有存储在Schema Registry中。
现在，ksqlDB文档 --您必须有一个架构注册中心--才能处理Avro事件：
具有架构注册表的堆栈可以在ksqlDB应用程序中使用Avro和Protobuf编码的事件。没有模式注册表，ksqlDB应用程序只能使用JSON或分隔格式。
我正在寻找解决这个问题的方法，以便能够在这些Avro事件主题上定义ksqlDB流和表。我没有什么想法，我想知道它们是否有效，或者是否有其他的解决办法。
使用Kafka (consumer+produc
浏览 0提问于2020-05-05得票数 0
回答已采纳
我偶然发现protobuf 对它的用法非常困惑。我们能用protobuf代替ctype/swig/cython吗？我的要求是必须围绕现有的用户空间C库编写一个python包装器。
浏览 3提问于2015-12-25得票数 2
回答已采纳
2回答
我的问题是在C++中序列化protobuf数据，并在Java中反序列化数据。下面是我使用的dcn给出的提示代码：
这样，我就在C++中创建了protobuf数据，并将其写入通过套接字发送的ostream。
Name name;
name.set_name("platzhirsch");
boost::asio::streambuf b;
std::ostream os(&b);
ZeroCopyOutputStream *raw_output = new OstreamOutputStream(&os);
CodedOutputStream *coded_o
浏览 2提问于2011-04-14得票数 3
回答已采纳
我正在尝试生成一个报告，它基本上应该包含窗口化的KSQL的行。我想根据搜索请求和点击的产品进行分组，以接收每对的计数。
最后，我希望通过拉查询输出下表中给定窗口的所有条目：
CREATE TABLE REPORT AS
SELECT QUERY_STRING, PRODUCT_ID, count(*) AS COUNTER
FROM INPUT_STREAM
WINDOW HOPPING (SIZE 7 DAYS, ADVANCE BY 1 DAYS)
GROUP BY QUERY_STRING, PRODUCT_ID;
只接收特定窗口的日志是没有问题的。但是显然，ksqlDB一次只能查询
浏览 2提问于2019-12-10得票数 0
场景: Apache Flink、Kafka、Protocol buffers data consumer。 数据来源为协议缓冲区格式的Kafka主题(多个主题: topic#1、topic#3、topic#3)。使用者是Apache Flink使用者。每个主题都有一个独特的协议定义。 List<String> topicList = Arrays.asList("topic#1,topic#2,topic#3".split(","));
inputStream = env.addSource(new FlinkKafkaConsumer[Prot
浏览 13提问于2021-04-03得票数 0
我使用的是ksqlDB版本5.3.2！当我尝试在ksql CLI中执行此查询时：
CREATE SINK CONNECTOR `hdfs_connector` WITH (
'connector.class'='io.confluent.connect.hdfs3.Hdfs3SinkConnector',
'tasks.max'='1',
'topics'='CUSTOMERS_CITY_2',
'hdfs.url'='hdfs://192.168.2.114:8020/tm
浏览 8提问于2020-01-10得票数 0
回答已采纳
1回答
当我在我创建的流上使用ksqlDB中的DESCRIBE EXTENDED时，我得到了以下结果： Local runtime statistics:
consumer-messages-per-sec: 0 | consumer-total-bytes: 101768 |
consumer-total-messages: 98 | last-message: 2021-08-18T15:27:28.978Z
| consumer-failed-messages: 1 |consumer-failed-messages-per-sec: 0 |
last-failed: 2021-0
浏览 46提问于2021-08-18得票数 0
1回答
KSQLDB创建带句点的流/主题
、、、、
我希望将流/表连接在一起，但是在KSQLDB中的create stream join语句上可以做到这一点。 CREATE STREAM test_name ...... Works CREATE STREAM test.name ......不支持WOrk 我收到了一个与在名称中使用句点相关的错误。我想为我的卡夫卡主题创建一个流，其中有一个句号。 有什么想法吗？
浏览 20提问于2021-07-03得票数 0
回答已采纳
我有Kafka Streams java应用程序启动和运行。我试图使用KSQL来创建简单的查询，并使用Kafka Stream来解决复杂的问题。我想同时运行KSQL和Kafka Streams作为Java应用程序。 我正打算通过https://github.com/confluentinc/ksql/blob/master/ksqldb-examples/src/main/java/io/confluent/ksql/embedded/EmbeddedKsql.java。有没有关于EmbeddedKsql的文档？或者任何可以工作的原型？
浏览 20提问于2020-06-23得票数 0
回答已采纳
在我的消费者中，我想反序列化Kafka协议消息。键是字符串类型，但消息值是一个protobuf对象。我知道我必须为消息值创建自己的自定义反序列化程序，但不知道如何创建一个。下面是我的消费者实现，我需要替换标记的行：
using Confluent.Kafka;
using System;
using System.Threading;
namespace EventHubsForKafkaSample
{
class Worker1
{
public static void Consumer(string brokerList, string connStr,
浏览 44提问于2021-09-07得票数 1
我正在使用Kafka Connect和Google PubSub Connector将消息从gcp PubSub写入到Kafka主题中。 我的连接器具有以下配置： {
"name": "MyTopicSourceConnector",
"config": {
"connector.class": "com.google.pubsub.kafka.source.CloudPubSubSourceConnector",
"tasks.max": "
浏览 14提问于2020-10-16得票数 0
我正在考虑将当前基于WCF的应用程序迁移到protobuf-net.Grpc。这似乎是可行的，但是，如果不包含具有ProtoInclude属性的所有派生类，则无法使(DTO类)基类的protobuf序列化属性。
简化的类层次结构：
[DataContract]
public abstract class DtoBase
{
[DataMember(Order = 1)]
public int Id { get;set; }
[DataMember(Order = 2)]
public int Version { get;set; }
[DataMemb
浏览 0提问于2019-08-03得票数 3
回答已采纳
如何在Swift中将protobuf (在我的例子中，我将它们用于gRPC)序列化为字节数组？
浏览 1提问于2016-06-23得票数 0
回答已采纳
我正在编写一个应用程序，用于计算和验证protobuf结构中的签名。它的计算方式类似于sign(protobuf_message.SerializeAsString())。
我能否确定，相同的protobuf_message将以相同的方式序列化(使用不同版本的库(但只使用proto2编码)，在不同的计算机上，在不同的条件下)，反之亦然？
浏览 1提问于2015-04-13得票数 2
回答已采纳
2回答
我想了解如何在进程之间或网络之间传输C++类的内容。
我正在阅读Google Protobuf教程：
似乎您必须创建一个抽象的、非C++接口来表示您的类：
syntax = "proto2";
package tutorial;
message Person {
optional string name = 1;
optional int32 id = 2;
optional string email = 3;
enum PhoneType {
MOBILE = 0;
HOME = 1;
WORK = 2;
}
}
但是，我更
浏览 4提问于2021-04-29得票数 1
回答已采纳
4回答
C#
每次我运行我的色情图我都会得到这样的例外：
但是，当我在调试模式下运行时，没有异常，程序运行良好，我能做什么呢？
注意:我在项目中的任何地方都不使用()
编辑：好的，下面是详细信息中的代码:如果有人知道如何使用protoBuff，并且知道这个问题.
************** Exception Text **************
System.Reflection.TargetInvocationException: Exception has been thrown by the target of an invocation. ---> ProtoBuf.
浏览 11提问于2010-10-01得票数 18
我有以下消息结构： syntax = "proto3";
package com.test;
option java_multiple_files = true;
message Event1 {
string event1 = 1;
}
message Event2 {
string event2 = 1;
}
message Events {
oneof oneof_type {
Event1 event1 = 1;
Event2 event2 = 2;
}
} 我创建了以下流： CREATE STREAM TEST_STREAM
浏览 13提问于2021-07-21得票数 0
我是ksqldb的新手，我正在寻找一个用于ksqldb的版本控制工具，就像java中的RDMBS的flyway迁移一样。
我阅读了下面的页面，了解了升级查询的方法，但我想更系统地控制流和表的版本。
也许到目前为止还没有满足这种需求的工具，我只需要自己开发？或者有没有正在进行的项目？
浏览 0提问于2021-01-08得票数 2
我运行这个查询
select * from USER_EVENTS emit changes limit 1;
USER_EVENTS是一条流。在此之前，我将auto.offset.reset设置为earliest。此查询运行缓慢。我也不知道原因。然后进行查询，检查以上查询的用户id，并在kafka connect中进行搜索。我发现查询需要获取主题中的所有消息，尽管我只需要一行。是真的吗?为什么要把所有的东西都取出来呢？我认为获取一个就足够了，因为我必须添加limit 1来查询。USER_EVENTS背后的主题有~1M消息。我使用的是ksqlServer 6.1.0，ksqlCli也是如此。
浏览 4提问于2022-10-25得票数 0
回答已采纳
1回答
我不知道什么时候使用加载.proto文件(反射)的方法更好，什么时候用pbjs脚本/工具生成静态代码更好。
反射法：
protobuf.load("awesome.proto", function(err, root) {
...
});
方法使用静态代码：
protobuf.load("bundle.json", function(err, root) {
...
});
根据，这两种方法的性能是相同的。
有人能向我解释一下哪种方法是为了什么目的吗？
我在网上搜索了很多，但没有得到这个问题的答案。我不是从编码的角度来看，而不是找出哪种方法更适合。
浏览 2提问于2017-05-31得票数 0
回答已采纳
1回答
我不习惯使用Protobuf-net进行一些序列化，并获得以下代码片段的折叠错误：
错误：
动态类型不是契约类型: TestType[]
片段：
using System.IO;
namespace QuickStart
{
class Program
{
static void Main()
{
//FileAccess.ShowFileAccess();
//Sockets.ShowSockets();
var dto = new DataTransferTyp
浏览 2提问于2013-07-15得票数 5
回答已采纳
1回答
在KSQL中:我想用模式(JSON/AVRO)提取底层有效负载，并将其添加到一个不同的KSQL流中。
示例：
投入：
Stream1 = '{"name":"Ben", "age":30}'
产出：
Stream2 = '{"EventTime":"2021-10-01:00:00:00", "Schema": "JSON", "EventPayLoad": "{"name":"Ben", "ag
浏览 4提问于2021-06-25得票数 0
我有一个卡夫卡主题，其中包含不同类型的信息，即不同类型的结构。json类的消息。需要评估每条消息/记录的模式。
我想知道我们如何在这里利用protobuf使事情变得更容易。我应该在哪里插入protobuf。
另外，protobuf封装的消息意味着它始终是模式安全的？
浏览 1提问于2020-04-14得票数 0
如何将protobuf-net对象转换为xml？我有一个非常大的对象，它包含在protobuf-net格式的文件中。我想以xml格式可视化这个对象的所有字段和子字段。该怎么做呢？
浏览 4提问于2014-06-18得票数 1
这似乎是一个相当简单的用例，我不明白下面代码片段中的异常是如何抛出的。
static void Main(string[] args)
{
using (var foobar = new MemoryStream())
{
ProtoBuf.Serializer.Serialize(foobar, new Foobar());
if (foobar.Length == 0)
throw new Exception("Didn't serialize");
}
}
[ProtoContrac
浏览 2提问于2013-01-31得票数 2
回答已采纳
我一直在摆弄ksqlDB，它真的很整洁。将数据输入Kafka，创建流甚至表，效果很好。现在，我想将可视化层/ BI工具连接到表中的数据，以创建仪表板或交互式BI报告(例如，Superset、Redash等)。
是否有一种方法可以将JDBC客户端直接连接到ksqlDB / Kafka流，以便它可以查询ksqlDB中的表？说我应该使用REST将应用程序与结果连接起来，但是：
REST是专有的，所以我如何在不编写自定义连接器的情况下将类似BI工具的东西连接到它？
如果我在生产/无头模式下运行ksqlDB，那么REST无论如何都不可用。(为什么？)
任何指示都将不胜感激。
浏览 5提问于2020-03-08得票数 0
回答已采纳
下面是我用来创建一个从数据库/memcached获取数据的GRPC系统的proto文件。
message CMSContent
{
repeated ArticleSummary Articles = 1;
uint32 RecordCount = 2;
}
service Article
{
rpc ListByCategory(ArticleByCatURI) returns (CMSContent){}
}
message ArticleByCatURI
{
uint32 ApplicationId = 1;
}
message Ar
浏览 1提问于2016-02-15得票数 2
回答已采纳
我有一个流程，从IBM大型机IIDR，我发送记录到Kafka主题。卡夫卡主题信息的value_format是AVRO，密钥也是AVRO格式的。这些记录被推入卡夫卡的话题。我有一个与这个主题相关的流。但是这些记录并没有被传递到溪流中。test_iidr主题的示例-
rowtime: 5/30/20 7:06:34 PM UTC, key: {"col1": "A", "col2": 1}, value: {"col1": "A", "col2": 11, "col3": 2, "
浏览 2提问于2020-05-30得票数 0
回答已采纳
我有数百万个对象，我需要将它们保存到缓存中。为了减少这些对象的大小和序列化/反序列化的时间，我使用protobuf对象而不是POJO，然后将它们作为字节数组保存到Ehcache中。但是Ehcache会将protobuf字节数组放入Ehcache的对象中，然后将对象序列化到内存中，因此使用protobuf的优势已经消失。
我可以直接将protobuf对象的字节表示保存到Ehcache中吗？
浏览 9提问于2012-11-19得票数 1
我正在尝试将列表中的点数据保存到protobuf.net创建的二进制文件中。虽然我在这方面本身没有问题，但我也在尝试将数据保存为一种在文本编辑器中不易查看的格式。默认情况下，当您将Point结构列表保存到文本文件中时，每个点的x和y都显示为ascii文本。
[global::ProtoBuf.ProtoMember(1, IsRequired = false, Name = @"BufPoints", DataFormat = global::ProtoBuf.DataFormat.Default)]
private List<Point> BufP
浏览 0提问于2012-11-08得票数 4
回答已采纳
1回答
试着把我的注意力集中在google protobuf上。我在C#中找到了一些protobuf的实现，但它们似乎缺少一个特性:能够从带有属性修饰的现有C#类自动生成.proto文件。
我之所以想这样做，而不是从.proto文件中自动生成的.proto类，是因为我已经在我的项目中定义了C#类，我不想仅仅为了满足ProtoBuf而重复它们。
有没有人遇到过这样的情况？
更新
这是否可以仅仅修饰C#类而不使用.proto文件来使用protobuf？
浏览 3提问于2009-08-26得票数 42
回答已采纳
2回答
我正在尝试更改现有net.tcp项目中的序列化程序，该项目使用客户端和服务器上的共享实体。我很难弄清楚protobuf-net(V2480)图表说我可以序列化私有成员，但是找不到文档来做这件事，没有属性是可能的吗？如所述，如何启用图形模式(作为参考
这会解决protobuf触发我的changed items标志的问题吗？例如，我有一个类
public enum FirstEnum
{
First = 0,
Second,
Third
}
public enum AnotherEnum
{
AE1 = 0,
AE2,
AE3
}
[Seria
浏览 0提问于2012-04-07得票数 3
回答已采纳
2回答
如何在windows环境下启动ksql？ 我们已经使用zip格式安装了confluent kafka。我们没有在confluent-home/bin/windows目录中找到ksql-server-start.bat文件，但是我们在confluent-home/bin/目录下观察到一个同名文件，该文件不是批处理文件。
浏览 52提问于2019-01-30得票数 2
回答已采纳
正如标题所述，我想尝试Google缓冲区，但是在编译.proto文件中的类时遇到了困难。我不确定生成的类应该是什么样子，它包含2500行是否正常。
这是maven项目，我包含了以下依赖项：
<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java</artifactId>
<version>2.6.1</version>
</dependency
浏览 1提问于2015-08-11得票数 1
回答已采纳
有一个使用protobuf序列化一些值的客户端。这个客户端是用python编写的。我使用socket将序列化结果发送到java代码：
serializedRow = t_event.SerializeToString()
sock.send(serializedRow)
在java代码中，消息是以字符串的形式接收的，但是在"ParseFrom“函数的步骤中，有一些不明确的错误。由于ParseFrom的参数是Bytes，因此在传递字符串之前，会将其转换为Bytes。
byte[] bytes = row.getBytes();
TaxiEvent taxiEvent1 = TaxiEve
浏览 11提问于2018-01-27得票数 2
1回答
我正在尝试将数据从.csv文件导入到一个表中，但是mysql很难找到它。当我只是将它放在我的C盘中，而不是文件夹中时，它发现它没有问题。当我把我想要的文件放在一个文件夹中，然后把文件路径放在我的查询中，它不起作用。
我使用的查询是：
将数据本地infile '/C:\file_path‘加载到表table_name字段中，字段以'，’结束，'"‘行结束，\n’忽略2行；
我也尝试过删除'local‘，但是没有效果。
谢谢!
浏览 0提问于2012-12-28得票数 0
回答已采纳
1回答
是否可以将具有属性的聚合类型反序列化为作为引用的抽象基类型，请参阅Aggregate.Base？如果没有，什么是最好的解决办法？
[ProtoContract]
[ProtoInclude(1, typeof(Derived))]
public abstract class Base { }
[ProtoContract]
public class Derived : Base
{
[ProtoMember(1)]
public int SomeProperty { get; set; }
}
[ProtoContract]
public class Aggregate
{
浏览 1提问于2012-07-25得票数 2
回答已采纳
1回答
单用户应用程序文件/数据存储建议
、、、、
我目前有一个C# winform应用程序，您可以在其中输入最终是关系型的数据。存储的数据量并不大。原始版本使用SQL存储信息。然而，我发现它很慢。另外，我希望能够使用自己的扩展名保存应用程序文件。
我已经改变了我的方法，基本上是使用类对象在内存中加载数据。为了保存，我只需使用ProtoBuf序列化所有内容，并在打开文件时反序列化。这种方法非常快速，在用户单击“保存”之前，更改将不会持久保存。但是，我发现查询分层数据有点麻烦。我使用Linq到对象查询数据.我会让ClassA有一个GUID密钥。我可以通过GUID在ClassA中引用ClassB。然而，我并不能真正地完成一个简单的SQL类型查询来获
浏览 3提问于2015-04-07得票数 0
回答已采纳
我需要将一个包含256 an到18 an数据的对象从android设备发送到WCF服务。我刚刚发现了protobuf.net，并同意这是可行的方法。我发现在android上显示使用protobuf的大多数示例都是为了进行如下查询：
www.webservice.com/API/MaxItems=10。我需要的是一种将整个BLOB发送到webservice的方法，而不仅仅是参数。有人能为我指出使用Android2.3.3和WCF.Net编写代码的正确方向吗？
我的设想如下：
Webservice正在使用.Net和Silverlight为客户提供服务，同时也为安卓平台上的客户提供服务。Webs
浏览 2提问于2012-04-20得票数 1
我使用protobuf-net进行序列化和反序列化。
我所遵循的方法是创建一个RuntimeTypeModel，并添加需要序列化或支持序列化的所有类型。在添加所有类型之后，我使用TypeModel.Compile()来获得性能优势。
当一个类实例被序列化并作为blob保存到数据库中时，我就能够在从数据库获取时反序列化它。但是，当我更改机器并尝试反序列化时，我得到的是ArgumentException类型的token
at ProtoBuf.ProtoReader.EndSubItem(SubItemToken token, ProtoReader reader) in c:\Dev\pr
浏览 8提问于2013-12-28得票数 2
我们的系统在使用protobuf序列化一条消息时，有时(但不是每次)都会引发下面暴露的错误。错误的原因是什么，我如何减轻错误？
请注意，我们已经在使用DeserializeWithLengthPrefix了。
更新:相关代码在这里
private const PrefixStyle PrefixStyleInPlace = PrefixStyle.Fixed32;
public static byte[] SerializeObjectToByteArray<TSerializable>(TSerializable source) where TSerializable : cla
浏览 6提问于2013-01-14得票数 31
回答已采纳
在下面的代码中，我希望在c#中使用预定义的protobuf消息。我发现我能够编写并使用该方法来获取已创建的方法并生成一个byte[]。
ContainerMessage containerMessage = new ContainerMessage();
containerMessage.Type = CommandType.Connect;
containerMessage.Connect = new Connect();
containerMessage.Connect.ClientName = "TemporaryClientName";
byte[] str
浏览 4提问于2018-02-01得票数 5
回答已采纳
1回答
我想丢弃多个流，drop适用于单流only.This ksql查询：
DROP STREAMS stream1, streams2;
不起作用。实现这一目标的另一种方法是什么？
浏览 16提问于2019-07-29得票数 0
这是今天在分析应用程序的时候出现的。我四处看了看，还没找到什么。虽然下面的问题与我的问题无关，但它确实有一个很好的调用堆栈。
在这些行中，正是我们堆栈中弹出的那一行，并且具有相当高的成本：
at ProtoBuf.ProtoReader.ReadTypedObject (object,int,ProtoBuf.ProtoReader,System.Type) <0x00056>
这是否意味着所有的值类型，特别是结构，总是被装箱？
浏览 2提问于2014-02-25得票数 2
例如，在KSQL中使用EXTRACTJSONFIELD时，名称中的空格出现了问题：
SELECT EXTRACTJSONFIELD(payload, '$.Successful Login') FROM MYSTREAM;
--它总是返回NULL
我应该如何处理键名中的空格？
我试过：
EXTRACTJSONFIELD(payload, '$.Successful%Login')
EXTRACTJSONFIELD(payload, '$.Successful%20Login')
EXTRACTJSONFIELD(payload, '$.[
浏览 0提问于2018-06-11得票数 2
回答已采纳
我在解析包含数组格式的protobuf数据的二进制文件时遇到了问题。
当我使用python API时，ParseFromString输出始终为零或无。
二进制文件中的序列化protobuf数据是使用C++接口SerializeToArray生成的。但是为了解析bin文件，我想使用python进行解析。但在python中，我找不到任何API来将序列化的protobuf数据解析为二进制文件中的数组。
有没有什么python API可以解决这个问题？有没有人能给出一个解决方案？
浏览 4提问于2018-05-08得票数 3
我试图向子进程发送一个protobuf消息。反序列化在父级中运行良好，如下所示：
var deserialized = Serializer.Deserialize(typeof(ChildProcessTestMessage), new MemoryStream(new byte[] { 8, 1 }));
[ProtoContract]
public class ChildProcessTestMessage
{
[ProtoMember(1)]
public int Int { get; set; }
}
我在这个示例代码和子进程中硬编码了字节0x0801，以确保字节是
浏览 2提问于2021-12-27得票数 1
我使用Jedis作为java客户端来连接到Redis服务器。我还使用协议缓冲区将数据写入jedis或redis缓存。但是我没有找到如何编写或者将protobuf对象设置为redis的方法。是我遗漏了什么，还是Jedis没有提供将protobuf对象存储为值的方法？
浏览 0提问于2015-10-16得票数 7
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
