StackOverflow Questions for Tag: apache-kafka-streams

alext
alext

Reputation: 812

Kafka Streams default value for session.timeout.ms?

Score: 1

Views: 19

Answers: 0

Read More
filpa
filpa

Reputation: 3654

Does stream time in a windowed table advance per key or globally?

Score: 0

Views: 8

Answers: 0

Read More
Abe
Abe

Reputation: 696

default max.compaction.lag.ms for changelog

Score: 0

Views: 16

Answers: 0

Read More
Jonah Neeley
Jonah Neeley

Reputation: 1

Kafka Streams Topology Test Driver - Records produced with suppressed() but not emitStrategy()

Score: 0

Views: 35

Answers: 0

Read More
Aindrail Santra
Aindrail Santra

Reputation: 21

Invalid topology: Topology has no stream threads and no global threads, must subscribe to at least one source topic or global table. Aindrail

Score: 0

Views: 24

Answers: 0

Read More
MOHAMMAD SHADAB
MOHAMMAD SHADAB

Reputation: 1

In Helidon SE 4.1.6 , how to send data to a specific partition using kafka producer

Score: 0

Views: 21

Answers: 1

Read More

Stream processing with flink using BroadcastStream is providing inconsistent results

Score: 0

Views: 46

Answers: 1

Read More
AustinTX
AustinTX

Reputation: 1352

Error registering Avro schema: Register schema operation failed while writing to the Kafka store; error code: 50001

Score: 2

Views: 8967

Answers: 1

Read More
basit
basit

Reputation: 11

Kafka Connect JDBC Source Connector Re-fetching Last Record Repeatedly

Score: 0

Views: 12

Answers: 0

Read More
zifeng yang
zifeng yang

Reputation: 1

Kafka streams sink message num as the program runs more and more

Score: -1

Views: 23

Answers: 0

Read More
KarlP
KarlP

Reputation: 5181

Kafka Streams KTable-KTable foreign key join emits null even if right side is empty

Score: 0

Views: 28

Answers: 1

Read More
rwachter
rwachter

Reputation: 33

Kafka Streams partition assignment problem with multiple topics and scaling

Score: 1

Views: 42

Answers: 1

Read More
Andy
Andy

Reputation: 147

NullPointerException + org.apache.kafka.common.header.internals.RecordHeader.key

Score: 1

Views: 989

Answers: 2

Read More
edi
edi

Reputation: 937

Cannot compile maven project

Score: 1

Views: 1185

Answers: 2

Read More
Alex H
Alex H

Reputation: 31

Inconsistent Results with KStream-KTable Join Under Load

Score: 2

Views: 75

Answers: 2

Read More
Martinus Elvin
Martinus Elvin

Reputation: 1

Kafka Streams Consumer Constantly Rebalance over 100k tps

Score: 0

Views: 41

Answers: 0

Read More
Saikat
Saikat

Reputation: 558

Analyzing Kafka Streams For Anomaly Detection

Score: 0

Views: 44

Answers: 0

Read More
PAA
PAA

Reputation: 12015

org.apache.kafka.common.errors.UnsupportedVersionException: The node does not support GET_TELEMETRY_SUBSCRIPTIONS

Score: 2

Views: 2236

Answers: 1

Read More
ceb
ceb

Reputation: 39

Is there any side effect of setting repartition.purge.interval.ms config with too high value in order to prevent purge?

Score: 1

Views: 29

Answers: 1

Read More
Sumit Baurai
Sumit Baurai

Reputation: 261

Kafka Stream KTable Foreign Key Left join outputs more tombstones than expected

Score: 1

Views: 36

Answers: 1

Read More
PreviousPage 1Next