Consumer/ConsumerGroup stream.next() does not receive new messages

Just follow the examples. The consumer app starts and receives all the relevant messages via stream.next() loop. Then the producer sends more messages, but the consumer loop does not trigger. Is that the expected behavior?