问题标签 [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.

15 问题
Newest
Active
Bountied
318
Unanswered
0 投票
0 回答
181 浏览

c# - 无法使用 IBM 上托管的 Confluent.Kafka 连接到 Apache Kafka

我正在尝试连接到 IBM 的托管 Apache Kafka 解决方案。这就是 IBM 在其文档中声明的连接 bootstrap.servers=broker-2-****.kafka.svc03.us-***.cloud.ibm.com:9093, sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="token" password="<api_key>";, sasl.mechanism=PLAIN, security.protocol=SASL_SSL,ssl.protocol=TLSv1.2

这就是我在代码中配置的方式

但是我无法在 c# 代码中设置 ssl.protocol=TLSv1.2。不确定这是否是问题的原因。无论如何，这是我得到的错误。错误日志链接

我试图了解日志，但我怀疑版本控制有问题，无法找出确切的问题。

我正在运行：

  1. 点网核心 3.1
  2. Confluent.Kafka(1.4.0)。如果您需要更多详细信息，请告诉我
0 投票
0 回答
46 浏览

ibm-datapower - 在 IBM Event Streams SaaS on Cloud 中，我可以在哪里查找失败的客户端连接尝试？

我正在尝试将 Kafka 客户端（它恰好是运行 V10 的 DataPower 设备）配置到 IBM Cloud 中的 IBM Event Streams SaaS 实例。但是 Kafka 客户端不断抛出错误：

代理传输失败初始化失败

在 IBM Event Streams SaaS 中，我可以去哪里确定是否可以看到我的 Kafka 客户端正在尝试建立连接？并且，理想情况下，查看一些有用的错误消息，例如“pwd is wrong”！

0 投票
0 回答
23 浏览

apache-kafka - macOS 上的 node-rdkafka：错误：配置属性“security.protocol”的值“sasl_ssl”无效

我正在尝试使用node-rdkafka并看到以下错误连接到 IBM Event Streams（以前的 Message Hub）

我在 StackOverflow 上尝试了其他答案，但没有运气。我正在macOS 10.15.7 (Catalina)上尝试这个

0 投票
1 回答
2111 浏览

apache-kafka - kafka-connect 分布式工作者是否可以使用配置“cleanup.policy=compact,delete”的主题“connect-offset”工作

我启动了一个 kafka-connect 分布式工作集群，它使用该主题connect-offset进行偏移存储：

由于为代理提供了默认策略“cleanup.policy=delete”，因此在使用“cleanup.policy=compact”创建主题时，我最终将获得该主题的“cleanup.policy=compact,delete”。导致 kafka-connect 工作进程抛出异常：

org.apache.kafka.common.config.ConfigException：通过“offset.storage.topic”属性提供的主题“slpe-connect-offset”需要具有“cleanup.policy=compact”以保证源连接器的一致性和持久性偏移量，但发现该主题当前具有“cleanup.policy=compact,delete”。继续可能会导致最终丢失源连接器偏移量以及将来重新启动此 Connect 集群的问题。更改 Connect 工作程序配置中的“offset.storage.topic”属性以使用具有“cleanup.policy=compact”的主题。

问题：是否有任何 kafka-connect worker 配置允许吃这个异常来保持工作进程？虽然这是一个风险，但delete在达到保留或大小限制之前不会发生。

0 投票
0 回答
39 浏览

java - Event Streams - 编码挑战（适合初学者）

我下载了 IBM Event Streams 应用程序编码挑战（https://developer.ibm.com/learningpaths/ibm-event-streams-badge/event-streams-coding-challenge/）

我是Java的初学者。我需要帮助（任何人）来创建 *.jar 文件。

采取的步骤：

我已经下载了 IBM 应用程序代码 Gradle，并且正在使用 Eclipse IDE。在进行任何更改之前，我尝试重新创建 *.jar 文件 (coding-challenge-setup.jar)。这是原始代码（未进行任何更改）-但是当我尝试（文件->导出-> Jar File ...）执行此操作时，系统会给我以下警告：

JAR 创建失败。有关其他信息，请参阅详细信息。导出时出现编译警告：eventstreams-badge-sample-master/consumer/src/main/java/com/ibm/eventstreams/App.java 资源与文件系统不同步：'/eventstreams-badge-sample-master/测试1.jar'。资源与文件系统不同步：“/eventstreams-badge-sample-master/test1.jar”。

最终我想对代码进行更改，然后重新创建 *.jar 文件并测试我的代码更改。我似乎无法创建原始 *.jar - 有人可以帮助解决这个问题。任何帮助表示赞赏。


12345678910