Apache pulsar -函数执行不会影响输出
Apache Pulsar是一个开源的分布式消息和流处理平台，由Apache软件基金会开发和维护。它具有高可扩展性、高性能和可靠性，适用于处理大规模数据流和事件流。
函数执行不会影响输出是指在Apache Pulsar中，函数计算的执行不会对输出产生影响。具体来说，当使用Pulsar Functions时，函数可以从输入流中读取数据，对数据进行处理，并将结果写入输出流中，而不会对输出流中的数据产生任何影响。
这种设计有以下几个优势和应用场景：
- 高可靠性：Apache Pulsar通过使用持久化存储来保证消息的可靠性，即使函数执行失败或发生故障，消息也不会丢失。
- 弹性扩展：Pulsar Functions可以根据负载情况自动进行水平扩展，以处理大量的数据流和事件流。这使得它非常适合处理高并发的实时数据处理任务。
- 灵活性：Pulsar Functions支持多种编程语言，包括Java、Python和Go，开发人员可以根据自己的喜好和需求选择合适的语言进行函数开发。
- 实时处理：由于Pulsar Functions是在流处理平台上运行的，它可以实时处理数据流和事件流，使得实时分析和实时决策成为可能。
推荐的腾讯云相关产品是腾讯云消息队列 CMQ，它是腾讯云提供的一种高可靠、高可用的消息队列服务，可以与Apache Pulsar结合使用，实现可靠的消息传递和处理。您可以通过访问腾讯云消息队列 CMQ的官方网站（https://cloud.tencent.com/product/cmq）了解更多信息和产品介绍。
相关·内容
我正在尝试使用Apache Pulsar的重复数据删除功能。 standalone.conf文件中设置了brokerDeduplicationEnabled=true，但是当我从生产者多次发送相同的消息时，我在消费者端得到了所有的消息，这是预期的行为吗？ 重复数据删除不就是AWS SQS中的content based deduplication吗？ 下面是我的生产者代码以供参考。 import pulsar
import json
client = pulsar.Client('pulsar://localhost:6650')
producer = cli
浏览 73提问于2021-08-18得票数 1
回答已采纳
在我的k8s集群上，在我的M1 Mac上的桌面上，登录到时遇到了问题。
当我尝试登录时，我无法使用默认的脉冲星管理凭据通过登录页面，当我检查该页面时会看到以下内容：
Failed to load resource: the server responded with a status of 404 (Not Found)
我认为这个问题与我无法通过端口7750连接后台服务有关，但老实说，我不知道如何解决这个问题。我使用helm图表进行部署，并使用minikube.yaml文件值来保持副本计数等，因为它运行在单一的destop节点上。
是否有人在此之前遇到过这个问题，或知道一个解决方案？如果这个
浏览 29提问于2022-01-27得票数 0
为了进行测试，我设法运行了一个嵌入式独立pulsar服务器和客户端。我还可以发送和接收消息。然而，我实际上想(集成-)测试功能(实现org.apache.pulsar.functions.api.Function)。如何在嵌入式设置中注册函数？ package kic.data.stream.pulsar
import groovy.util.logging.Log
import org.apache.pulsar.PulsarStandalone
import org.apache.pulsar.PulsarStandaloneBuilder
import org.apache.puls
浏览 26提问于2019-06-09得票数 1
回答已采纳
我正在尝试为Pulsar设置Zookeeper集群。我正在按照here的说明进行操作，但是我总是失败。 在我的设置中，我有两个节点，它们应该是集群的一部分。由于我需要将bookie部署到相同的节点，因此我执行了 $ PULSAR_EXTRA_OPTS="-Dstats_server_port=8001" bin/pulsar-daemon start zookeeper 启动zookeeper。之后，我尝试使用以下命令初始化集群： bin/pulsar initialize-cluster-metadata \
--cluster pulsar-cluster-1 \
浏览 123提问于2019-09-02得票数 0
我不能得到一个简单的hello-world类型的Spring Boot应用程序来利用Pulsar Log4j2附加器。在启动时，它会报告错误：
2021-05-14T15:34:23.549-05:00 pulsar-client-io-6-1错误pulsar -client-io-6-1错误o.a.p.c.i.ProducerImpl applog-json无法创建生产者:名为'pulsar-log4j2-appender-applog-json‘的Producer已连接到主题2021-05-14 15:34:23,550主错误无法启动pulsar管理器pulsar manager
浏览 3提问于2021-05-15得票数 1
我正在尝试运行一个脉冲星DebeziumPostgresSource连接器。
这是我正在运行的命令：
bin/pulsar-admin \
--admin-url https://localhost:8443 \
--auth-plugin org.apache.pulsar.client.impl.auth.AuthenticationToken \
--auth-params file:///pulsar/tokens/broker/token \
--tls-allow-insecure \
source localrun \
--broker-service
浏览 24提问于2020-11-05得票数 2
回答已采纳
我在Go代码中引用了一个包为：
github.com/apache/pulsar/pulsar-function-go/pf
但是，在构建用于设置集成测试的坞映像时，我需要包括对该库的一些本地更改。
在我的Dockerfile中，我设置了GOPATH和GOROOT，路径如下：
ENV GOROOT /usr/local/go
ENV GOPATH /go
ENV PATH /go/bin:$PATH
然后，在Dockerfile中，我将源代码复制到Docker映像中，并尝试安装Go模块，如下所示：
COPY target/pulsar-function-go/ /pulsar/dependen
浏览 4提问于2020-01-23得票数 0
我可以使用以下docker命令运行Apache Pulsar： docker run -it \
-p 6650:6650 \
-p 8080:8080 \
--mount source=pulsardata,target=/pulsar/data \
--mount source=pulsarconf,target=/pulsar/conf \
apachepulsar/pulsar:2.6.0 \
bin/pulsar standalone 我正在尝试将其转换为docker-compose，并使用下面的docker-compose.yml文件。当我运行该命令时：
浏览 210提问于2020-10-10得票数 0
Flink数据管道从Apache分区主题中读取。我已经将PulsarSource订阅设置为SubscriptionType.Exclusive。当它被更改为SubscriptionType.Shared时，它期望为命名空间启用事务策略。然后在代理中启用事务管理器并启动它。但还是得到了这个例外
Caused by: java.io.IOException: org.apache.flink.util.FlinkRuntimeException: java.util.concurrent.ExecutionException: org.apache.pulsar.client.api.transa
浏览 16提问于2022-05-28得票数 0
我们在我们的Pulsar星团中观察到了以下警告。我们应该关心它吗？
18:37:37.165 [pulsar-modular-load-manager-29-1]
WARN org.apache.pulsar.brok er.loadbalance.BundleSplitStrategy -
Could not split namespace bundle pulsareval/0x56000000_0x56800000
because namespace pulsareval has too many bundles: 512
浏览 0提问于2019-08-01得票数 1
我正在使用Apache Pulsar，并试图部署一个Pulsar函数，但我得到了这个错误： org.apache.pulsar.broker.web.RestException: Policies not found for myTenant/myNamespace namespace 我已经检查了函数中的代码，一切看起来都很正常。我使用的是Pulsar 2.6.0，但我尝试了其他版本，并获得了相同的结果。 是什么导致了这个问题？我该如何解决它？
浏览 152提问于2021-04-13得票数 1
我正在尝试用java编写一个脉冲星客户端，但是我在记录器(Slf4j)中出现了一个错误。我认为这是因为我的PropertyConfigurator制作不好，但是即使我使用defaultConfigurator，也会得到同样长的错误.当我试图让我的PulsarClient变成这样的时候，它就坏了：
this.client = PulsarClient.builder()
.serviceUrl(config.get("target"))
.authentication(AuthenticationFactory.token(
浏览 18提问于2022-09-24得票数 0
回答已采纳
1回答
我正在尝试将Apache设置为log4j2的一个附录。这里没有太多的文档，但是我在这里找到了一些例子。
我已经建立了一个玩具示例，在这个示例中，生产者正在记录单个消息，并且在Pulsar服务器上订阅了同一个主题并侦听消息。消费者收到了一些东西，但没有收到我所期望的信息：
Message sent: Test message
Message received: 18:05:27.510 [pulsar-client-io-5-1] INFO org.apache.pulsar.client.impl.ConsumerImpl
Message received: 18:05:27.510 [ma
浏览 5提问于2020-06-24得票数 3
回答已采纳
我在Docker容器中以standalone模式运行Apache pulsar。
我正在将日志文件行发布到pulsar主题。总日志大小约60G。
脉冲星容器不断耗尽/磁盘上的磁盘空间，必须终止。
这是默认配置。docker-compose文件如下所示
pulsar:
image: apachepulsar/pulsar
container_name: pulsar
command: bin/pulsar standalone
ports:
- 6650:6650
- 8080:8080
有没有办法限制脉冲星磁盘的使用，这样它就
浏览 3提问于2020-06-18得票数 1
1回答
我目前正致力于在Minikube中安装Pulsar。安装似乎进行得很顺利，但是最后当我尝试获取HTTP代理URL和二进制代理URL时...我收到一条错误消息，指出我没有指定有效的服务： xyz-MBP:pulsar xyz$ kubectl get services -n pulsar | grep pulsar-mini-proxy
pulsar-mini-proxy LoadBalancer 10.107.193.52 <pending> 80:31241/TCP,6650:32025/TCP 8h
xyz-MBP:
浏览 36提问于2021-10-19得票数 0
回答已采纳
我试图通过java执行apache pulsar生产者和消费者程序，我在GCP虚拟机上安装了apache-pulsar standalone，并在独立模式下启动了集群。下一步是我已经在windows eclipse中给出了一个maven build和我在GCP机器上上传的同一个jar文件，当我在windows eclipse中执行生产者和消费者程序时，我得到了连接被拒绝的错误，这是显而易见的，因为pulsar没有安装在windows机器上。但是，当我在GCP实例中尝试同样的事情时，即使集群已经启动，我也得到了错误，这与没有找到类定义错误有关。 pom.xml >>> <
浏览 344提问于2019-02-10得票数 1
1回答
如何确定哪个测试处于挂起状态？
、、、、
我有一个测试挂着..。当我尝试从Maven运行测试时，它总是以ManagedLedgerTest结尾，如下所示：
[INFO] Running org.apache.bookkeeper.client.PulsarMockReadHandle
[INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.028 s - in org.apache.bookkeeper.client.PulsarMockReadHandle
[INFO] Running org.apache.zookeeper.MockZooK
浏览 1提问于2020-02-09得票数 0
场景:我在Rancher Kubernetes中部署了Apache Pulsar v2.6.0，以及jetstack/cert-manager： helm install cert-manager jetstack/cert-manager --namespace cert-manager --set installCRDs=true
helm install --values ./values.yaml pulsar apache/pulsar 我还为所有脉冲星组件配置了TLS，如下所示(values.yaml)： tls:
enabled: true
# common setti
浏览 20提问于2020-09-22得票数 1
回答已采纳
我正在尝试运行新的apache脉冲星Lakehouse Sink Connector，并获得java.lang.IllegalArgumentException。
下面是我的设置。docker-compose.yaml文件：
version: '3.7'
volumes:
mssql-data:
minio-data:
networks:
oentity:
driver: bridge
services:
pulsar:
image: apachepulsar/pulsar:latest
command: bin/pulsar stand
浏览 19提问于2022-09-20得票数 1
回答已采纳
我独立安装了阿帕奇脉冲星。脉冲星有时会超时。它与高吞吐量无关，也与特定主题(遵循日志)无关。Pulsar-admin代理健康检查返回OK或timeout。如何进行调查？ 10:46:46.365 [pulsar-ordered-OrderedExecutor-7-0] WARN org.apache.pulsar.broker.service.BrokerService - Got exception when reading persistence policy for persistent://nnx/agent_ns/action_up-53da8177-b4b9-4b92-8f75
浏览 86提问于2020-03-24得票数 1
我有一个Java客户端客户端正在接收Pulsar (v2.10.0) AVRO消息(雇员)，如下所示：
import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.api.Schema;
impo
浏览 2提问于2022-05-31得票数 2
腾讯云控制台的接入地址协议为http，设置后报错
Invalid scheme 'http'. Expected 'pulsar' or 'pulsar+ssl'
看sdk文档需要pulsar协议 Pulsar Java client | Apache Pulsar
要使用客户端库连接到 Pulsar，您需要指定一个Pulsar 协议URL。
浏览 78提问于2022-12-14
我正在为Apache使用Java用户，而我的应用程序不会启动。
我们核实了以下内容：
脉冲星令牌是正确的。我们可以使用telnet和curl命令命中目标SSL端口(6651)，所以它不是防火墙或网络问题角色在Pulsar 中有足够的权限，我们正在为正确的Pulsar集群命中正确的端点，我们在这个环境中使用正确的信任证书<code>F 211</code>
我们还可以使用此客户端代码从另一个环境中再现该问题：
import org.apache.pulsar.client.api.PulsarClient;
PulsarClient client = PulsarClie
浏览 1提问于2021-07-27得票数 0
我正在尝试实现一个简单的Apache函数，并以LocalRunner模式访问State，但它不起作用。
pom.xml片段
<dependencies>
<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-original</artifactId>
<version>2.9.1</version>
</dependency>
<depend
浏览 8提问于2022-01-07得票数 1
回答已采纳
1回答
在执行下面的代码时，使用java中的apache连接到apache。在束流管道中加入脉冲星客户端时，误差小于误差。
梁版本2.40，2.41 javaSE 1.8
import java.io.*;
import org.apache.beam.sdk.*;
import org.apache.beam.io.pulsar.*;
import org.apache.beam.sdk.options.*;
import org.apache.beam.sdk.transforms.*;
import org.apache.beam.sdk.values.*;
import org.apache.
浏览 10提问于2022-10-03得票数 1
1回答
我在AvroSchema中有一个疑问，我正在创建一个java程序，它有一个生产者是模式的类型，这行生产者= pulsarClient.newProducer(AvroSchema.of(Foo.class)).topic("test_topic").create()；的newProducer方法的第一个参数是模式，在这里，我们正在传递一个AvroSchema的Foo类，但它的错误AvroSchema无法解决。 import java.util.concurrent.TimeUnit;
import org.apache.pulsar.client.api.Consumer;
浏览 26提问于2019-03-13得票数 0
我有一个使用Ignite的复杂项目，并安装了Ignite版本的log4j2。
我还想将安装到log4j2，但是，当我启动应用程序时，我会得到以下错误：
log4j:WARN No appenders could be found for logger (org.apache.pulsar.shade.io.netty.util.internal.logging.InternalLoggerFactory).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.o
浏览 6提问于2020-07-28得票数 1
回答已采纳
在我的Pulsar消费者/生产者中，当我试图连接到Pulsar时，我会收到以下错误消息：
org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException： java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(.)失败:连接被拒绝: puls
浏览 1提问于2020-06-11得票数 0
在Pulsar Python客户端中，有订阅者选项unacked_messages_timeout_ms来设置未确认消息重新发送的时间间隔。 与Pulsar Go客户端相当的是什么？ Python py_consumer = client.subscribe(
topic='my-topic',
subscription_name="py-subscriber",
unacked_messages_timeout_ms=10000,
consumer_type=pulsar.ConsumerType.Shared
) 戈
浏览 43提问于2021-08-31得票数 0
回答已采纳
我正在开发一个使用log4j2的Ignite版本的复杂应用程序。它运行得非常好，但是当我试图添加一个Pulsar 时，它会抛出一个错误：
log4j:WARN No appenders could be found for logger (org.apache.pulsar.shade.io.netty.util.internal.logging.InternalLoggerFactory).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4
浏览 0提问于2020-07-24得票数 0
回答已采纳
1回答
我正在构建一个处理Apache Pulsar的GO应用程序。Go客户端需要C++库，正如Pulsar文档所要求的( Kafka btw也是如此)。 我想把所有这些都打包到一个容器中，尽可能小。我通常使用SCRATCH并从另一个基于golang的容器复制输出。不幸的是，我不能从这个初始容器中获取外部库： FROM golang:latest as builder
ENV GO111MODULE=on \
CGO_ENABLED=0 \
GOOS=linux \
GOARCH=amd64
浏览 16提问于2020-01-18得票数 4
我已经从Run Pulsar locally在Ubuntu18.04.2LTS上安装了apache pulsar standalone v2.3。它不需要任何身份验证就能正常工作。我尝试过使用security-tls-transport和security-tls-authentication配置tls证书。我已经按照链接中提到的修改了以下配置broker.conf，client.conf和standalone.conf。使用命令bin/pulsar standalone运行脉冲星，并使用下面的命令发送消息。 bin/pulsar-client produce my-topic --messa
浏览 162提问于2019-04-03得票数 1
我正在尝试使用pulsar go客户端，使用go模块，但无法使用正确的版本导入。
创建了一个带有脉冲星依赖项的go.mod文件，还添加了其他依赖项，之前我使用的是dep，一切都很好。现在我转到了go模块，除了pulsar dependency，其他的包都很好，我不确定我错过了什么。
module sample
go 1.13
require github.com/apache/pulsar/pulsar-client-go/pulsar v2.4.1
需要github.com/apache/pulsar/pulsar-client-go:版本"v2.4.1“无效:未知版本pul
浏览 0提问于2019-10-28得票数 1
1回答
我是Apache Pulsar的新手，但我正在尝试使用Pulsar-Functions来处理某个主题的现有消息。这些函数似乎仅用于流式传输，因此只有在新消息到达输入主题时才会触发它们。不过，我还是想确认一下。 谢谢!
浏览 12提问于2021-08-06得票数 0
2回答
我目前正在使用Apache Pulsar，它是从本地Minikube集群上的舵图安装的。安装过程很顺利，Apache Pulsar运行得也很好。然而，每当我关闭/重新启动我的笔记本电脑时，我再也不能让所有的pod运行起来。我总是得到CrashLoopBackOff状态。在重启机器时，我尝试使用以下命令重启Pulsar集群(minikube start)：
xyz-MBP:~ xyz$ minikube start
minikube v1.23.2 on Darwin 11.4
Kubernetes 1.22.2 is now available. If you would like t
浏览 43提问于2021-10-21得票数 0
我正试图从脉冲星的话题中吸取经验。下面可以看到我的客户端代码。但是，我面对的是NoClassDefFoundError。请告诉我如何解决这个问题。
脉冲星客户端版本: 2.10，脉冲星服务器版本: 2.10，安装类型:独立(非码头)，操作系统: Ubuntu 20.04.4 LTS
我的脉冲星客户端代码：
private static void consumeFromPulsarAsync() throws Exception {
logger.info("consumeFromPulsarAsync()");
PulsarClient client = P
浏览 3提问于2022-05-10得票数 1
在k8s中使用apache pulsar时，是否可以在一个应用程序中创建多个pulsar客户端并同时连接到pulsar？我知道惯例是使用单个pulsar客户端，但我很好奇是否可以使用多个客户端。这不会导致任何错误吗？
浏览 19提问于2021-03-26得票数 1
2回答
我有一个带有一堆依赖项的maven项目，其中一个我想打印一行到控制台，名为pulsar-log4j2-appender。我尝试在Intellij中打开有问题的.class文件： External Libraries | Maven: org.apache.pulsar:pulsar-log4j2-appender:2.6.0 | pulsar-log4j2-appender-2.6.0.jar | org.apache.pulsar.log4j2.appender | PulsarManager.class 当我尝试添加System.out.println语句时，Intellij显示该文件是
浏览 107提问于2020-07-24得票数 0
回答已采纳
1回答
我有一个使用Debezium的项目，主要基于，然后连接到Apache Pulsar。
我已经更改了一些配置。文件现在看起来如下所示：
database.history=io.debezium.relational.history.MemoryDatabaseHistory
connector.class=io.debezium.connector.mysql.MySqlConnector
offset.storage=org.apache.kafka.connect.storage.FileOffsetBackingStore
offset.storage.file.filename=offs
浏览 141提问于2019-07-22得票数 2
回答已采纳
我使用Apache Pulsar Python客户端来连接我的微服务。我想创建Key_Shared消费者，如下所示：
import pulsar,_pulsar
client = pulsar.Client('pulsar://localhost:6650')
consumer = client.subscribe('my-topic', 'consume-id',
consumer_type=_pulsar.ConsumerType.KeyShared)
但我得到了以下错误：
Attr
浏览 13提问于2020-06-05得票数 1
我配置了broker.conf并尝试创建一个启用了tls的客户机。实际上，我提供了correctly.It在尝试运行客户端时显示的以下错误的证书路径。
2019-09-27 13:30:36.586 INFO ConnectionPool:72 | Created connection for pulsar+ssl://broker.example.com:6651/
2019-09-27 13:30:36.605 ERROR ClientConnection:441 | [<none> -> pulsar+ssl://broker.example.com:6651/]
浏览 5提问于2019-09-27得票数 1
我研究Apache Pulsar已经有一段时间了，我很高兴。但是，我刚开始使用身份验证/授权，并且在Java管理客户机中遇到了一个奇怪的错误。
虽然我可以执行所有类型的操作，如创建/删除租户、创建/删除名称空间、创建/删除分区主题、向租户添加管理员角色等，但尝试使用
org.apache.pulsar.client.admin.Namespaces.grantPermissionOnNamespace()
我得到了这个错误：
org.apache.pulsar.client.admin.PulsarAdminException$ServerSideErrorException: HTTP 50
浏览 1提问于2020-05-20得票数 0
我们团队中有一个新的开发人员，要求她为Docker中的Apache集群构建一个Python客户端概念的简单证明。
让我感到困惑的是，她在哪里没有包括安装python包要求的步骤。通常，我总是有一个Dockerfile，其行如下：
# Install pip requirements
COPY requirements.txt .
RUN python -m pip install -r requirements.txt
不过，她只有一个docker-compose.yml文件，看起来如下：
version: "3"
services:
pulsar:
image:
浏览 7提问于2022-02-10得票数 1
Apache pulsar通过分层存储减载器提供了一个非常有趣的架构。 我想知道如何从另一个应用程序进行交互式查询？我的意思是直接查询键值系统/“数据库”，而不是使用pulsar-sql，后者在底层使用Presto。 在@sijieg中，在twitter上，has posted以下模式： ? 看起来我可以访问State-store (甚至是Segment-reader)并直接访问博彩公司中的数据(根据Metastore ?)我们如何访问这些状态存储/段阅读器并访问数据，就像Flink-Pulsar或Spark-Pulsar一样。
浏览 17提问于2020-04-07得票数 2
我有一个LucidWorksFusion5 kubernetes安装安装在AWS 上，目前该服务之一，连接器经典REST服务，正在经历一次中断。在深入挖掘日志之后，我发现：
ERROR in com.lucidworks.logging.logback.PulsarAppender[PULSAR] - Failed to connect to Pulsar topic persistent://uat/_logs/system_logs at: pulsar://uat-pulsar-broker:6650 org.apache.pulsar.client.api.PulsarClientEx
浏览 9提问于2022-01-07得票数 0
回答已采纳
我正在尝试为Apache Pulsar设置一个异步消费者，但我的问题是只收到一条消息，除非我重新启动Spring Boot应用程序，否则没有其他消息。不幸的是，关于在脉冲星上使用CompletableFuture的文档不是很好，我还是个新手。 我的代码如下： @EventListener(ApplicationReadyEvent.class)
public void subscribe() throws PulsarClientException {
Consumer consumer = this.pulsarClient.newConsumer(JSONSchema.of(Tenan
浏览 111提问于2021-04-20得票数 1
回答已采纳
我得到了一个例外：
org.apache.pulsar.client.api.PulsarClientException$AuthorizationException: Authorization failed example_ingest_producer on topic persistent://myTenant/myNamespace/myTopicName with error Don't have permission to administrate resources on this tenant
当试图从我们的客户端应用程序连接到Pulsar时。我在运行脉冲星2.4.2
浏览 0提问于2020-02-24得票数 2
回答已采纳
4回答
我有一个maven项目()，我想在上面运行代码覆盖率。
我在主项目的pom文件上运行了命令mvn test -Pcoverage jacoco:prepare-agent jacoco:report，但是没有生成报告。相反，我收到一个警告说
[INFO] --- jacoco-maven-plugin:0.7.7.201606060606:report (post-test) @ pulsar-discovery-service ---
[INFO] Skipping JaCoCo execution due to missing execution data file.
[INFO]
[I
浏览 1提问于2017-04-20得票数 3
我能够使用这个docker命令运行Apache：
docker run -it \
-p 6650:6650 \
-p 8080:8080 \
--mount source=pulsardata,target=/pulsar/data \
--mount source=pulsarconf,target=/pulsar/conf \
apachepulsar/pulsar:2.6.0 \
bin/pulsar standalone
我正在尝试将其转换为docker-组合，并使用下面的docker-come.yml文件。当我运行命令时：
docker-compose up
浏览 5提问于2020-06-22得票数 6
回答已采纳
我正在尝试复制struct/SchemaDefinition.下的示例我希望将消息的架构定义为一个名为Davis的类，定义如下：
package com.example.streaming;
import lombok.Builder;
import lombok.AllArgsConstructor;
import lombok.NoArgsConstructor;
import java.sql.Timestamp;
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class Davis {
Timestamp t
浏览 3提问于2021-09-28得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
