Kafka Streams as table Patch log not full Post

文章/答案/技术大牛

发布

1回答

apache-kafka、apache-kafka-streams、ksqldb

新想法:使用Kafka Streams和KSQL来达到相同的目标。所有服务都将它们的输出写入结果主题，该主题形成了一个更改日志Kstream，我们可以在KSQL中查询已完成的条目。

浏览 9提问于2019-07-12得票数 0

1回答

使用Spring Cloud Stream上的自定义serde序列化聚合状态存储时出错

apache-kafka-streams、spring-cloud-stream、hive-serde

Long, GenericRecord>, KStream<String, MyCustomJavaClass>> joinAndAggregate() { .join(table, (streamKey, streamValue) -> (Long) streamValue.get-0.consumer.key-serde: io.confluent.kafka.<

浏览 82提问于2020-05-20得票数 1

回答已采纳

2回答

在gradle中找不到测试任务的方法useJUnitPlatform

java、gradle

packages.confluent.io/maven/'} testLogging { implementation 'org.apache.kafka:kafka-clients:1.0.0-cp1' implementation'

浏览 0提问于2018-08-24得票数 14

回答已采纳

1回答

创建的表和流未显示为主题

apache-kafka、confluent-platform、ksqldb

正在发生的事情的简要介绍： ksql> CREATE TABLE RTSHTABLE (primaryKey BIGINT, secondaryKey BIGINT) WITH (KAFKA_TOPIC= 'rtsh', VALUE_FORMAT='JSON', KEY='primaryKey'); ------------------------------ Ta

浏览 16提问于2019-04-16得票数 0

回答已采纳

3回答

使用Kafka流聚合流数据

apache-kafka、apache-kafka-streams

我正在向Kafka生成消息，代码如下：props.put("bootstrap.servers", "localhost:9092");props.putString.format("{\"type\&quo

浏览 0提问于2016-10-19得票数 1

1回答

使用ksqldb-server在kafka中创建表

apache-kafka、confluent-platform、ksqldb

我正在尝试使用(Confluent) ksqldb-server通过其REST接口使用以下代码(bash脚本)创建一个kafka表： (xkey VARCHAR, \ WITH (KAFKA_TOPIC=\'sample-topic\', \ KEY=\'

浏览 18提问于2021-02-24得票数 0

回答已采纳

2回答

为什么Clickhouse不支持向kafka表添加列

apache-kafka、clickhouse

我在向ClickHouse中的Kafka队列添加列时遇到问题。我已经使用以下命令创建了一个表( .... some othercolumnsENGINE = Kafka()kafka_broker_list = '172.21.0.3:9092', kafka_topic_list = 'my_topic

浏览 4提问于2020-12-17得票数 1

1回答

线程"main“org.apache.kafka.streams.errors.InvalidStateStoreException:中的异常

java、apache-kafka、apache-kafka-streams

org.apache.kafka.common.serialization.Serdes;import org.apache.kafka.streams.StreamsBuilder;import org.apache.kafka.streams.

浏览 0提问于2019-07-12得票数 0

1回答

在我的公司，我们广泛地使用Kafka，但是我们一直使用关系数据库来存储几个中间转换和聚合的结果，因为容错原因。现在，我们正在探索卡夫卡流作为一种更自然的方式来做到这一点。KTable来阅读.代码如下所示KTable<String, String> kTable = builder.table("input-topic"); kTable.toStream().foreach((K,V) -> client.post</

浏览 0提问于2018-05-09得票数 3

回答已采纳

1回答

应用程序无法启动，因为kafka* streams存储正在等待运行*

java、spring-boot、apache-kafka、apache-kafka-streams

我有一个使用kafka streams的spring boot应用程序(kafka docker镜像：wurstmeister/kafka:2.12-2.1.1，kafka依赖：org.apache.kafka:kafka-streams:2.4.1)。在该应用程序创建KTable之后，如下所示： streamsBuilder.table("my-topic", Consumed.with(Serdes.

浏览 1提问于2020-05-22得票数 0

2回答

java.lang.NoClassDefFoundError:无法在Windows 10上初始化类org.rocksdb.Options

java、spring、docker、apache-kafka、rocksdb

服务启动后，将为每个kafka线程抛出异常：线程“线程”中的异常:无法在org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:128) at org.apache.kafka.streams.state.internals.RocksDBStore.init(RocksDBStore.java:185) at org.apache.kafka.streams.st

浏览 0提问于2019-01-10得票数 1

1回答

如何捕获不符合kafka流加入条件的kafka记录？

join、apache-kafka、apache-kafka-streams

Kafka流会静默跳过没有连接匹配的记录。有没有什么方法可以将这些记录发送到不同的主题，以便稍后处理它们？builder = new StreamsBuilder(); vehicleStream.join(vinMappingTable, (vehicleMsg, vinInfo) -> {

浏览 12提问于2019-06-20得票数 1

回答已采纳

1回答

为什么maven给我这个Scala错误执行干净安装

scala、maven、intellij-idea、build、package

我似乎找不出为什么package org.apache.kafka.streams.scala的maven会“考虑”scala包。我通常使用sbt，但这次我必须使用maven。任何帮助都将不胜感激。[ERROR] This symbol is required by 'value com.lightbend.kafka.scala.streams.StreamsBuilderS.consumed'of org.apache.kafka.streams.of org.a

浏览 0提问于2018-09-12得票数 1

回答已采纳

1回答

Gradle没有考虑到依赖关系锁文件。

gradle、dependencies、locking

.+' implementation 'org.apache.kafka:kafka-streams:2.6.+' implementation 'com.fast

浏览 2提问于2021-01-18得票数 0

回答已采纳

3回答

将图像保存在公共文件夹中，而不是存储laravel 5

php、sql、database、image、laravel

下面是我的简单代码Route::get('pic',function (){}); //save format //save full</em

浏览 1提问于2017-03-03得票数 21

回答已采纳

3回答

如何调试在发生ajax事件时启动的php

php、ajax

php $encoded = json_encode($patchData); } { echo "Error updating table: " . mysqli_error($con$( "#" + this.id

浏览 5提问于2013-10-19得票数 0

1回答

如何定义StreamsBuilderFactoryBean的两个实例

spring、apache-kafka、apache-kafka-streams、spring-kafka

我是Spring Kafka的新手。(KafkaStreamsConfig.class); private String applicationId我像这样使用"commonDSLBuilder“public class BindPostDSL { @Bean(name

浏览 2提问于2018-08-06得票数 1

回答已采纳

2回答

KTable不对具有相同密钥的传入记录执行重复数据消除

apache-kafka、spring-kafka、spring-cloud-stream、spring-cloud-stream-binder-kafka

: bindings: consumer:$StringSerde serde: org.apache.kafka.common.serialization.Serdes$StringSerde 根据spring cloud stream kafka stream关于状态存储的documentation，我将上面的物化视图添加为

浏览 38提问于2021-05-07得票数 1

回答已采纳

1回答

如何在kafka物化视图中访问头部信息？

spring、spring-cloud-stream、spring-cloud-stream-binder-kafka

@StreamListener} cloud: kafka: binder:$StringSerde value.serde: org.apache.kafka.comm

浏览 13提问于2020-03-30得票数 0

1回答

java.lang.VerifyError:未初始化的对象存在于向后分支Kafka* Win-10上。*

apache-kafka

[2020-07-27 16:08:05,144] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistrationd119 04b9 0076 0100 c000 7801 3a04 013a Stackmap Table: same_frame(@11)

浏览 3提问于2020-07-27得票数 0

回答已采纳

点击加载更多