Kafkaand和OSB 12c之间的集成问题
我正在Kafka(kafka_2.11-0.10.0.0)和OSB 12c(12.2.1.2)之间建立连接，以便在OSB上使用来自Kafka的消息。
我已经按照要求的步骤在OSB中安装了Kafka Transport，并成功运行，但是当我尝试使用来自Kafka的消息时，我得到以下错误:
com . bea . wli . sb . transports . transport exception:org . Apache . Kafka . common . Kafka exception:无法在Oracle . ateam . sb . transports . Kafka . Kafka endpoint . start(kafkaendpoint . Java:505)在Oracle . ateam . sb . transports . Kafka . kafkatransportprovider＄endpointsstartuptask . run(kafkatransportprovider . Java:399)在Java . util . timerthread . mainloop(timer . Java:555(KafkaEndpoint.java:568)at Oracle . ateam . sb . transports . Kafka . kafkaendpoint . start(kafkaendpoint . Java:480)...3更多原因:org . Apache . Kafka . common . Kafka exception:Java . lang . illegalargumentexception:没有注册可以处理org . Apache . Kafka . common . network . saslchannelbuilder . configure(saslchannelbuilder . Java:86)的名为KafkaClient的配置。...7更
我已经尝试创建新的主题来阅读那里的信息，但它仍然不起作用。
OSB配置：
Transport:
Protocol : Kafka
endpoint URI: http://localhost:2181
共有2个答案
在这里，您使用Zookeeper端口(2181)，而不是使用Kafka引导代理:localhost:9092
问题似乎是您正在使用的endpoint。这里有两件事需要解决：
-
< li>Kafka不使用http协议，除非您使用REST代理。 < Li > Kafka的OSB传输需要指向引导服务器。
考虑到端口2181，您的endpoint似乎指向Zookeeper。
-
本文向大家介绍接口和集成测试之间的差异。，包括了接口和集成测试之间的差异。的使用技巧和注意事项，需要的朋友参考一下 众所周知，测试是任何应用程序或软件交付过程中最重要的阶段，因为测试不仅可以验证应用程序的质量，还可以为开发人员提供改进其产品的机会。 每个应用程序都是通过将其组成部分的不同组成部分进行开发来开发的。现在我们知道，集成测试是在集成环境中测试所有组件的测试，即测试是对所有组件进行的，它们
-
我在过程中创建一个Web应用程序在围棋使用贝戈（https://beego.me）。 我需要捕获Newrelic中的应用程序监控和计量指标，并能够查看Newrelic中的所有事务。 我遵循了此文档，正在使用Beego GoRelic在代码中初始化Newrelic代理。 这是我的router.go课 在我的应用程序中。conf，我提供了newrelic许可证密钥和应用程序名称，如下所示： 当我在模式
-
本文向大家介绍IDEA 2020 设置项目集成git 及svn和git之间的切换问题，包括了IDEA 2020 设置项目集成git 及svn和git之间的切换问题的使用技巧和注意事项，需要的朋友参考一下 Git是什么？svn是什么？ Git svn 统称版本控制器 在开发中经常是两个或多个人同时开发一个控制器为了不产生代码冲突法发明了版本控制器 最终目的，为了多人开发 Git是目前世界上最先进的分
-
本文向大家介绍单元测试和集成测试之间的区别，包括了单元测试和集成测试之间的区别的使用技巧和注意事项，需要的朋友参考一下 众所周知，测试是任何应用程序或软件交付过程中最重要的阶段，因为测试不仅可以验证应用程序的质量，还可以为开发人员提供改进其产品的机会。 每个应用程序都以某种高级或低级语言进行开发，这意味着已经为其开发编写了一些代码，因此在要测试的模块的基础上，存在测试的分类，即单元测试和集成测试。
-
我在将JProfiler连接到Linux上运行的远程WebSphere 8.5.5实例时遇到了一些问题。当我在我的Windows 10机器上启动JProfiler时，我选择“本地或远程配置应用程序服务器”，并选择与IBM WebSphere 8集成的选项。x应用服务器。 我遇到的问题是设置配置文件的“指定远程地址”部分。安装程序说我需要在目标JVM上运行分析代理。我从JProfiler网站下载ta
-
我有一个配置类，它存储在hz IMap 这个配置类是1-st实例成员 P. S成员是两个不同的应用程序的一部分。 此配置作为对象从第一个集群成员推送到IMap 我的目标是在另一个模块中看到这个配置 如何在第二个成员实例中序列化该对象 如果调用 我得到了