Edge Cases and Advanced Scenarios

This document covers edge cases and advanced scenarios across all Kafka APIs.

Producer Edge Cases

See clients/producer.md for detailed coverage of:

• Null keys and values
• Very large batches
• Broker failures
• Transaction timeouts
• Partition leader changes
• Buffer exhaustion scenarios
• Record size limits

Consumer Edge Cases

See clients/consumer.md for detailed coverage of:

• Null keys and values
• Empty poll results
• Duplicate records
• Partition assignment changes
• Consumer group rebalance during processing
• ShareConsumer record lock expiration
• Delivery count overflow

Streams Edge Cases

See streams/dsl.md and streams/state-stores.md for:

• Null values in aggregations
• Late arriving records
• Empty windows
• State store migration
• Querying windowed stores
• Iterator lifecycle management

Admin Edge Cases

See clients/admin.md for:

• Concurrent operations
• Partial batch failures
• Consumer groups in rebalancing
• Deleting active groups
• ACL operations on non-existent resources

Connect Edge Cases

See connect/connectors.md and connect/data-schemas.md for:

• Offset management
• Schema evolution
• Transaction boundaries
• Null and optional fields
• Complex nested structures

Security Edge Cases

See common/security.md for:

• Certificate expiration
• Multi-mechanism authentication
• OAuth token refresh
• Credential rotation

Error Handling Edge Cases

See common/errors.md for:

• Network partition scenarios
• Broker failure scenarios
• Rebalance scenarios
• Transaction fencing
• Serialization errors with corrupt data