StackOverflow Questions for Tag: kafka-streams-scala

Amitb

Reputation: 462

Using Kafka Streams with MSK Express brokers - internal topic creation

amazon-web-servicesapache-kafkaapache-kafka-streamsaws-msk

Score: 0

Answers: 0

alext

Reputation: 812

Kafka Streams default value for session.timeout.ms?

apache-kafka-streams

Score: 1

Answers: 0

filpa

Reputation: 3654

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

apache-kafkaapache-kafka-streams

Score: 0

Answers: 0

Abe

Reputation: 706

default max.compaction.lag.ms for changelog

apache-kafkaapache-kafka-streams

Score: 0

Answers: 0

Jonah Neeley

Reputation: 1

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

javajunitapache-kafka-streams

Score: 0

Answers: 0

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

javaspring-bootspring-kafkaapache-kafka-streams

Score: 0

Answers: 0

MOHAMMAD SHADAB

Reputation: 1

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

apache-kafkaapache-kafka-streamsapache-kafka-connectkafka-producer-apihelidon

Score: 0

Answers: 1

Hariharan Janakiraman

Reputation: 1

Stream processing with flink using BroadcastStream is providing inconsistent results

apache-kafkaapache-flinkapache-kafka-streamsflink-streaming

Score: 0

Answers: 1

AustinTX

Reputation: 1352

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

apache-kafkaavroapache-kafka-streamsconfluent-schema-registry

Score: 2

Answers: 1

basit

Reputation: 11

Kafka Connect JDBC Source Connector Re-fetching Last Record Repeatedly

apache-kafkakafka-consumer-apiapache-kafka-streamsapache-kafka-connectconfluent-platform

Score: 0

Answers: 0

zifeng yang

Reputation: 1

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

apache-kafkaapache-kafka-streams

Score: -1

Answers: 0

KarlP

Reputation: 5191

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

javaapache-kafkaapache-kafka-streams

Score: 0

Answers: 1

rwachter

Reputation: 33

Kafka Streams partition assignment problem with multiple topics and scaling

apache-kafkaapache-kafka-streams

Score: 1

Answers: 1

Andy

Reputation: 147

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

apache-kafkaapache-kafka-streamsspring-cloud-stream-binder-kafka

Score: 1

Answers: 2

edi

Reputation: 937

Cannot compile maven project

javamavenapache-kafkaapache-kafka-streams

Score: 1

Answers: 2

Alex H

Reputation: 31

Inconsistent Results with KStream-KTable Join Under Load

apache-kafkaspring-kafkakafka-consumer-apiapache-kafka-streams

Score: 2

Answers: 2

Martinus Elvin

Reputation: 1

Kafka Streams Consumer Constantly Rebalance over 100k tps

javaperformanceleft-joinspring-kafkaapache-kafka-streams

Score: 0

Answers: 0

Saikat

Reputation: 558

Analyzing Kafka Streams For Anomaly Detection

javaapache-kafkaspring-kafkaapache-kafka-streams

Score: 0

Answers: 0

PAA

Reputation: 12063

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

javaapache-kafkaapache-kafka-streams

Score: 2

Answers: 1

ceb

Reputation: 39

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

apache-kafkaapache-kafka-streams

Score: 1

Answers: 1

PreviousPage 1Next