问题标签 [message-hub]

更新：关于以下问题的一些上下文。我的目标是处理用户的请求，他们为每个请求提供一个 Kafka 主题。我使用部署在 Bluemix 上的 Message Hub 作为 Kafka 提供者。请求将传递代理 URL、主题名称、用户名、密码和 API 密钥。Bluemix 上的 Message Hub 需要 JAAS 身份验证并提供具有不同 LoginModule 实现的登录模块。有些基于 CallbackHandlers，有些基于 CredentialProviders。

我选择了在com.ibm.messagehub.login.MultiUserLoginModule. 使用该模块，我只需要提供一个自定义凭据提供程序，例如：

挑战在于类加载器以及 CustomCredentialProvider 如何在运行时从传递给 MultiUserLoginModule 的请求中获取用户名/密码。我必须使用什么配置才能使其正常工作？

详细信息：我有一个在 WebSphere Liberty 8.5.5 中运行的 Web 应用程序，并希望通过第三方服务进行身份验证。该第三方服务使用 CredentialProvider 实现 JAAS LoginModule。我的 Web 应用程序使用 CustomCredentialProvider 扩展 CredentialProvider 以传递凭据。

我不明白类加载应该如何工作。我的server.xml定义：

网络应用程序

第三方登录模块

实现第三方登录模块的库

登录上下文

上述配置的结果是我的 CustomCredentialProvider 的 ClassNotFoundException：

如何更改第三方 JAAS 登录模块的配置才能myApp.CustomCredentialProvider在我的streaming-serviceWeb 应用程序中实现？

注意：我已经尝试生成一个 streaming-service.jar 并将其直接添加到messageHubLoginLib. 这解决了 ClassNotFoundException 但 CustomCredentialProvider 类完全在我正在运行的 Web 应用程序的上下文之外加载，并且仍然无法访问我的凭据。

我正在使用 Kafka Broker 的 IBM Bluemix 实现。

我正在创建具有以下属性的 KafkaProducer：

有了这个，我得到了以下异常：

org.apache.kafka.common.KafkaException: org.apache.kafka.clients.producer.internals.DefaultPartitioner 不是 org.apache.kafka.clients.producer.Partitioner 的实例

阅读以下博客后： http: //blog.rocana.com/kafkas-defaultpartitioner-and-byte-arrays我在属性文件中添加了以下行，即使我使用的是新 API：

现在我得到了这个例外：

org.apache.kafka.common.KafkaException：无法实例化类 kafka.producer.ByteArrayPartitioner 它是否有一个公共的无参数构造函数？

看起来ByteArrayPartitioner没有默认构造函数。知道我在这里缺少什么吗？

谢谢马杜

我按照本教程使用 Bluemix 中的流分析服务与消息集线器进行交互： https ://developer.ibm.com/bluemix/2015/10/16/streaming-analytics-message-hub-2/?cm_mc_uid =45284031179414585919178&cm_mc_sid_50200000=1464112496

我收到一个错误：

引起：org.apache.kafka.common.KafkaException：javax.security.auth.login.LoginException：找不到LoginModule类：com.ibm.messagehub.login.MessageHubLoginModule

谢谢

有没有办法将 Message Hub (Apache Kafka) 的日志大小从 1 GB (retention.bytes) 增加到 50 GB，并将 Public Bluemix 上的日志保留时间从 24 小时增加到 24 小时？

尝试使用上述代码将消息发布到 Message Hub 时，我们总是收到以下错误。

2016-06-21 18:38:22-[INFO] com.ibm.cloudant.streaming.messageHub.Client.send(476): >>>> 发送 document_id julia30 @ my_database 2016-06-21 18:38:22 -[DEBUG] org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(623)：初始化与节点-1的连接以发送元数据请求 2016-06-21 18:38:22-[DEBUG] org.apache.kafka .clients.NetworkClient.initiateConnect(487)：在 kafka01-prod01.messagehub.services.us-south.bluemix.net:9093 处启动到节点 -1 的连接。2016-06-21 18:38:22-[DEBUG] org.apache.kafka.common.security.authenticator.SaslClientAuthenticator$1.run(105)：创建 SaslClient：client=multiuser-adapter@multiuser.messagehub.ibm.com ;service=kafka;serviceHostname=kafka01-prod01.messagehub.services.us-south.bluemix.net;mechs=[GSSAPI] 2016-06-21 18:38:22-[DEBUG] com.

生产者的设置如下所示：

```

```

使用上述设置，使用 Message Hub REST API 创建主题没有问题。尝试发布消息时会出现问题。

任何想法都受到高度赞赏。

我们需要了解 Bluemix MessageHub 是否支持静态数据加密。如果它不提供对静态数据加密的直接支持，那么消费者或生产者是否有任何最佳实践来实现这一点？

我正在关注来自 github 的消息中心 java 示例。我创建了自己的 Kafka 生产者版本，它在使用 java 主应用程序的 J2Se 环境中运行良好。下面的代码片段 -

kafka 客户端版本 - 0.90

当我将此代码包装在 J2EE MDB 中并将其部署在 BPM 服务器上时。当 MDB 触发时，线程继续等待 send() ：-

RecordMetadata recordMetadata = kafkaProducer.send(producerRecord).get();

并在一段时间后超时。它不会抛出任何其他异常或错误。

我的问题是，为了从 BPM 内部使用 kafka 客户端 api，我是否必须执行任何其他步骤，例如 ssl 配置等。

请指教。

谢谢。

我在 Bluemix 上提供了一个 IBM Message Hub 实例。我已经实现了一个在我的本地机器上运行的 Java 接收器，它需要能够连接到这个 IBM Message Hub 实例并接收消息。

我应该如何设置我的 VCAP_SERVICES 以便我可以从 Bluemix 连接到我的 IBM Message Hub 实例？当我转到“服务凭据”选项卡时，我配置了一组凭据。密钥名称是 MHCredentials。它的 JSON 值为：

请告诉我应该如何设置我的 VCAP_SERVICES 以便我可以从本地计算机上运行的接收器连接到 MessageHub。我已经在我的机器上创建了一个名为：VCAP_SERVICES 的环境变量，上面显示了 JSON 字符串。然而，当我运行我的接收器时，我得到了一个错误：Not a JSON Array.

我正在将消息从 Message Hub 流式传输到 Bluemix 中的 Spark 实例。我正在使用 java 客户端将简单的 json 消息发送到 Message Hub。

JSON 消息 -

当我开始在 Spark 中进行流式传输时，我收到的消息的开头有一个额外的 null。

请让我知道为什么 Spark 上下文将这个 null 放在前面。我怎样才能删除它？

KafkaSender 代码 -

谢谢拉吉

我们目前正在使用 messagehub 进行开发。我们配置了以下 MessageHub 实例：

但是，当我们尝试启动我们的应用程序时，我们会收到错误消息：

任何想法，是什么原因造成的？我们无法启动使用此功能的应用程序的任何模块。

米希尔