草庐IT

emqx_plugin_kafka

全部标签

java - 来自不同 maven 模块的同名文件不能共存于使用 maven assembly-plugin 创建的 jar 文件中

如果两个文件在两个不同的maven-modules中具有不同的内容但同名的文件,它们都放在一个jar文件中,带有ma​​venassembly-plugin,只有一个文件最终成为.jar文件的一部分。问题:在构建jar文件时,有没有办法确保将文件的内容组装成一个文件?我显然不想手动将信息放在一起,因为这是我试图通过将项目拆分为不同模块来避免的。编辑:我有一个我想保留的自定义程序集描述符,即使我开始使用另一个插件也是如此。这个描述符基本上排除了除英语之外的所有语言的资源和错误文本。jar-with-dependenciesjarfalse/truetrueruntime**/*Resou

java - 如何找到哪个消费者分配给kafka中主题的哪个分区?

我正在构建一个kafka管理器工具,我需要检查哪个主题分区分配给了消费者组中的哪个消费者。假设有消费者组group-A消费主题topic-A,n个分区,那么在group-A托管在不同的VM中。那么如何找到哪个分区分配给哪个消费者主机呢?在kafka0.9.1中可以吗?提前致谢。 最佳答案 您可以检查$KAFKA_HOME/bin/kafka-consumer-groups.sh的工作原理并将其实现集成到您的kafka管理器工具中,该工具将向您展示详细信息组所有者信息(例如,分区分配、滞后、IP)。小组主题分区CURRENT-OFFS

java - 如何使用 Java 中的结构化流从 Kafka 反序列化记录?

我使用Spark2.1。我正在尝试使用SparkStructuredStreaming从Kafka读取记录,反序列化它们并在之后应用聚合。我有以下代码:SparkSessionspark=SparkSession.builder().appName("Statistics").getOrCreate();Datasetdf=spark.readStream().format("kafka").option("kafka.bootstrap.servers",kafkaUri).option("subscribe","Statistics").option("startingOffset

java - 如何连接 Apache Kafka 和 Amazon S3?

我想使用KafkaConnect将来自Kafka的数据存储到存储桶s3中。我已经运行了一个Kafka的主题,并且创建了一个存储桶s3。我的主题有关于Protobuffer的数据,我尝试使用https://github.com/qubole/streamx我得到了下一个错误:[2018-10-0413:35:46,512]INFORevokingpreviouslyassignedpartitions[]forgroupconnect-s3-sink(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:280)[

java - Maven 3 : Failed to execute goal org. apache.maven.plugins :maven-archetype-plugin:2. 2:生成

我正在尝试使用测试ma​​venmvnarchetype:generate-DgroupId=org.sonatype.mavenbook-DartifactId=quickstart-Dversion=1.0-SNAPSHOT-DpackageName=org.sonatype.mavenbook-DarchetypeGroupId=org.apache.maven.archetypes-DarchetypeArtifactId=maven-archetype-quickstart-DarchetypeVersion=1.0-DinteractiveMode=false几分钟后,系统

java - 使用 maven-jaxb2-plugin 生成 java 源代码时,如何为集合启用 setter?

我正在使用maven-jab2-plugin从XSD模式生成POJO。我生成的类没有任何集合字段的setter。如何为集合生成setter?谁能解释默认不启用setter的原因? 最佳答案 使用Settersplugin包含在JAXB2-Basics中,如文档所述here.我已经复制粘贴了他们的用法示例(并对其进行了修改以专门显示setter):org.jvnet.jaxb2.maven2maven-jaxb2-plugin0.7.0generate-Xsettersorg.jvnet.jaxb2_commonsjaxb2-basi

java - 如何使用 license-maven-plugin

我想使用license-maven-plugin以便能够为我的项目生成许可证header。所以我有以下pom.xml:4.0.0org.foobar-parent1.0-SNAPSHOTpomBar:ParentApache2.0http://www.apache.org/licenses/LICENSE-2.0.txtrepoAbusiness-friendlyOSSlicenseMyCorp.http://www.mycorp.org/2014UTF-8apache_v2org.codehaus.mojolicense-maven-plugin1.6false**/*.javage

java - 在Java中创建之前检查kafka中是否存在主题

我正在尝试使用以下方法在kafka0.8.2中创建一个主题:AdminUtils.createTopic(zkClient,myTopic,2,1,properties);如果我在本地多次运行代码进行测试,则会失败,因为主题已经创建。有没有办法在创建主题之前检查主题是否存在?TopicCommandapi似乎没有为listTopics或describeTopic返回任何内容. 最佳答案 您可以使用kakfa-client版本0.11.0.0的AdminClient示例代码:Propertiesconfig=newProperties

java - 添加附加路径到 exec-maven-plugin

我想向exec-maven-plugin添加一个额外的类路径。除了%classpath之外,我还想添加一个额外的路径到包含资源的目录(/Users/kornp/resources)。目前,我的pom看起来像这样:org.codehaus.mojoexec-maven-plugin1.1.1javaruntime%classpath:/Users/kornp/resourcesorg.drrabbit.maventest.App我该如何配置? 最佳答案 我在源文件夹之外的特定目录中有一些配置文件。所以我为我的pom.xml文件定义了额

java - 在 SWT 中使用 Maven tycho-p2-plugin

如何使用EclipseP2存储库和Maventycho-p2-plugin构建SWT应用程序? 最佳答案 您可以为“目标平台配置”插件定义目标环境。无论您正在为多个环境构建RCP或功能,您都可以让您的功能包含这些主机的swt片段。org.eclipse.tychotarget-platform-configuration${tycho-version}p2linuxgtkx86win32win32x86solarisgtksparcfeature.xml中的代码段 关于java-在SWT