我创建了一个普通的java项目，并将lagom kafka客户端的所有依赖项放在类路径上，然后将application.conf放在源文件夹中。application.conf的内容 service-name = ""
在运行应用程序时我发现在创建KafkaConfig时，即将到来的conf对象在其源中没有我的application.conf
之后，我尝试使用vm参
浏览 17提问于2018-01-31得票数 1
回答已采纳
我刚刚开始使用lagom，正在尝试运行lagom示例，但我在启动服务器时遇到了错误。我遇到了以下错误 [info] Starting Kafka ....Kafka Server[error] Total time: 32 s, completed Jan 28, 2017 1:19:03 AM lagomServiceGa
浏览 0提问于2017-01-28得票数 3
2回答
尝试了不同的文档，但无法使用lagom实现kafka使用者api。AhcWSComponents {
}
请向我提供关于如何实现kafka
浏览 7提问于2020-06-29得票数 0
1回答
我知道如何使用Lagom的ServerServiceCall[Req, Res]设置响应的Content-Type头。但是，如果将String指定为响应参数类型，则无论我在服务调用的正文中设置什么，Content-Type都会被覆盖为"text/plain“。像这样的东西可以工作吗：import com.lightbend.lagom.scaladsl.api.transport.MessageProtocolimport com.lightbe
浏览 14提问于2020-02-19得票数 0
1回答
阅读项目，我无法摆脱一种感觉，即它与 (构建基于参与者的反应性微服务的框架)具有相同的功能。其他相似之处
拉古姆最后一次发布是在4月份，之前是在2020
浏览 6提问于2021-08-25得票数 1
回答已采纳
使用spring.cloud.stream.kafka.bindings.function配置配置使用者，并启用DLQ。spring.cloud.stream.kafka.bindings.consumeTest-in-0: batch-mode: falsetest.file.error dlqProducerProperties.configuration.key.serializer: org.apache.kafka.comm
浏览 9提问于2021-11-13得票数 1
回答已采纳
我有一个用例，在这个用例中，我需要编写一个自定义逻辑来根据消息中的某些关键参数分配分区。我对此做了一些研究，发现kafka转换支持覆盖转换接口中的某些方法，但我无法在git、hub或其他地方编写一些示例代码。请有人共享示例代码或git集线器链接，以便在kafka源连接器中执行自定义分区分配吗？
提前谢谢！.
浏览 1提问于2019-03-15得票数 3
回答已采纳
2回答
我正在将Kafka配置为我的RouteBuilder中的源码。我的目标是处理Kafka断开连接的问题。)); });Connection to node -1 could not be established.
浏览 2提问于2017-11-14得票数 2
我正在使用Datadog从运行在我的本地主机上的Kafka收集指标。当我在我的Datadog代理上运行-info命令时，这是我为Kafka得到的错误。你知道这是什么原因吗？kafka - instance #kafka-localhost-9999 [ERROR]: 'Cannot connect to instance localhost
浏览 33提问于2016-08-27得票数 0
案例2:作为单个服务运行时使用覆盖网络(群集模式)WARN [2019at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64) [kafka_2.12-1.0.0.jar:?]我对 kafka 不太了解，也无法理解覆盖网络是如何影响卡夫卡过程的，而它在桥接网络中
浏览 2提问于2019-12-06得票数 0
回答已采纳
1回答
我们通过DCOS运行Kafka。我们有一个主题，它似乎有一些错误的数据。我想删除这个话题。尝试运行: kafka-topics.sh --zookeeper --delete --topicdcos kafka broker更新1 --options delete.topic.enable=true`该主题仍然存在，并且仍然标记为要删除
浏览 2提问于2016-01-12得票数 4
错误日志： at org.apache.flink.streaming.connectors.kafka.internals.Handover.close(Handover.javaat org.apache.flink.streaming.connectors.kafka.internals.Kaf
浏览 22提问于2021-07-06得票数 0
回答已采纳
我正在阅读spark Kafka集成文档，发现我无法覆盖key.deserializer、value.deserializer和schema.registry.url。我试图解码来自spark的Avro消息，我必须编写自定义逻辑，而这是由其他Kafka客户端库提供的。
浏览 1提问于2021-02-20得票数 0
1回答
如何开启Kafka源连接器幂等性功能？
我知道在confluent中，我们可以通过worker配置中的producer.*属性覆盖生产者配置，但是Kafka本身呢？是一样的吗？
浏览 1提问于2021-01-22得票数 1
我正在使用下面的代码处理Kafka流。我从JSON检查筛选条件，以确定条件if "UserID":"1"。请参考下面的代码
builder.by: org.apache.kafka.streams.errors.StreamsException: A serializer (key: org.apache.kafka.common.serialization.ByteArraySerializer/ value: org.apache.kafka.common.serial
浏览 0提问于2018-05-11得票数 4
回答已采纳
我在我的mac上的minikube k8集群的Pod上运行了一个landoop kafka镜像。我有两个不同的服务来公开用于模式注册的端口8081和用于代理的端口9092。但是，当我尝试运行控制台消费者或我的消费者应用程序时，Kafka从不消费消息。1)不能在k8集群之外通过上述方式访问k8集群外的Kafka吗?如果是这样，我是不是做错了? 2)如果端口是开放的，这不是意味着broker是可用的吗？
浏览 86提问于2018-02-13得票数 3
/bin/bash
timeout -k 3s 3s $path/bin/kafka-console-cons
浏览 14提问于2021-11-28得票数 0
(kafka.log.Log)Kafka: # NOTE: UseIP:port notation
浏览 0提问于2018-05-09得票数 0
回答已采纳
我正在使用Kafka 0.10 REST。我只是在Java中使用了一个HTTP对象来调用Kafka (例如curl命令)。当我使用该消息时，我需要指示使用者偏移量，否则它将从开始或最近读取，但无法找到指示偏移量的参数。
是否有完整的REST代理文档来描述每个参数。
浏览 0提问于2018-04-01得票数 2
回答已采纳
2回答
implementation (('org.apache.kafka:kafka-streams:2.3.0'), { })到底出了什么问题:一个评估项目的问题发生了
无法为参数org.rocksdb:rocksdbjni:5.18.3在DefaultExternalModuleDependency{group='org.apache.kafk
浏览 10提问于2020-07-13得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
