There is no issue if you call `poll()` is all partitions are paused. If
fact, if you want to make sure that the consumer does not fall out of
the consumer group, you must call `poll()` in regular interval to not
hit `max.poll.interval.ms` timeout.
-Matthias
On 10/24/18 10:25 AM, pradeep s
Pause and resume is required since i am running a pod in kubernetes and i
am not shutting down the app
On Tue, Oct 23, 2018 at 10:33 PM pradeep s
wrote:
> Hi,
> I have a requirement to have kafka streaming start at scheduled time and
> then pause the stream when the consumer poll returns empty
+1 (non-binding)
Verified signatures and checksums of release artifacts
Performed quickstart steps on rc artifacts (both scala 2.11 and 2.12) and
one built from tag 2.1.0-rc0
Andras
On Wed, Oct 24, 2018 at 10:17 AM Dong Lin wrote:
> Hello Kafka users, developers and client-developers,
>
>
Hi friends,
however I suggest you to be aware of the contents of the mail by Manikumar
dated October 4 @ 16:44 (see mail list archive):
"Deprecated scala consumers/producers are removed from 2.0 release. Old
consumer related options are removed from /kafka-consumer-groups.sh tool." ...
Best,
Hello All.
I'm trying to setup the KAFKA cluster with transactions and
authorization enabled.
I use "spring-kafka" integration. Here is my code in Java:
@Bean
public DefaultKafkaProducerFactory createDefaultKafkaProducerFactory(
KafkaProperties kafkaProperties,
Hello Kafka users, developers and client-developers,
This is the first candidate for feature release of Apache Kafka 2.1.0.
This is a major version release of Apache Kafka. It includes 28 new KIPs and
critical bug fixes. Please see the Kafka 2.1.0 release plan for more
details:
