小编1Z1*_*Z10的帖子

我正在寻找一种使用kafkacat. 是否可能或唯一的方法是通过此处列出的脚本？

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic mytopic

When uploading a csv file and a JSON object at the following endpoint

@PostMapping(value = "dataset/rows/query", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
Mono<List<Integer>> getRowsByQuery(@RequestPart("dataset") Mono<FilePart> file, 
                                   @RequestPart("query") QueryDTO query){
    return Mono.just(new ArrayList<>());
}

I get the following error:

2020-12-17 12:25:05.142 ERROR 195281 --- [or-http-epoll-3] a.w.r.e.AbstractErrorWebExceptionHandler : [d418565e-17]  500 Server Error for HTTP POST "/dataset/rows/query"

org.springframework.core.io.buffer.DataBufferLimitException: Part headers exceeded the memory usage limit of 8192 bytes
    at org.springframework.http.codec.multipart.MultipartParser$HeadersState.onNext(MultipartParser.java:360) ~[spring-web-5.3.1.jar:5.3.1]
    Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Error has been observed at the following site(s):
    |_ checkpoint ? org.springframework.boot.actuate.metrics.web.reactive.server.MetricsWebFilter [DefaultWebFilterChain] …

几天之内,我一直在努力解决这个问题而没有真正理解它背后的原因.使用Liquibase,PostgreSQL和H2DB(用于测试).Liquibase在使用PostgreSQL时运行正常,但是一旦我需要运行在H2DB上执行的测试,它们就会因为$ {now}属性的解析异常而失败,就好像它没有被有效值替换一样(至少我是这么认为的).这是我创建表的变更集:

<?xml version="1.0" encoding="utf-8"?>
<databaseChangeLog
    xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
    xmlns:ext="http://www.liquibase.org/xml/ns/dbchangelog-ext"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-3.5.xsd
                        http://www.liquibase.org/xml/ns/dbchangelog-ext http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-ext.xsd">

    <property name="now" value="now()" dbms="h2"/>

    <property name="now" value="current_timestamp" dbms="postgresql"/>

    <property name="floatType" value="float4" dbms="postgresql, h2"/>
    <property name="floatType" value="float" dbms="mysql, oracle, mssql"/>

    <!--
        Added the entity Container.
    -->
    <changeSet id="20180424154826-1" author="developer">
        <createTable tableName="container">
            <column name="id" type="bigint" autoIncrement="${autoIncrement}">
                <constraints primaryKey="true" nullable="false"/>
            </column>
            <column name="name" type="varchar(255)">
                <constraints nullable="false" />
            </column>

            <column name="description" type="varchar(2000)">
                <constraints nullable="true" />
            </column>

            <column name="container_type" type="varchar(255)">
                <constraints nullable="true" />
            </column>

            <column name="created" type="timestamp">
                <constraints nullable="true" />
            </column>
        </createTable> …

在检查地图是否已经具有对象作为键时遇到一些麻烦。

例如

const myMap: Map<MyObject1, MyObject2> = new Map<MyObject1, MyObject2>();

我还在MyObject1类中定义了一个equals函数

equals(other: ThreatAgentMgm): boolean {
    return other.id === this.id;
}

但myMap.has(myObject1)总是错误的。我读了has方法基于===运算符，我应该在MyObject1类中定义其他内容吗？

我有以下html代码

<mat-tab label="Regular" (selectChange)="tabClick()"
                 (click)="tabClick()">
   <h1>Some more tab content</h1>
</mat-tab>

这就是功能，

tabClick(){
    console.log('Tab clicked...');
}

但它似乎没有被称为，为什么？以上任何事件均未触发？

必须从 Docker 化的 Spring-Boot 应用程序与 Kafka 进行通信，\n我能够工作的唯一选择就是对 Kafka 进行 Docker 化。

这是我的docker-compose-yml：

version: \'3.5\'\nservices:\n  zookeeper:\n    image: wurstmeister/zookeeper\n    ports:\n      - "2181:2181"\n    networks:\n      - kafka-network\n  kafka:\n    image: wurstmeister/kafka\n    ports:\n      - "9092:9092"\n    networks:\n      - kafka-network\n    environment:\n      KAFKA_ADVERTISED_HOST_NAME: kafka\n      KAFKA_AUTO_CREATE_TOPICS_ENABLE: \'true\'\n      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181\n    depends_on:\n      - zookeeper\n    volumes:\n      - /var/run/docker.sock:/var/run/docker.sock\nnetworks:\n  kafka-network:\n    name: kafka-network\n

这样我就可以使用 url kafka:9092从kafka 网络上的另一个容器连接到 Kafka 代理

version: \'3.5\'\nservices:\n  zookeeper:\n    image: wurstmeister/zookeeper\n    ports:\n      - "2181:2181"\n    networks:\n      - kafka-network\n  kafka:\n    image: …