Manually stopped partitions should not be resumed by reactor-kafka

[bsideup]

Hi!

Observed behaviour:
If user manually stops some of the assigned partitions, PollEvent will resume it on a next flow control action:

reactor-kafka/src/main/java/reactor/kafka/receiver/internals/DefaultKafkaReceiver.java

Lines 475 to 481 in 7a1bab3

	if (requestsPending.get() > 0 && !awaitingTransaction.get()) {
	if (partitionsPaused.getAndSet(false))
	consumer.resume(consumer.assignment());
	} else {
	if (!partitionsPaused.getAndSet(true))
	consumer.pause(consumer.assignment());
	}

Expected behaviour:
Manually controlled partitions should be respected and not affected by PollEvent's logic.

Version:
Both 1.0.0.RELEASE and latest master

[Delorien84]

I am voting for that issue. I want to just fill same issue. Currently I implemented ugly workaround, that check incoming records and re-pause and seek the partition when additional messages comes, when it should not.

[garyrussell]

Fixed by #199 last year.