31
4
I am doing poc with provectus kafka-ui, an open source GUI tool for kafka.
我正在用Provetus Kafka-UI做POC，这是一个用于Kafka的开源图形用户界面工具。
For normal string value, my setup is running fine. However I am not able to use it with CloudEvent. I see encoded garbled characters.
对于正常的字符串值，我的设置运行良好。但是，我不能将其与CloudEvent一起使用。我看到了编码的乱码字符。
I tried adding proto file for CloudEvent and using protobufFile as serde, but it is not working.
我尝试为CloudEvent添加proto文件，并使用协议bufFile作为serde，但不起作用。
Here is my docker-compose
这是我的被告牌-作文
个人中心
文章发布
退出 kafka:
image: confluentinc/cp-kafka:6.0.2
container_name: kafka
restart: always
depends_on:
- zookeeper
ports:
- "9092:9092"
- "29092:29092"
extra_hosts:
- "host.docker.internal:host-gateway"
environment:
KAFKA_BROKER_ID: 1
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092
KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
kafka-ui:
container_name: kafka-ui
image: provectuslabs/kafka-ui:latest
ports:
- "8080:8080"
depends_on:
- zookeeper
- kafka
environment:
KAFKA_CLUSTERS_0_NAME: local
KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: kafka:29092
KAFKA_CLUSTERS_0_ZOOKEEPER: zookeeper:2181
KAFKA_CLUSTERS_0_JMXPORT: 9997
kafka.clusters.0.serde.0.name: ProtobufFile
kafka.clusters.0.serde.0.className: com.provectus.kafka.ui.serdes.builtin.ProtobufRawSerde
kafka.clusters.0.serde.0.properties.protobufFilesDir: /protofiles/
kafka.clusters.0.serde.0.properties.protobufMessageName: io.cloudevents.v1.CloudEvent # default type for values
kafka.clusters.0.serde.0.properties.protobufMessageNameByTopic.ais-fused: io.cloudevents.v1.CloudEvent
volumes:
- "./proto/:/protofiles"
github.com/provectus/kafka-ui/blob/master/documentation/compose/…
Github.com/provectus/kafka-ui/blob/master/documentation/compose/…
31
4
0
我在大学学习C++时学习了这段代码..后来我在C#中使用了同样的东西...但现在我想在Java中使用它...我在互联网上寻找类似的东西，但我什至不知道如何表达它，以便我得到正确的结果。 所以嗯，请让我
我正在我的 Ruby on Rails Controller 上运行 RSPEC 测试，这是我正在测试的 Controller 操作: Controller 代码: class Customers::
想为我选择的选项卡设置自定义背景，到目前为止，子类化是我自定义 UITAbBar/UITabBarItem 的方式。 问题是:有谁知道(或知道我在哪里可以找到)设置背景的属性是什么？ 所选选项卡周围有
您好，我在 commerefacades-beans.xml 中创建了 eProductForm bean，我添加了 ProductData 的自定义属性。 然后在commercewebs
我有两个表:1. 客户2. customer_order 客户表包含客户数据(duh)，customer_order 包含所有订单。我可以在 customer.id=customer_order.id
在我的 TableView 中，我有一个 NSMutableArray *currList 的数据源 - 它包含对象 Agent 的对象。我创建了自定义的 TableCell 并正确设置了所有内容。我
是否建议使用自引用泛型继承？ public abstract class Entity { public Guid Id {get; set;} public int Version
我正在尝试为我的 Grafana 安装使用自定义文件 ( custom.ini )。不幸的是，这不起作用。 我做了什么: 安装了一台装有 CentOS 7 的虚拟机 添加了 Grafana Yum R
我被分配了两个给定类的作业，一个是抽象父类 Lot.java，另一个是测试类 TestLots.java。我不应该编辑其中任何一个。任务是创建Lot的两个子类，使TestLots中的错误不再是错误。
我是 Botpress 的新手。 我刚刚安装了 Botpress 的最新版本“botpress-ce-v11_0_1-win-x64”。 我浏览了文档，发现了一些关于内容类型、内容元素和内容渲染的解释
我一直在四处寻找，但我还没有找到任何东西，除了 Qt3 的旧文档和 qt 设计器的 3.x 版。 我会举个例子，并不是因为我的项目是 GPL 而不能提供代码，而是为了简单起见。 示例:您正在为您的应用
场景 我有一个自定义规则来验证订单的运费: public class OrderValidator : BaseValidator { private string CustomInfo {
我有用于身份验证的自定义拦截器: @Named("authInterceptor") @Provides @Singleton fun providesAuthIntercep
如果有人没有添加照片，我想显示默认头像图像。我假设我需要在模型或助手中执行自定义 getter。 如果我做 getter，它会看起来像这样吗: def avatar_url "default_ur
我正在使用 Google Search API，但遇到了一些麻烦。这个请求(在 Python 中，使用 requests 库)工作正常 res = requests.get("https://www.
我使用 MSKLC 制作了自定义键盘布局。 我以为我仔细按照说明操作了chose appropriate values对于LOCALENAME和 LOCALID参数。 但是，在通过按 Win+Spac
我正在使用 simpleframework解析 XML 字符串并将其转换为对象。 Serializer serializer = new Persister(); try { Customer
我正在使用 C# 控制台应用程序从 MySql 数据库获取一些数据，但在正确查询时遇到一些问题 现在的情况: SELECT * FROM Customer WHERE EXISTS ( SELECT
我在我的 iPhone 4S 上运行我的应用程序，我正在使用自定义表格 View Controller 和自定义表格 View 单元格，当我将表格 View 向上滑动到空白区域并同样向下滑动到空白区域
我有一个自定义的 JavaScript 变量，它正在检查 eventAction 是什么，这样我就可以知道是否触发一些转换像素。自定义 Javascript 称为“FacebookConversion
我是一名优秀的程序员,十分优秀！