我一直在使用这个链接上的Message Hub示例代码：// Synchronously wait for a response from Message Hub / Kafka on every message produced
浏览 6提问于2017-02-07得票数 1
回答已采纳
关于我们是否可以使用Python访问Message Hub的问题之前已经提出过。答案通常是否定的，直到用Python编写了SASL实现。社区里有没有人有例子？
浏览 0提问于2016-04-20得票数 3
byte[], byte[]>( KEY.getBytes("UTF-8"),
// Synchronously wait for a response from Message Hub / Kafka.(Kafka
浏览 2提问于2016-11-22得票数 0
回答已采纳
我试着把一些连接器(jdbc连接器，mysql连接器)放到kafka- connector容器中，但是它没有工作。
如果我输入插件路径，我应该写在哪里？卡夫卡-连接？)
浏览 26提问于2022-05-20得票数 0
1回答
install --no-prompt confluentinc/kafka-connect-avro-converter:5.5.3 && \ cp/
浏览 13提问于2022-11-08得票数 0
(JaasConfig.java:63) ~kafka-clients-2.3.1.jar:na at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:90) ~kafka-clients-2.3.1.jar:na at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:90)~kafka</e
浏览 23提问于2021-06-17得票数 0
客户端支持Kafka 0.9，但显然没有包含新的身份验证和加密功能，所以我猜测它只适用于开放服务器(和以前的版本一样)。在任何情况下，即使是Java客户机也需要一个特殊的消息集线器登录模块来连接(或者从示例中看是这样)，这表明除非有一个类似的模块可用于Python，否则什么都不能工作。
浏览 2提问于2016-02-09得票数 1
我在Bluemix上配置了一个IBM Message Hub实例。我已经实现了一个运行在本地机器上的Java接收器，它需要能够连接到这个IBM Message Hub实例并接收消息。我应该如何设置我的VCAP_SERVICES，以便可以从Bluemix连接到我的IBM Message Hub实例？当我转到Service Credentials选项卡时，我配置了一组凭据。": "https://kafka-admi
浏览 22提问于2016-08-11得票数 0
我是kafka新手，我试图运行一个示例apache生产者代码，将数据推送给kafka。我能够通过java创建新的主题，但是在推进过程中，我得到了一个例外。>(TOPIC,"Test message from java program " + sdf.format(new Date()));
System.out.println(message);message from java program 4&
浏览 6提问于2015-05-04得票数 0
回答已采纳
/java,/usr/share/confluent-hub-components,/usr/share/java/kafka-connect-jdbc"RUN confluent-hub install --no-pr
浏览 8提问于2022-01-12得票数 0
回答已采纳
如何从控制台应用调用我的SignalR集线器。然后SignalR集线器会将消息发送给它的客户端？
浏览 3提问于2021-02-18得票数 0
我希望这些异常被打印为一种适当的日志格式，比如sflf4j(LOGGER.ERROR)，而不是在控制台上打印。问题是，我想要以正确的日志格式打印错误，而不是用巨大的堆栈跟踪抛出控制台。下面是KakaConsumerConfigFactory.java的代码片段，该代码片段使DLT实现可以处理错误记录并将其推送到DLT主题。;import org.springframework.kafka.cor
浏览 4提问于2022-10-25得票数 0
我使用的是MS示例中的代码： public Task PushMessage(string Message) var T = Clients.All.SendAsync(Message); return T;
} 但是writeline调用永远不会到达
浏览 32提问于2019-04-19得票数 0
我们已经建立了Cloudera基础设施(动物园管理员、经纪人等)，我已经成功地使用了Kafka命令行工具来生成和使用消息。我使用[org.apache.kafka/kafka_2.10 "0.8.2.1"]作为依赖项，并且已经能够使用客户端API来设置一个KafkaProducer，该KafkaProducer发布带有纯字符串内容的消息我的问题是:在上是否有一个代码示例来演示如何初始化KafkaConsumer，并在另一边读取该消息，因为我已经搜索了好几天，而且似乎没有一个工作：
它们使用
浏览 3提问于2016-05-19得票数 0
我们正在使用kubernetes上的kafka连接集群(头盔图表)。我无法这样做与雪花卡夫卡连接器。P.S.：
对于PoC，我在本地机器上运行了kafka connector，并在插件目录中添加了雪花-kafka-连接器jar文件，运行良好。但是需要这个码头映像来进行生产部署。
浏览 2提问于2019-10-10得票数 1
回答已采纳
ENV CONNECT_PLUGIN_PATH="/usr/share/java,/usr/share/confluent-hub-components"
RUN confluent-hub install --no-prompt confluentinc/kafka<
浏览 3提问于2021-07-01得票数 5
回答已采纳
我们在我们的环境中使用Kafka 2.10-0.9.0.2.4.2.0258。我们在少数几个主题上得到了卡夫卡控制台用户的例外。我知道，有时这些主题中包含的消息太大了，但它们不会超过message.max.bytes。
java.lang.IllegalArgumentExceptionat java.nio.Buffer.limit(Buffer.
浏览 1提问于2016-08-29得票数 2
回答已采纳
1回答
export KAFKA_OPTS="-Djava.security.auth.login.config=jaas.conf"
(echo -n "1|"; cat message.json | jq-c) | kafka-conle-producer.sh --topic test-event-hub --broker-list test-eh-namespace.servicebus.windows.net(Native Method) at org.apache.ka
浏览 1提问于2021-05-07得票数 1
回答已采纳
1回答
$1.run(LicenseStore.java:159) at org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java(StandaloneHerder.java:
浏览 0提问于2018-12-19得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
