Kafka Producer错误TOPIC:XXXXXX的10条记录已过期:自创建批处理以来，已经过去了6686毫秒
本文介绍了Kafka Producer错误TOPIC:XXXXXX的10条记录已过期:自创建批处理以来，已经过去了6686毫秒的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 Kafka版本:0.10.2.1，Kafka Version : 0.10.2.1,Kafka Producer error Expiring 10 record(s) for TO...
Kafka到hdfs3接收器缺少必需的配置"confluent.topic.bootstrap.servers"；没有默认值
本文介绍了Kafka到hdfs3接收器缺少必需的配置"confluent.topic.bootstrap.servers"；没有默认值的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 我的HDFS是通过ambari，HDP安装的.我目前正在尝试将kafka主题加载到HDFS接收器中. Kafka和HDFS安装在同一台机器x.x.x.x中.除了默认端口根据我...
将数据从 Kafka Topic 以 JSON 格式推送到 PostgreSQL
本文介绍了将数据从 Kafka Topic 以 JSON 格式推送到 PostgreSQL的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 更新后出错[2019-07-29 12:52:23,301] INFO Initializing writer using SQL dialect: PostgreSqlDatabaseDialect (io.confl...
是否有Classroom.Courses.Topics.get的示例，所以我可以使用现有的topicId调用Classroom.Courses.CourseWork.create?
本文介绍了是否有Classroom.Courses.Topics.get的示例，所以我可以使用现有的topicId调用Classroom.Courses.CourseWork.create?的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 我们学校正在尝试将所有课程作业在线转移.我们有八名老师将内容添加到一个班级，主要是手动而不是使用脚本.我有一个JavaSc...
我在哪里定义 topic.metadata.refresh.interval.ms?
本文介绍了我在哪里定义 topic.metadata.refresh.interval.ms?的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 我正在对 kafka 进行一些测试，希望很快将其放入我的生产堆栈中.我正在使用文件 kafka-console-producer.sh 和 kafka-console-consumer.sh 来测试 kafka 的功能...
我在哪里定义topic.metadata.refresh.interval.ms?
本文介绍了我在哪里定义topic.metadata.refresh.interval.ms?的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 我正在对kafka进行一些测试，并希望很快将其放入生产环境中.我正在使用文件 kafka-console-producer.sh 和 kafka-console-consumer.sh 来测试kafka的功能.I'm ...
JSON解析错误:无法构造io.starter.topic.Topic的实例
本文介绍了JSON解析错误:无法构造io.starter.topic.Topic的实例的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 我正在学习Spring Boot，我做了一个演示，但是当我发布添加对象的请求时，它不起作用！Im learning Spring Boot and I made a demo but when I POST a reques...
如何以编程方式创建jms Topic和TopicConnectionFactory?
本文介绍了如何以编程方式创建jms Topic和TopicConnectionFactory?的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 任何人都知道您是否可以以编程方式创建主题及其连接吗?当前，我使用glassfish管理实用程序来创建主题及其连接工厂.如果我无法在代码中创建它，那么glassfish/openmq是否具有默认主题以及可以使用的conn...
如何使用Events Push插件动态创建新的Topic
本文介绍了如何使用Events Push插件动态创建新的Topic的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 为了创建一个事件的主题，我需要在conf / MyEvents.groovy文件中声明如下： To create a topic for an event I need to declare this in my conf/MyEvents.gr...
IllegalStateException: Topic(s) [XYZ] is/are not present and missingTopicsFatal 为真
本文介绍了IllegalStateException: Topic(s) [XYZ] is/are not present and missingTopicsFatal 为真的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 我有一个 Spring Boot 应用程序，它尝试从本地 Kafka 主题中读取数据.I have a Spring Boot app ...