Release v2.8.1.0 · streamnative/kop

Features

Add test framework for Kafka clients of different versions #605
Only allow topics under specific namespaces to be listed #636
Support Kafka consumer for Pulsar format messages when entryFormat is kafka #632
Add Authorizer used for authorization #657
Allow setting listener name for topic lookup and optimize the lookup #646
Add fetch down converted when entryFormat=kafka #660
Add authorization to produce and consume #671
Skip getting Kafka advertised address from ZK when lookup with listenerName #670
Support KoP for v0 version of SASL_HANDSHAKE #676
Add commit Offset tests for Kafka clients of different versions #686
Support non-partitioned topics #690
Support minBytes and maxWait parameters in the fetch request #702
Support delay close on authentication failure #709
Support close Idle connections when timeout #714

Fix some corner cases not handled well for CreateTopics request #592
Fix group id z-node not updated for the same client id #607
Fix deadlock caused by KafkaTopicConsumerManager #620
Fix KoP will cause Kafka Errors.REQUEST_TIMED_OUT when consume multi TopicPartition in one consumer request #654
Remove closed KafkaTopicConsumerManager from cache #659
Avoid creating a lot of MetadataCache instances #663
Handle unsupported ApiVersionsRequest when channelPrepare #689
Fix go sarama client with v0 handshake can successfully authenticate but will fail to fresh metadata #697
Fix many non-durable cursors created on a topic with multiple groups #695
Fix import wrong authentication exception #704

Create Kafka namespace if missing #693
Optimize the protocol handler start #627
Use pooled direct memory allocator when decoding Pulsar entry to Kafka records #673
Refactor APIs to allow access from the Proxy module #710
Add support for passing OriginalPrincipal from Proxy #711