1回答
我正在使用Akka Kafka (Scala)，并希望发送自定义对象。}
如何正确地编写自己的序列化程序？而且，我应该如何处理字段config？
浏览 2提问于2017-08-01得票数 0
1回答
下面是我的用例
让每个主题的使用者将工作分发给集群中的工作人员。这让我探索Akka集群的工作分配，路由和缩放。我可以使用Akka“监督员”作为卡夫卡的消费者，并根据其分类将输入的工作分配给适当的工人。但是，我仍然想要理解的是，在Akka集群中实现主管和员工之间的一种灵活的沟通方式的正确方法。因为一旦监督者消耗了卡夫卡的信息，卡夫卡的偏移就会发生。通过使用由Kafka支持的持久邮箱，使主管成为持久的参与者。主管在卡夫卡对工
浏览 4提问于2016-04-10得票数 6
1回答
我们已经发现reactive-kafka使用它自己的dispatcher (akka.kafka.default- dispatcher )，但是，如果我们使用默认的akka dispatcher，一切都会更快(reactive-kafka dispatcher ~300 messages/s，default dispatcher ~1300 messages/s )
我想知道使用默认调度程序是否安全。
浏览 2提问于2016-06-11得票数 3
val system: ActorSystem = ActorSystem()
val consumerConfig = system.settings.config.getConfig("akka.kafka.consumer
浏览 4提问于2020-08-17得票数 0
我将相关角色的消息(反)序列化到Play /从Play序列化！杰森。我想使用JSON (反)序列化的akka持久化系统(如果可能)。谢谢!
最好的！
浏览 3提问于2015-01-27得票数 4
我们使用Chill-bijection来序列化/反序列化Kafka与Kryo之间的消息。我们的应用程序的旧版本使用的是依赖于com.esotericsoftware.kryo.kryo-2.21.jar的Chill 0.6.0，而我们的应用程序的新版本使用的是依赖于com.esotericsoftware.kryo-shaded为了最大限度地减少停机时间，我们的应用程序的新版本需要能够读取由旧版本的应用程序编写的消息，但它会失败，并返回一个错误： org.ap
浏览 42提问于2021-01-20得票数 0
回答已采纳
我已经从下载了一个示例代码，并在它发送消息的每一次新运行中运行AtLeastOnceDelivery.sln。如果我更改消息命名空间，它将显示一个错误。如果我能够清除持久性，希望它能够接受更改后的命名空间并重新启动消息传递id。
浏览 0提问于2018-09-24得票数 0
回答已采纳
三个或更多，我得到了这个：
[INFO][11/28/2017 2:57:27 PM][Thread 0005][[akka://ECHO3DEV/user/api-master/PortfolioCoordinator[ERROR][11/28/2017 2:57:27 PM][Thread 0005][[akka://ECHO3DEV/user/api-master/PortfolioCoordinator&
浏览 3提问于2017-11-28得票数 1
回答已采纳
如何发布附件 (pdf，xls，xml，jpg.)卡夫卡主题。目前，我们正在宣传卡夫卡的阿夫罗格式。AVRO支持将文件附加到其中吗？
浏览 1提问于2020-07-13得票数 0
回答已采纳
我正试图用Kafka 0.10构建一个POC。我使用自己的scala域类作为Kafka消息，其中包含一组字符串数据类型。我不能使用Kafka库附带的默认序列化类或字符串序列化器类。我想我需要编写自己的序列化程序并将其提供给生产者属性。如果您知道用Kafka (使用scala)编写一个示例自定义序列化程序，请进行共享。非常感谢，非常感谢。
浏览 1提问于2017-04-17得票数 0
我正在研究为Kafka实现自定义序列化器/反序列化器。要实现Kafka自定义序列化程序/反序列化器，我们必须分别实现org.apache.kafka.common.serialization.Serializer和org.apache.kafka.common.serialization.Deserializer
浏览 2提问于2020-01-31得票数 1
回答已采纳
1回答
我想在CSharp中为kafka编写一个自定义的序列化程序。我搜索了很多，但我没有找到一个很好的参考资料，关于如何用dotnet语言为kafka编写自定义序列化程序。
浏览 18提问于2020-06-01得票数 2
1回答
我有以下scala代码：import akka.actor.ActorSystemimport akka.kafka.import org.apache.kafka.clients.consumer..runWith
浏览 3提问于2017-11-03得票数 1
回答已采纳
1回答
当我使用spring-boot和spring-kafka时，我的代码如下：spring.kafka.bootstrap-servers=localhost:9092spring.kafka.consumer.key- deserializer=org.apache.kafka.common.serialization.StringDeserializerspring.<e
浏览 0提问于2018-07-06得票数 0
我已经读取了一个csv文件，并使用Kafka生产者应用程序将value字段转换为字节，并将其写入Kafka主题。现在我正在尝试阅读Kafka主题使用结构化流，但不能应用自定义kryo反序列化的值域。有人能告诉我如何在结构化流媒体中使用自定义反序列化吗？
浏览 0提问于2018-01-10得票数 1
/src/main/scala/App.scala中有以下代码import akka.actor.ActorSystemimport akka.stream."
scalaVersion
浏览 0提问于2018-06-18得票数 2
回答已采纳
我想知道我是否需要一个自定义的序列化程序来将JSON消息生成到kafka队列中。我在生产时不一定要处理对象，但我得到的消息将是JSON格式的，我需要将其推入kafka队列。现在，我想知道是否需要一个定制的序列化程序来将JSON格式的消息生成到队列中，因为毕竟JSON消息将是一个简单的字符串。
浏览 2提问于2015-01-19得票数 3
另外，我需要一些特殊的序列化逻辑。据我所知，要创建自定义序列化程序，我必须实现Serializer<>接口。因此，问题是Kafka-镜制造者没有使用我在producer.properties中指定的自定义序列化程序：client.id=producerB要构建序列化程序，我使用gradle： constra
浏览 1提问于2019-07-18得票数 2
回答已采纳
1回答
[INFO] [02/04/2014 16:34:58.408] [RemoteApp-akka.actor.default-dispatcher-4] [akka://RemoteApp/system/endpointReader-akka.tcp%3A%2F%2FLocalApp%40127.0.0.1%3A10174-0]
Message [akka.remote.transport.AssociationHandle$InboundPayload] fr
浏览 0提问于2014-02-04得票数 2
回答已采纳
1回答
我对Akka流和反应流非常陌生。我有一个问题:是否有可能让rest接收一条消息，将其丢弃在Kafka总线上，然后由Kafka流用户最大限度地聚合消息。回溯答案的时间窗口吗？
如何实施这样的制度？
浏览 1提问于2017-05-25得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
