Hi, folks,
KIP-562(KAFKA-9445) already merged three days ago.
I have updated KIP-216 to reflect the KIP-562.
The main change is to introduce a new exception
`InvalidStateStorePartitionException`, will be thrown when user requested
partition not available.
Please take a look and any feedback is
Hi all,
You all have good points!
I took a look, and I thought it over. After some thinking, it appears the
main point of contention is whether or not we can support emit on change
for stateless operations. I agree with John in that we probably should
restrict ourselves to materialized KTables:
Rohit Agrawal created KAFKA-9493:
Summary: Error after some time in Kafka on Kubernetes with PVC
Key: KAFKA-9493
URL: https://issues.apache.org/jira/browse/KAFKA-9493
Project: Kafka
Issue
Rajini Sivaram created KAFKA-9492:
-
Summary: ProducerResponse with record-level errors throw NPE with
older client version
Key: KAFKA-9492
URL: https://issues.apache.org/jira/browse/KAFKA-9492
Jason Gustafson created KAFKA-9491:
--
Summary: Fast election during reassignment can lead to replica
fetcher failures
Key: KAFKA-9491
URL: https://issues.apache.org/jira/browse/KAFKA-9491
Project:
