| Sean Clemmer |
Re: dumping JMX data |
Fri, 01 Apr, 00:02 |
| Kavitha Veluri |
connect kafka to database to push consumed data |
Fri, 01 Apr, 01:38 |
| Kavitha Veluri |
Kafka connect to database to push consumed data |
Fri, 01 Apr, 01:43 |
| Surendra , Manchikanti |
Re: Kafka connect to database to push consumed data |
Fri, 01 Apr, 02:49 |
| Ewen Cheslack-Postava |
Re: About AMQP connector and Kafka Connect framework |
Fri, 01 Apr, 04:20 |
| Gerard Klijs |
Re: dumping JMX data |
Fri, 01 Apr, 04:21 |
| Paolo Patierno |
RE: About AMQP connector and Kafka Connect framework |
Fri, 01 Apr, 07:23 |
| Mayur Mohite |
Multiple streaming jobs on the same topic |
Fri, 01 Apr, 07:42 |
| Achanta Vamsi Subhash |
Re: dumping JMX data |
Fri, 01 Apr, 08:11 |
| Yuto KAWAMURA |
Kafka Streams: context.forward() with downstream name |
Fri, 01 Apr, 08:20 |
| Kavitha Veluri |
Re: Kafka connect to database to push consumed data |
Fri, 01 Apr, 13:06 |
| Kalpesh Jadhav |
RE: Java API for kafka-acls.sh |
Fri, 01 Apr, 14:14 |
| Cees de Groot |
Re: ConsumerRebalanceFailedException with the kafka-console-consumer (bug?) |
Fri, 01 Apr, 15:45 |
| Cees de Groot |
Re: Wait for 0.10 or go to 0.9 first |
Fri, 01 Apr, 15:50 |
| Stevo Slavić |
New async producer NetworkClient endlessly trying to fetch metadata for deleted topics |
Fri, 01 Apr, 15:52 |
| Stevo Slavić |
Re: New async producer NetworkClient endlessly trying to fetch metadata for deleted topics |
Fri, 01 Apr, 16:04 |
| Cees de Groot |
Re: Multiple streaming jobs on the same topic |
Fri, 01 Apr, 16:09 |
| Ismael Juma |
Re: Wait for 0.10 or go to 0.9 first |
Fri, 01 Apr, 16:23 |
| Ismael Juma |
Re: New async producer NetworkClient endlessly trying to fetch metadata for deleted topics |
Fri, 01 Apr, 16:24 |
| Oleg Zhurakousky |
Deadlock when committing offsets |
Fri, 01 Apr, 16:29 |
| Stevo Slavić |
Re: New async producer NetworkClient endlessly trying to fetch metadata for deleted topics |
Fri, 01 Apr, 16:32 |
| R Krishna |
Re: Multiple streaming jobs on the same topic |
Fri, 01 Apr, 16:43 |
| Jay Kreps |
Re: Kafka connect to database to push consumed data |
Fri, 01 Apr, 17:00 |
| Guozhang Wang |
Re: KStream-KTable join with the KTable given a "head start" |
Fri, 01 Apr, 18:15 |
| Guozhang Wang |
Re: Kafka Streams: context.forward() with downstream name |
Fri, 01 Apr, 18:29 |
| Wang, Howard |
Listener for Lead broker change for topic partition in the 0.9.* consumer |
Fri, 01 Apr, 18:36 |
| Ryan Phillips |
Re: Listener for Lead broker change for topic partition in the 0.9.* consumer |
Fri, 01 Apr, 18:42 |
| Heath Ivie |
Log Retention: What gets deleted |
Fri, 01 Apr, 19:21 |
| Yifan Ying |
Kafka constant shrinking and expanding after deleting a topic |
Sat, 02 Apr, 02:46 |
| LeiNing |
Kafka performance issue |
Sat, 02 Apr, 04:25 |
| Ewen Cheslack-Postava |
Re: Partition size for topic |
Sat, 02 Apr, 05:07 |
| Oleg Zhurakousky |
Re: Partition size for topic |
Sat, 02 Apr, 17:22 |
| Alexis Midon |
Re: Upgrade path to 0.10.x |
Sun, 03 Apr, 06:32 |
| Ismael Juma |
Re: Upgrade path to 0.10.x |
Sun, 03 Apr, 07:47 |
| Yuto KAWAMURA |
Re: Kafka Streams: context.forward() with downstream name |
Sun, 03 Apr, 16:29 |
| Guozhang Wang |
Re: Upgrade path to 0.10.x |
Sun, 03 Apr, 21:25 |
| Guozhang Wang |
Re: Kafka constant shrinking and expanding after deleting a topic |
Sun, 03 Apr, 21:29 |
| Guozhang Wang |
Re: Kafka Streams: context.forward() with downstream name |
Sun, 03 Apr, 22:20 |
| Vineet Mishra |
Re: Kafka performance issue |
Sun, 03 Apr, 23:43 |
| Ratha v |
ProducerConfig - The configuration serializer.class = org.apache.kafka.common.serialization.StringSerializer was supplied but isn't a known config |
Mon, 04 Apr, 00:09 |
| Ewen Cheslack-Postava |
Re: About AMQP connector and Kafka Connect framework |
Mon, 04 Apr, 00:27 |
| Ratha v |
Re: ProducerConfig - The configuration serializer.class = org.apache.kafka.common.serialization.StringSerializer was supplied but isn't a known config |
Mon, 04 Apr, 00:42 |
| Ratha v |
If my producer producing, then why the consumer couldn't consume? it stuck @ poll() |
Mon, 04 Apr, 00:58 |
| Ratha v |
Does kafka version 0.9.0x use zookeeper? |
Mon, 04 Apr, 05:10 |
| Yuto KAWAMURA |
Re: Kafka Streams: context.forward() with downstream name |
Mon, 04 Apr, 05:48 |
| Gerard Klijs |
Re: Does kafka version 0.9.0x use zookeeper? |
Mon, 04 Apr, 05:49 |
| Lohith Samaga M |
New consumer API waits indefinitely |
Mon, 04 Apr, 05:51 |
| Ratha v |
Re: Does kafka version 0.9.0x use zookeeper? |
Mon, 04 Apr, 05:56 |
| Ratha v |
Re: New consumer API waits indefinitely |
Mon, 04 Apr, 05:56 |
| Ratha v |
Re: If my producer producing, then why the consumer couldn't consume? it stuck @ poll() |
Mon, 04 Apr, 06:23 |
| Lohith Samaga M |
RE: New consumer API waits indefinitely |
Mon, 04 Apr, 06:37 |
| Ratha v |
Re: New consumer API waits indefinitely |
Mon, 04 Apr, 06:51 |
| Lohith Samaga M |
RE: New consumer API waits indefinitely |
Mon, 04 Apr, 08:26 |
| Caesar Ralf Franz Hoppen |
Re: (auto.commit.interval = heartbeat.interval) => infinite rebalance loop |
Mon, 04 Apr, 11:15 |
| Lohith Samaga M |
RE: New consumer API waits indefinitely |
Mon, 04 Apr, 11:20 |
| Ismael Juma |
Re: New consumer API waits indefinitely |
Mon, 04 Apr, 11:50 |
| Niko Davor |
RE: New consumer API waits indefinitely |
Mon, 04 Apr, 18:29 |
| Ratha v |
Re: New consumer API waits indefinitely |
Tue, 05 Apr, 00:20 |
| Ratha v |
Re: New consumer API waits indefinitely |
Tue, 05 Apr, 00:47 |
| Kevin Mao |
Cleaning up a topic that has had its metadata deleted |
Tue, 05 Apr, 00:57 |
| Guozhang Wang |
Re: Kafka Streams: context.forward() with downstream name |
Tue, 05 Apr, 04:14 |
| Lohith Samaga M |
RE: New consumer API waits indefinitely |
Tue, 05 Apr, 07:06 |
| Lohith Samaga M |
RE: New consumer API waits indefinitely |
Tue, 05 Apr, 07:07 |
| Lohith Samaga M |
RE: New consumer API waits indefinitely |
Tue, 05 Apr, 08:05 |
| Michael Freeman |
Message reconsumed with 'earliest' offset reset 0.9.0.1 |
Tue, 05 Apr, 10:51 |
| Ratha v |
Is there any behavioural change to connect local server and remote server? |
Tue, 05 Apr, 12:13 |
| Jakub Neubauer |
Disable offset management |
Tue, 05 Apr, 14:42 |
| josh gruenberg |
Re: Kafka Streams: context.forward() with downstream name |
Tue, 05 Apr, 15:24 |
| Mario Ricci |
Question on Java client consumer.seek() |
Tue, 05 Apr, 15:56 |
| Guozhang Wang |
Re: Kafka constant shrinking and expanding after deleting a topic |
Tue, 05 Apr, 16:04 |
| maverick m. |
data not replicated to followers by leader |
Tue, 05 Apr, 16:30 |
| Guozhang Wang |
Re: Kafka Streams: context.forward() with downstream name |
Tue, 05 Apr, 17:23 |
| westfox |
Error happen when kafka 0.9 client try connect with server, with SSL enabled |
Tue, 05 Apr, 19:42 |
| Afshartous, Nick |
Low-level Consumer Example (Scala) |
Tue, 05 Apr, 19:58 |
| Ewen Cheslack-Postava |
Re: Is there any behavioural change to connect local server and remote server? |
Tue, 05 Apr, 21:09 |
| josh gruenberg |
Re: Kafka Streams: context.forward() with downstream name |
Tue, 05 Apr, 21:30 |
| Ismael Juma |
Re: Error happen when kafka 0.9 client try connect with server, with SSL enabled |
Tue, 05 Apr, 22:16 |
| westfox |
Re: Error happen when kafka 0.9 client try connect with server, with SSL enabled |
Tue, 05 Apr, 22:45 |
| Guozhang Wang |
Re: Kafka Streams: context.forward() with downstream name |
Tue, 05 Apr, 23:13 |
| Guozhang Wang |
Re: Kafka constant shrinking and expanding after deleting a topic |
Tue, 05 Apr, 23:16 |
| Ratha v |
Re: Is there any behavioural change to connect local server and remote server? |
Wed, 06 Apr, 00:08 |
| Ratha v |
WARN Error while fetching metadata with correlation id 1 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) |
Wed, 06 Apr, 01:01 |
| Gwen Shapira |
Re: Log Retention: What gets deleted |
Wed, 06 Apr, 01:12 |
| Ratha v |
Re: Is there any behavioural change to connect local server and remote server? |
Wed, 06 Apr, 03:18 |
| Ratha v |
How new consumer get to know about zookeeper URL? |
Wed, 06 Apr, 03:20 |
| Ian Wrigley |
Re: How new consumer get to know about zookeeper URL? |
Wed, 06 Apr, 03:26 |
| Ratha v |
Re: How new consumer get to know about zookeeper URL? |
Wed, 06 Apr, 03:27 |
| christopher palm |
KafkaProducer Retries in .9.0.1 |
Wed, 06 Apr, 04:23 |
| Manikumar Reddy |
Re: KafkaProducer Retries in .9.0.1 |
Wed, 06 Apr, 05:01 |
| Alexis Midon |
Re: Kafka constant shrinking and expanding after deleting a topic |
Wed, 06 Apr, 05:02 |
| Mudit Agarwal |
kafka issue |
Wed, 06 Apr, 05:23 |
| Ratha v |
Re: WARN Error while fetching metadata with correlation id 1 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) |
Wed, 06 Apr, 06:44 |
| Matthias J. Sax |
Re: Question on Java client consumer.seek() |
Wed, 06 Apr, 08:25 |
| David Buschman |
Re: Low-level Consumer Example (Scala) |
Wed, 06 Apr, 09:01 |
| Mudit Agarwal |
kafka issue |
Wed, 06 Apr, 09:10 |
| Baris Akgun (Garanti Teknoloji) |
Kafka Consumer Problem |
Wed, 06 Apr, 11:30 |
| Vince Deters |
Kafka C/C++ client with consumer group support? |
Wed, 06 Apr, 14:16 |
| 高 志明 |
Does Kafka support federation of clusters? |
Wed, 06 Apr, 14:59 |
| Uber Slacker |
Kafka Connect concept question |
Wed, 06 Apr, 15:56 |
| Ben Davison |
Re: Kafka C/C++ client with consumer group support? |
Wed, 06 Apr, 16:04 |