SessionWindows type base class

Hey there, I was working on some KTable API related stuff and noticed something a little bit confusing. For class SessionWindows that defines the spec for a session window, it doesn't have a base class: public final class SessionWindows On the other hand, the `TimeWindows` class is subclass of

Jenkins build is back to normal : kafka-2.1-jdk8 #89

See

Build failed in Jenkins: kafka-2.0-jdk8 #206

See Changes: [wangguoz] MINOR: standby task test throughput too low 2.0 (#6062) -- [...truncated 889.29 KB...] kafka.zk.ReassignPartitionsZNodeTest > testDecodeValidJson PAS

Re: [EXTERNAL] - Re: [DISCUSS] KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer

Hi ChienHsing Wu, Maybe I'm misunderstanding something, but I'm not sure I see the need for a KIP here. You can just set max.partition.fetch.bytes to a very small value. That will cause Kafka to fetch only one message from each partition. This will give you the round robin behavior you want.

Build failed in Jenkins: kafka-trunk-jdk8 #3273

See Changes: [wangguoz] MINOR: Increase throughput for VerifiableProducer in test (#6060) [wangguoz] MINOR: Bump admin client retries for creating repartition topics (#6063) [wangguoz] MINOR: Add test demonstr