我正在使用 Kafka 在 Java 中使用消息。我想通过在本地机器上多次启动同一个应用程序来进行测试。当我启动时，我第一次能够开始使用来自主题的消息。当我启动第二个时，我得到：
Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group
并且不要从该主题中获取任何消息。如果我尝试启动更多它们，我会遇到同样的问题。
我用于 Kafka 的配置是
Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group
我有两个主题
spring:
kafka:
bootstrap-servers: kafka:9092
consumer:
auto-offset-reset: earliest
key-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer2
value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer2
properties:
spring.deserializer.key.delegate.class: org.springframework.kafka.support.serializer.JsonDeserializer
spring.deserializer.value.delegate.class: org.springframework.kafka.support.serializer.JsonDeserializer
spring.json.use.type.headers: false
listener:
missing-topics-fatal: false
以及不同类文件中的两个侦听器。
@KafkaListener(topics = SERVERS_KAFKA_TOPIC, id …通过在Eclipse/STS中使用"Spring Stater Project",我能够快速启动并运行Vaadin项目.我想通过Vaadin-Addon将图表添加到项目中.我谷歌搜索试图找到如何正确添加和使用Vaadin Chart插件到项目.但我很困惑,因为有很多"指南/教程",但很多不是春季启动或他们已过时或部分.
所以我正在寻找Vaadin-SpringBoot-VaadinChart-AddOn的完整指南/教程.
这是我到目前为止:
---- Pom文件----
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.aci</groupId>
<artifactId>oversight2</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>oversight2</name>
<description>Oversite</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.2.5.RELEASE</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
<!-- <dependency> -->
<!-- <groupId>com.vaadin</groupId> -->
<!-- <artifactId>vaadin-spring-boot</artifactId> -->
<!-- <version>1.0.0</version> -->
<!-- </dependency> -->
<dependency>
<groupId>com.vaadin</groupId>
<artifactId>vaadin-spring-boot-starter</artifactId>
<version>1.0.0.beta3</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.vaadin.addon</groupId>
<version>2.0.0</version>
<artifactId>vaadin-charts</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>com.vaadin</groupId>
<artifactId>vaadin-bom</artifactId>
<version>7.4.5</version>
<type>pom</type>
<scope>import</scope> …我需要Spring Boot的输出，Spring Data REST是XML，而不是JSON。我放入存储库中：
@RequestMapping(value="/findByID", method=RequestMethod.GET, headers = { "Accept=application/xml" }, produces="application/xml")
MyXmlAnnotatedObject findById(@Param("id") BigInteger id);
我还在pom依赖项中添加了以下内容
<dependency>
<groupId>com.fasterxml.jackson.dataformat</groupId>
<artifactId>jackson-dataformat-xml</artifactId>
<version>2.4.3</version>
</dependency>
<dependency>
<groupId>org.codehaus.woodstox</groupId>
<artifactId>woodstox-core-asl</artifactId>
<version>4.4.1</version>
</dependency>
但是当我尝试
http://localhost:9000/factset/search/findByID?id=18451
我仍然得到JSON。我真的为我的用户需要XML任何想法吗？
我的 s3 存储桶有数千个文件。它们都在同一个“文件夹”中。所以 s3 前缀是相同的。我想使用 python boto3 获取包含某个单词的文件名列表。我不希望 boto3 调用发回所有文件名并让客户端过滤掉名称。我看到了使用“yield”和“.filter”的示例，但它们正在接收所有文件并使客户端做很多工作。
为了帮助更好地理解，如果我使用 AWS CLI：
aws --profile test s3api list-objects-v2 --bucket mybucket --prefix tmp/ --output json --query "Contents[?contains(Key, 'foobar')]"
但我需要使用 boto3 发送请求，AWS 只需发送回带有“foobar”的文件名。