Re: [new to kafka/java] Could I check whether a consumer has been closed?

Warning, though. `closed` is volatile. That shouldn't be too much of a problem, but if something is odd, make a mental bookmark. Consumer and KafkaConsumer should have a permanent isClosed() method. It sure would be handy. I'll put it as an issue. On Mon, May 29, 2023 at 8:47 PM Daniel Hinojos

Re: [new to kafka/java] Could I check whether a consumer has been closed?

As a stop-gap you can create something like the following. private static boolean isClosed(KafkaConsumer consumer) { try { var consumerClass = consumer.getClass(); Field field = consumerClass.getDeclaredField("closed"); field.setAccessible(true); return (Boolean) field.get(consumer); } catch (NoSu

[new to kafka/java] Could I check whether a consumer has been closed?

Hello everyone, my question is as the topic. In particular, when I have a Consumer object, I would like to see if https://github.com/apache/kafka/blob/2e1947d240607d53f071f61c875cfffc3fec47fe/clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java#L269 (kafka-clients-3.4.0) has been

Re: New To Kafka - How to Start

Hello . How about starting with 'quick start' ? https://kafka.apache.org/quickstart Thanks, Yu Watanabe On Tue, Aug 10, 2021 at 10:44 AM Gilbert Flores < gilbert.flo...@primergrp.com> wrote: > Hi, > > Good day to you. We are on the stage of exploring integration systems and > we have read and

New To Kafka - How to Start

Hi, Good day to you. We are on the stage of exploring integration systems and we have read and were introduced with Kafka thru Confluent. May I ask how we can start so we can start learning its capabilities? Hope to hear from you soon. Thanks, *Gilbert V. Flores* (gilbert.flo...@primergrp.com)

Re: New to Kafka

Hi Christian/Gaurav, I am looking for the user group meetings which is listed in the page https://cwiki.apache.org/confluence/display/KAFKA/Kafka+papers+and+presentations . User group meetings: - 1st Kafka user group meeting at LinkedIn, Jun. 14, 2012. video (part 1)

Re: New to Kafka

What exactly is outdated? Are you not able to grok Kafka with the current presentations? On Fri, Mar 11, 2016 at 1:01 AM, prabhu v wrote: > Hi, > > Can anyone please help me with the video presentations from Kafka experts? > > Seems the link provided in Kafka home page > > https://cwiki.apache.o

Re: New to Kafka

What u need prabhu from presentation, go to YouTube u will get presentation or search Kafka example u will get . On Mar 11, 2016 9:12 PM, "prabhu v" wrote: > Hi, > > Can anyone please help me with the video presentations from Kafka experts? > > Seems the link provided in Kafka home page > > https

New to Kafka

Hi, Can anyone please help me with the video presentations from Kafka experts? Seems the link provided in Kafka home page https://cwiki.apache.org/confluence/display/KAFKA/Kafka+papers+and+presentations is outdated.. Thanks in advance..

New to Kafka

Hi, Can anyone please help me with the video presentations from Kafka experts? Seems the link provided in Kafka home page https://cwiki.apache.org/confluence/display/KAFKA/Kafka+papers+and+presentations is outdated.. Thanks in advance..

Re: new to kafka

> I am fairly new to Kafka and working on building a stream processing system > using Kafka and Storm. > > I am looking for couple of references: > > 1. Reference architecture for Kafka hardware setup that will provide > complete redundancy and fault tolerance > 2. B

new to kafka

I am fairly new to Kafka and working on building a stream processing system using Kafka and Storm. I am looking for couple of references: 1. Reference architecture for Kafka hardware setup that will provide complete redundancy and fault tolerance 2. Benchmarking tool for Kafka setup -Alpesh

Re: New to Kafka: ZooKeeper and Client

Hi Chris, Kafka producer doesn't require zookeeper anymore, so you can simply connect to one of the brokers directly. Tim On Tue, Apr 29, 2014 at 9:23 AM, Chris Helck wrote: > I have a few newbie questions. I need to create a Producer that sends > messages to Kafka brokers. > > Does a machine

New to Kafka: ZooKeeper and Client

I have a few newbie questions. I need to create a Producer that sends messages to Kafka brokers. Does a machine running a Kafka client (Producer) need its own instance of ZooKeeper running? Or does is simply connect to the ZooKeeper that is running remotely with the Kafka brokers?