问题标签 [ibm-eventstreams]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
2 回答
283 浏览

ibm-cloud-private - ibm-eventstreams-dev 未部署到 IBM Cloud Private

我尝试将 ibm-eventstreams-dev v 0.1.1 安装到 IBM Cloud Private 中,但收到一条错误消息:

内部服务错误:图表与 Tiller v2.6.0 不兼容

0 投票
1 回答
144 浏览

apache-kafka - ibm-eventstreams 是否支持 Kafka ACL?

想要检查我可以在 IBM Cloud Private (ICP) 2.1.0.3 上部署的 ibm-eventstreams 是否支持适用于特定主题的 Kafka SASL 身份验证和 ACL?

我指的是关于 Kafka ACL 的 developerWorks 文章: https ://developer.ibm.com/opentech/2017/05/31/kafka-acls-in-practice/

想知道 ibm-eventstreams 是否可用并支持它。如果受支持,我在上述文档中看到的 ACL 支持是否有任何更改/增强?是否有任何进一步的文件可用?

0 投票
2 回答
170 浏览

kubernetes - 将 ibm-eventstreams-dev 部署到本地环境时出错

我尝试将 ibm-eventstreams-dev v 0.1.2 安装到我的 Mac 中。

在我将 eventstreams 安装到我的 Mac 后,总是有几个 pod 无法运行。它包括三个 kafka pod:es-ibm-es-kafka-sts-0/1/2、es-ibm-es-ui-deploy-69758d9dfd-kc2zx、es-ibm-es-ui-oauth2-client-reg- pgvq6 并且还有一个名为 es-ibm-es-ui-oauth2-client-reg 的失败作业。

您可以在以下图片中查看详细信息: 在此处输入图像描述

在此处输入图像描述

在此处输入图像描述

所以我有两个关于 ibm-event-stream 的问题:

  • ibm-eventstreams-dev 是否​​仅在 ICP 上支持?我可以在没有ICP环境的本地环境中安装它吗?

  • 如何解决 ibm-eventstreams-dev 中的 ui pod 问题?

  • 卡夫卡豆荚有什么问题?状态消息“CrashLoopBackOff”是什么意思?

我的环境详细信息:

  • Kubernetes 1.11.1
  • 掌舵:稳定 2.10.0
  • 一个集群有三个节点,每个节点是一个虚拟机。

请帮助我,非常感谢!

0 投票
2 回答
3211 浏览

python - Python Kafka 客户端 - 没有错误但无法正常工作

我在 python 中运行 confluent_kafka 客户端。目前我在尝试生产然后消费消息时没有收到任何错误,但问题是生产者说它成功了,但消费者找不到任何消息。

我创建了一个主题,这是我正在使用的构建的类:

运行这个我得到打印:

0 投票
0 回答
70 浏览

apache-kafka - 将 Event Streams Kafka 主题连接到 IBM Cloud 中的 Grafana

如何在 IBM Cloud 的控制台中将 Kafka 主题从 Event Streams 连接到 Grafana?我似乎找不到可以工作的连接器,但文档似乎表明这不仅是可能的,而且是推荐的。

0 投票
0 回答
376 浏览

apache-spark - Spark Streaming readStream 无法从安全的 Kafka (EventStreams) 中读取

我正在尝试将数据从程序发送到安全的 Kafka 集群(IBM Cloud 上的 EventStreams - Cloud Foundry Services),然后在我的消费者应用程序(即火花流)中,我试图从相同的卡夫卡源。

这是Properties我在生产者内部设置的:

这是我用来将数据发送到 Kafka 集群的代码:

我能够确认这确实将数据发送到 Kafka 集群,因为我能够使用 IBM 云提供的 Grafana 指标查看进入集群的数据。

现在在我的 spark 流代码中,这是我尝试从 kafka 源中读取的方式:

其次是:

我不确定为什么,但我的 Spark Streaming 根本无法从源读取数据。当我启动 spark 流程序时,它会在输出中显示:

有一次,当我再次运行我的制作人时,火花流仍然存在于0 0. 我不确定我在这里写错了什么。

编辑:让消费者运行超过 7 个小时,仍然没有变化

0 投票
1 回答
1324 浏览

node.js - node-rdkafka 生产者未收到“就绪”事件

我正在尝试设置生产者以使用 node-rdkafka 将消息发送到 IBM Cloud 中的 Event Stream Service,但是我无法从服务器接收到“就绪”事件。

我花了一天的时间试图弄清楚这一点,我确信这将归结为我对 Producer 的配置,但据我所知,我做对了。

我从 Ubuntu 19.04 运行它,使用 node-rdkafka 创建生产者。我正在使用 Node 10.15.2 运行它

感谢您提供的任何建议。

我在下面包含了一些看起来失败的日志摘录。

0 投票
1 回答
372 浏览

spring-boot - 春季卡夫卡消费者有时不起作用

消费者有时不工作,有时却不工作,无法解决问题。

应用属性:

在我的休息控制器中,我有这个方法

在 WebSphere Application Server 的系统输出日志中,我经常看到这些消息

0 投票
1 回答
64 浏览

ibm-eventstreams - 将 IBM EventStreams 与 C/C++ 结合使用

我需要使用 C++ 程序中的事件流。寻找示例代码。

尝试了来自 librdkafka 的 ./rdkafka_example,我没有收到任何错误消息,但消息没有通过。这可能是授权问题,因为我找不到向代码提供凭据的位置。任何地方都有示例 C++ 程序吗?

0 投票
1 回答
615 浏览

spring-mvc - 在spring-mvc中创建时配置kafka主题保留策略?

创建期间配置所有主题的保留策略

尝试使用 spring 配置rentention.ms,因为我收到以下错误:

原因:java.util.concurrent.ExecutionException:org.apache.kafka.common.errors.PolicyViolationException:指定的保留时间无效。允许的范围是 [3600000..2592000000] 从我读到的新值是-1(无穷大)所以超出了这个范围

遵循 如何在 spring-mvc 中创建期间配置 kafka 主题保留策略中的内容?,我添加了下面的代码,但似乎没有效果。关于如何解决这个问题的任何想法/提示?