《apache》专题

我有一个使用Apache FOP生成PDF文件的应用程序。一切都很好，除了生成的PDF中的西里尔字母。据我所知，我应该捆绑应用程序的西里尔字母的字体。 因此，我将应用程序设置如下:我在../src/main/resources/conf/fop . XML(PDF渲染器的默认设置)并像这样初始化FOP: fileLoader是我自己的读取文件的实用程序，XSLT由它加载，一切都很好。我尝试了另一种

任务非常简单：防止“donothyphenatethisextremelyword”在 的块内被连字符。我尝试过： 结果： 真的没有办法吗？任何帮助将不胜感激。

Quarkus是否有Apache Camel传奇的扩展？我尝试了一个将Spring靴与骆驼传奇一起使用的示例，但无法使其与Quarkus一起使用。 谢谢库纳尔

我在我的application.properties文件中定义了一个数据源： 但是，当我尝试运行我的camelway时，我得到了这个错误："在注册表中找不到bean：类型为：javax.sql.数据源的数据源"。我总是在Spring配置我的数据源，使用application.properties文件没有问题。 完整的错误日志： 我的骆驼路线： 编辑：我以编程方式添加了数据源，如下所示： 但是，现在

我试图使用Apache POI创建docx文档。但是，当我在Microsoft Word中打开创建的文档时，结果与用LibreOffice Writer打开时不同。我用表和交叉引用体验了这种行为。 我想知道是否有必要进行任何配置以将输出格式保存为微软Word格式。 例如，下面的代码创建一个docx文档，该文档包含一个具有2行2列的表：

我试图在聚合器完成后获得一个回复，但是我得到一个异常，我没有指定任何聚合器子项，但是当我指定一个。to（）endpoint我没有收到聚合结果。。。这可能吗？ 控制器： 聚合器：

我正在尝试向异步路由发送消息，但它不起作用。我刚刚在github上创建了一个项目来模拟这个问题

关于ApacheCamel的简短问题。我有以下场景，其中我的服务器接收jms消息，然后转换为csv文件，然后插入DB。为此，我有两个bean： xml2csv 我使用路由像： 当"路由"一个文件从-到，它是移动像一个消息？或者把问题放在不同的地方，ApacheCamel是否获取一个文件，将其包装为消息，并将其路由到bean或组件？ 我的理解是正确的还是错误的。

我试图使用Apache Beam将一些看起来像Json的数据流作为字符串写入BigQuery。数据是一个数组中的一个数组，由于不可能将嵌套数组写入Bigquery，所以我在主记录地址中创建了一个子记录Address_Instance。我需要帮助将我的嵌套记录写入BigQuery。 下面是我的数据的样子，以及我如何将其转换为Bigquery。 这就是我得到的错误： 下面是我的BigQuery模式的样

我有一个包含的数据流，看起来像。我想解析这些字符串并使用Apache Beam写入BigQuery表，但在写入重复字符串时出现错误。 以下是如何将字符串转换为: 下面是我的BigQuery模式的样子： 我已经设法使用Python为BigQuery表编写了一个类似的重复字符串，但无法使用Apache Beam来完成。我想我没有在中保存正确的键值对。我现在得到的错误是： 我需要关于如何保存一个类似的重

是否有一种方法可以使用Java SDK将任意的无模式JSON字符串转换为Apache Beam“行”类型？如果不是，是否可以从现有对象派生出一个Beam模式类型？ 我找到了JsonToRow和ParseJsons的文档，但它们需要提供模式或POJO类才能工作。我还发现，您可以将JSON字符串读入BigQuery TableRow，但似乎没有一种方法可以将TableRow转换为不需要已经有一个模式的

我正在使用Apache Beam的kafkaIO阅读一个主题，该主题在Confluent schema Registry中有一个avro模式。我可以反序列化消息并写入文件。但最终我想写给BigQuery。我的管道无法推断架构。我如何提取/推断模式并将其附加到管道中的数据，以便我的下游进程（写入BigQuery）能够推断模式？ 下面是我使用模式注册表url设置反序列化器的代码，以及我从Kafka读到

我正在尝试建立一个Apache Beam管道，该管道使用Apache Beam读取Kafka并写入BigQuery。我使用这里的逻辑筛选出一些坐标:https://www.talend.com/blog/2018/08/07/development-data-processing-job-using-apache-beam-streaming-pipeline/TLDR:主题中的消息的格式为id,

我正在尝试阅读使用apache Beam上的KafkaIO的多个kafka代理。偏移量管理的默认选项是kafka分区本身（不再使用来自kafka>0.9的zookeper）。使用此设置，当我重新启动作业/管道时，会出现重复和丢失记录的问题。 从我读到的内容来看，处理这一点的最佳方法是管理对外部数据存储的偏移量。用当前版本的apache beam和Kafkaio是否可以做到这一点？我现在使用的是2.

我使用apache beam和google dataflow Runner将数据从kafka流到BigQuery。我想利用insertId进行重复数据删除，我在google Docs中发现了这一点。但是，即使这些插入是在几秒钟内发生的，我仍然看到许多行具有相同的insertID。现在我在想，也许我没有正确地使用API来利用BQ提供的流式插入的重复数据删除机制。 我在beam中编写的代码如下所示：