- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在尝试使用 KafkaAvroSerialzer 设置一个 kafka 生产者以获得值(value)。当 rit 尝试创建生产者时,我遇到了这个错误。我正在使用 confluence 5.2.1 中提供的所有 jars
java.lang.NoClassDefFoundError: Could not initialize class io.confluent.kafka.schemaregistry.client.rest.RestService
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.<init>(CachedSchemaRegistryClient.java:104)
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.<init>(CachedSchemaRegistryClient.java:81)
at io.confluent.kafka.serializers.AbstractKafkaAvroSerDe.configureClientProperties(AbstractKafkaAvroSerDe.java:53)
at io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.configure(AbstractKafkaAvroSerializer.java:43)
at io.confluent.kafka.serializers.KafkaAvroSerializer.configure(KafkaAvroSerializer.java:48)
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:370)
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:298)
at swing.KafkaUtilityPanel.sendMessage(KafkaUtilityPanel.java:229)
at swing.KafkaUtilityPanel.access$1200(KafkaUtilityPanel.java:32)
at swing.KafkaUtilityPanel$4.actionPerformed(KafkaUtilityPanel.java:164)
at javax.swing.AbstractButton.fireActionPerformed(AbstractButton.java:2022)
at javax.swing.AbstractButton$Handler.actionPerformed(AbstractButton.java:2348)
at javax.swing.DefaultButtonModel.fireActionPerformed(DefaultButtonModel.java:402)
at javax.swing.DefaultButtonModel.setPressed(DefaultButtonModel.java:259)
at javax.swing.plaf.basic.BasicButtonListener.mouseReleased(BasicButtonListener.java:252)
at java.awt.Component.processMouseEvent(Component.java:6533)
at javax.swing.JComponent.processMouseEvent(JComponent.java:3324)
at java.awt.Component.processEvent(Component.java:6298)
at java.awt.Container.processEvent(Container.java:2236)
at java.awt.Component.dispatchEventImpl(Component.java:4889)
at java.awt.Container.dispatchEventImpl(Container.java:2294)
at java.awt.Component.dispatchEvent(Component.java:4711)
at java.awt.LightweightDispatcher.retargetMouseEvent(Container.java:4888)
at java.awt.LightweightDispatcher.processMouseEvent(Container.java:4525)
at java.awt.LightweightDispatcher.dispatchEvent(Container.java:4466)
at java.awt.Container.dispatchEventImpl(Container.java:2280)
at java.awt.Window.dispatchEventImpl(Window.java:2746)
at java.awt.Component.dispatchEvent(Component.java:4711)
at java.awt.EventQueue.dispatchEventImpl(EventQueue.java:758)
at java.awt.EventQueue.access$500(EventQueue.java:97)
at java.awt.EventQueue$3.run(EventQueue.java:709)
at java.awt.EventQueue$3.run(EventQueue.java:703)
at java.security.AccessController.doPrivileged(Native Method)
at java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:80)
at java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:90)
at java.awt.EventQueue$4.run(EventQueue.java:731)
at java.awt.EventQueue$4.run(EventQueue.java:729)
at java.security.AccessController.doPrivileged(Native Method)
at java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:80)
at java.awt.EventQueue.dispatchEvent(EventQueue.java:728)
at java.awt.EventDispatchThread.pumpOneEventForFilters(EventDispatchThread.java:201)
at java.awt.EventDispatchThread.pumpEventsForFilter(EventDispatchThread.java:116)
at java.awt.EventDispatchThread.pumpEventsForHierarchy(EventDispatchThread.java:105)
at java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:101)
at java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:93)
at java.awt.EventDispatchThread.run(EventDispatchThread.java:82)
制作人这是我添加的生产者部分,但尝试使用 KafkaAvroSerializer 创建 kafka 生产者失败。
try {
//Configure connection properties
Properties producerConfig = createKafkaProducerProperties(environment);
//Create Kafka Producer
try (KafkaProducer<String, GenericRecord> myProducer = new KafkaProducer<>(producerConfig)) {
//Create ProducerRecord
Schema schema = new Schema.Parser().parse(new File("src/main/resources/investorOnboarding.avsc"));
GenericRecordBuilder genericRecordBuilder = new GenericRecordBuilder(schema);
GenericData.Record genericRecord = genericRecordBuilder.build();
final ProducerRecord<String, GenericRecord> myProducerRecord = new ProducerRecord<>(topicName.getCode(), genericRecord);
//Send the message
myProducer.send(myProducerRecord, new Callback() {
@Override
public void onCompletion(RecordMetadata metadata, Exception exception) {
if(exception == null){
alertSuccessStatus("Message has been successfully sent to Kafka");
}
}
});
//Disconnect
myProducer.close();
}
} catch (Exception ex) {
logger.info(ex.getMessage());
}
}
private Properties createKafkaProducerProperties(Environment implementation) throws UnknownHostException, PasswordProviderException {
Properties producerConfig = new Properties();
producerConfig.put("client.id", InetAddress.getLocalHost().getHostName());
producerConfig.put("bootstrap.servers", implementation.getBootStrapServers());
producerConfig.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
producerConfig.put("value.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer");
producerConfig.put("schema.registry.url", "http://localhost:8085");
已添加 jar
最佳答案
您需要使用kafka-schema-registry-client
,但我认为您不需要kafka-schema-registry
。
无论如何,我强烈建议您使用 Maven 或 Gradle 来管理任何 Java 项目的依赖项
https://docs.confluent.io/current/clients/install.html#installation-maven
关于java - 无法初始化类 io.confluence.kafka.schemaregistry.client.rest.RestService,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56514984/
关闭。这个问题不满足Stack Overflow guidelines .它目前不接受答案。 想改善这个问题吗?更新问题,使其成为 on-topic对于堆栈溢出。 2年前关闭。 Improve thi
我们有一堆 Confluence 页面供每个团队记下叶子。每个这样的页面都包含一个包含团队、团队成员姓名、月份、周...等的表格。 现在我们想要一个整合页面,在一个页面中显示所有团队的信息。我们可以创
我们的团队使用 Confluence 作为我们企业范围内的知识共享系统。这很好,但是对 Confluence 的搜索太糟糕了。我和其他公司的人谈过,他们也有类似的提示。 具体问题...是否有 Conf
我正在使用 Confluence REST api ,并想提取一些文件。文档正文有多种格式:editor , storage , view , export_view , anonymous_expo
如何在 Confluence 中格式化内联代码像这样?我的意思是,不是一个单独的代码块,而是例如内联classname。 最佳答案 要在 Confluence 中插入内联等宽字体,请将文本用双花括号括
在 Atlassian Confluence 中,您可以开发自定义宏或小工具。这两者有什么区别?据我所知:“小工具是由完全在用户的网络浏览器中运行的脚本生成的,而不是在 Confluence 服务器上
我正在尝试使用 swagger 将我的 Swagger JSON 模式 (myapi.json) 上传到 Atlassian Confluence - confluence独立 tool . 独立的
我在 Confluence 页面中插入了一张图片。似乎没有选项可以添加标题以提供图像的简短说明。 我找到了一个链接 - https://confluence.atlassian.com/display
我有一堆 html 文件,我使用他们的 API 从 fogbugz 导出,我正在尝试使用 UWC 将它们导入 Confluence。 但是,当我尝试导入它们时,它们以 html 格式导入,在我的空间中
我正在尝试将我们的 mediawiki 迁移到 confluence。我们尝试使用 Universal Wiki Converter,但它导出 HTML 内容,为此我们必须在 conflence 中手
我们使用 confluence 来制作文档,但我发现选择代码宏非常耗时;这是一个 5 步过程。即使手动键入宏也效率不高。 在 Stack Overflow 编辑器中,我们所要做的就是选择文本并按下按钮
我正在使用 Confluence 5.1,我想隐藏侧边栏 - 但仅限于几页。我只找到了一个基于 JQuery 的解决方案,它似乎不能在所有浏览器中正常工作。无论默认设置如何,它似乎都完全隐藏了侧边栏。
我正在使用 Confluence 5.1,我想隐藏侧边栏 - 但仅限于几页。我只找到了一个基于 JQuery 的解决方案,它似乎不能在所有浏览器中正常工作。无论默认设置如何,它似乎都完全隐藏了侧边栏。
我可以从 Confluence REST API 获取权限列表(使用 PythonConfluenceAPI): p = api.get_space_information(space_key, ex
我正在构建一个 confluence 插件,包括带有蓝图的蓝图向导对话框。但是当我尝试加载向导时,浏览器控制台出现 JS 错误, Uncaught error wizard points to a n
我正在将这个 table-plus 宏与 Confluence 一起使用: http://confluence.atlassian.com/display/CONFEXT/Table-plus+mac
关闭。这个问题是not reproducible or was caused by typos .它目前不接受答案。 想改善这个问题吗?更新问题,使其成为 on-topic对于堆栈溢出。 2年前关闭。
我想知道是否有一种方法可以将 gitlab 与 confluence 连接起来,并在每次将某些内容推送到 Gitlab 项目时使用管道 confluence 进行更新。 最佳答案 您需要使用来自 At
我已成功使用 Confluence Rest API 创建页面并将其附加到空间。我的 json 看起来很像示例中的那个: { "type":"page","title":"My Example Pag
我想显示 JIRA 详细信息,例如问题标题、版本路线图以及 Confluence 站点中项目的问题提出/解决图表。这对于登录的人来说很好,但我也需要它来进行匿名访问。我不想在 JIRA 中为项目设置匿
我是一名优秀的程序员,十分优秀!