《apache》专题

我试图编写一个流作业，它将数据流下沉到postgres表中。为了提供完整的信息，我的工作基于以下文章:https://tech.signavio.com/2017/postgres-flink-sink，这些文章建议使用JDBCoutputFormat。 所以我的问题是：我错过了什么吗？我应该将插入的行提交到某个地方吗？ 向你致意，伊格内修斯

我用Cassandra Sink写了一个Flink应用程序。一切都工作得很好，但是没有生成各种度量标准（如Latency、NumRecordsInPerSecond，等等）。 我真的需要Flink提供的延迟度量，但它没有显示任何数据。 我需要做一些其他的事情来让其他的图表工作吗？尤其是潜伏期。

我已经为运行在localhost上的节点服务器创建了一个反向代理，以便可以通过HTTPS提供服务。 然而，当应用程序试图发出请求时，我会得到： 内容混合：“HTTPS://foo.com/”的页面通过HTTPS加载，但请求了不安全的XMLHttpRequestendpoint“http：//localhost:8888/graphql？query=%7bnotifications(userid)%

我在运行代码时遇到以下异常： 线程“main”java.lang.noClassDeffounderror:org/apache/spark/logging在java.lang.ClassLoader.DefineClass1(Native Method)，在java.security.secureClassLoader.DefineClass1(classLoader.java:760)，在ja

下面是我正在使用的代码：

我目前正在使用Kafka listener设置Spring Boot应用程序。我试图只对消费者进行编码。对于producer，我现在正在从Kafka控制台手动发送消息。我举了一个例子：http://www.source4code.info/2016/09/spring-kafka-consumer-producer-example.html 我尝试将其作为Spring Boot应用程序运行，但无法

使用Spring for Apache Kafka或Spring AMQP，我可以实现消息发布/订阅。Spring云总线使用Kafka/rabbitmq来完成大致相同的事情，它们之间的区别是什么？

我有一个用Spring Boot构建的Camel应用程序。此应用程序使用ActiveMQ在两个系统之间传递消息。现在，我需要根据配置添加在ActiveMQ和Apache Kakfa之间选择作为消息代理的能力。 这是可以做到的吗？我对Kafka一无所知，但就我所阅读的内容而言，它的工作方式与ActiveMQ不同。 假设我的Camel应用程序向这样的队列发布消息： 我的申请表中有。yml此配置 我能用

我想知道Kafka选项重要性级别的区别。阿帕奇·Kafka有三个等级。 组织。阿帕奇。Kafka。普通。配置。配置定义。重要性 这三者有什么区别？

我们将收到处理该物品属于以下任何组的请求- Grp1- 我们收到3个A1、B1、C1请求。由于所有请求都属于同一组，因此应按顺序处理这些请求（在提取下一个请求进行处理之前，应先完成当前请求） 我们收到了4个A1、A2、B2、B3请求，其中A2和B2请求属于同一组，因此应按场景1中所述顺序处理，A1和B3请求应并行处理，因为它们属于不同的组 因此，基本上应该并行处理来自不同组的请求。来自同一组的请求

我的理解是spring-kafka是为了与Kafka Client API交互而创建的，后来，spring-cloud-stream项目是为了“构建与共享消息系统连接的高度可扩展的事件驱动微服务”而创建的，该项目包括几个绑定器，其中一个是允许与Kafka Stream API交互的绑定器： 所以我很清楚，如果我想与Kafka流API交互，我将使用Spring-Cloud-Stream方法和适当的绑

我正在使用Kafka Producer和RoundRobin分区器来处理一个有12个分区的主题。 代码可在此处找到https://github.com/apache/kafka/blob/2.8/clients/src/main/java/org/apache/kafka/clients/producer/RoundRobinPartitioner.java 我面临的问题是，这个分区程序让分区正确

阅读这篇关于主题分区中消息排序的文章：https://blog.softwaremill.com/does-kafka-really-guarantee-the-order-of-messages-3ca849fd19d2 允许在不设置最大值的情况下重试。航班请求。每连接到1可能会更改记录的顺序，因为如果将两个批发送到单个分区，第一个失败并重试，但第二个成功，则第二个批中的记录可能会首先出现。 根

我看到有很多指南，但我似乎仍然不能让它发挥作用。 > 我从https://maven.apache.org/download.cgi下载了apache-maven-3.5.4-bin.zip文件 我把它放在C:\program files\apache-maven-3.5.4中 “'MVN'不被识别为内部或外部命令、可操作程序或批处理文件。” 我做错了什么？