|
Stream partitions and repartitioning topics for state store lookups
|
|
4
|
503
|
14 June 2022
|
|
Handle different retention periods for a state-store depending on the message payload
|
|
1
|
819
|
10 June 2022
|
|
Some logging timestamps of kafka libraries are in the future
|
|
0
|
456
|
8 June 2022
|
|
Average for each window
|
|
3
|
486
|
7 June 2022
|
|
Mediumint unsigned datatype showing in binary
|
|
2
|
499
|
2 June 2022
|
|
Not able to use Custom Class for Kafka Stream Serdes
|
|
1
|
634
|
2 June 2022
|
|
Long / Integer Serde won't output value - Kafka 3.2
|
|
1
|
521
|
31 May 2022
|
|
Kafka multi environment with the same topic name
|
|
1
|
488
|
30 May 2022
|
|
Syncgroup keeps on failing with message "The group began another rebalance" and it never ends
|
|
0
|
578
|
27 May 2022
|
|
Does kafka stream works well when there are one input topic and two sink processor node?
|
|
1
|
505
|
20 May 2022
|
|
Is Ktable a posible solution?
|
|
1
|
523
|
17 May 2022
|
|
Repeatable reads with interactive queries
|
|
7
|
525
|
12 May 2022
|
|
Importing test data from Control Center
|
|
0
|
495
|
3 May 2022
|
|
Missing partitions in global stream thread
|
|
4
|
524
|
29 April 2022
|
|
Question regarding thread-local variables within a stream processing topology
|
|
2
|
498
|
26 April 2022
|
|
Kafka Broker often shuts down
|
|
2
|
803
|
22 April 2022
|
|
Serdes Custom type in Kafka Streams
|
|
1
|
537
|
15 April 2022
|
|
Error messages 'schema.registry.url' was supplied but isn't a known config
|
|
2
|
819
|
13 April 2022
|
|
Split topology creation from presentation of resulting topics
|
|
5
|
551
|
10 April 2022
|
|
Mixing Processor API with Stream DSL
|
|
3
|
519
|
13 April 2022
|
|
Deployed Kafka in minikube; How to use python to produce/consume within and outside minikube?
|
|
1
|
620
|
5 April 2022
|
|
Kafka template not able to send topics when running through integration tests
|
|
3
|
491
|
5 April 2022
|
|
De-duplicator Using Kafka Streams
|
|
2
|
527
|
4 April 2022
|
|
Kafka Stream 101: Windowing and Event Timestamp
|
|
3
|
498
|
1 April 2022
|
|
Window expiration
|
|
3
|
652
|
29 March 2022
|
|
Understanding Aggregate KTables Subtractor
|
|
4
|
586
|
24 March 2022
|
|
Kafka state stores and at-least-once processing guarantee
|
|
2
|
630
|
21 March 2022
|
|
What is Kafka-ML
|
|
2
|
534
|
15 March 2022
|
|
Intermittent data loss under high volume with aggregation after map() or groupBy() (rekey, repartition) with log compaction enabled
|
|
0
|
530
|
8 March 2022
|
|
Aggregations on Windowed KTables
|
|
2
|
558
|
7 March 2022
|