python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - apache-kafka-streams

Using Spring Cloud Stream Kafka Streams with Avro input/output with nativeEncoding/decoding=false

We're testing the use of Kafka Streams via Spring Cloud Stream function support with Avro input/output records, but setting nativeEncoding=false and nativeDecoding=false in order to use a custom Messa...
test-img

José María Lora

spring-boot

apache-kafka

apache-kafka-streams

spring-cloud-stream

spring-cloud-stream-binder-kafka

Votes: 0

Answers: 1

Latest Answer

For Kafka Streams binder in Spring Cloud Stream, we recommend using native decoding/encoding with Serdes unless you have strong reasoning for relying on the message conversion approach. What is the us...
test-img

sobychacko

Is it possible to make csv file using records from KAFKA STREAMS within a time frame?

I'm trying to send data records from Kafka topic using Kafka Streams using SCALA. After each 100 record, it should make a csv. Is it possible without use of Kafka connect?? UPDATE : I'm able to make c...
test-img

Anish Aravindan

scala

apache-kafka

kafka-consumer-api

apache-kafka-streams

Votes: 0

Answers: 1

Latest Answer

Regarding the original question, yes, it is possible, assuming that the topic has exactly a multiple of the amount of lines in the file you want to limit by. E.g. You want to write files of 100 lines,...
test-img

OneCricketeer

Kafka Streams Lost Produced Messages

I'm using Kafka Streams with Spring Boot and after some aggregations I produce data to a new topic. When I consume records (with kafka-console-consumer) from this topic at the first time all messages ...
test-img

Palamariuk Maksym

apache-kafka

apache-kafka-streams

Votes: 0

Answers: 0

Stateful Aggregations with Apache Kafka Streams

I want to use Kafka Streams to perform stateful aggregations. The use-case is that we are getting a stream of events, which we want to store until we get a specific event, at which point we will perfo...
test-img

Aditya Chandla

apache-kafka

apache-kafka-streams

spring-kafka

Votes: 0

Answers: 0

Posts

Questions

Blogs

Jobs