far...@technify.pk |
Load connect jars without restarting connector |
Wed, 31 Jan, 10:45 |
Dmitry Minkovsky |
Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Thu, 01 Feb, 02:19 |
Sunil Parmar |
Re: monitor consumer offset lag script/code |
Thu, 01 Feb, 03:41 |
? ?? |
NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics |
Thu, 01 Feb, 06:11 |
TSANG, Brilly |
RE: NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics |
Thu, 01 Feb, 06:54 |
Matthias J. Sax |
Re: Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Thu, 01 Feb, 07:59 |
? ?? |
Re: RE: NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics |
Thu, 01 Feb, 08:18 |
Dmitry Minkovsky |
Re: Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Thu, 01 Feb, 10:10 |
trading DEV |
KAFKA step by step installation help |
Thu, 01 Feb, 10:19 |
Traiano Welcome |
Fixing Wrecked Kafka Topic Partitions after a cluster reconfigure |
Thu, 01 Feb, 13:28 |
Michal Michalski |
Re: Fixing Wrecked Kafka Topic Partitions after a cluster reconfigure |
Thu, 01 Feb, 14:11 |
Traiano Welcome |
Re: Fixing Wrecked Kafka Topic Partitions after a cluster reconfigure |
Thu, 01 Feb, 15:55 |
John Chu |
Failed to send SSL Close messages unexpected status returned by SSLEngine.wrap, expected Close received Ok |
Thu, 01 Feb, 17:26 |
Guozhang Wang |
Re: Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Thu, 01 Feb, 18:53 |
satyajit vegesna |
Re: Kafka Consumers not rebalancing. |
Thu, 01 Feb, 21:53 |
Andrey Falko |
Re: Recommended max number of topics (and data separation) |
Fri, 02 Feb, 01:28 |
Ted Yu |
Re: Recommended max number of topics (and data separation) |
Fri, 02 Feb, 03:48 |
Dmitry Minkovsky |
Re: Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Fri, 02 Feb, 04:57 |
tao xiao |
Can leader be removed from ISR if leader is unstable |
Fri, 02 Feb, 07:26 |
Zoran |
Re: Group consumer cannot consume messages if kafka service on specific node in test cluster is down |
Fri, 02 Feb, 09:06 |
Navneet Kumar |
Re: Group consumer cannot consume messages if kafka service on specific node in test cluster is down |
Fri, 02 Feb, 09:14 |
SenthilKumar K |
Kafka Log deletion Problem |
Fri, 02 Feb, 13:38 |
Srikanth |
Re: skipped-records-rate vs skippedDueToDeserializationError-rate metric in streams app |
Fri, 02 Feb, 13:43 |
Krishnakumar Gurumurthy |
subscribe kafka topics |
Fri, 02 Feb, 13:49 |
Richard Rodseth |
Usual remedy for "Under Replicated" and "Offline Partitions" |
Fri, 02 Feb, 19:27 |
Jeff Widman |
Re: Usual remedy for "Under Replicated" and "Offline Partitions" |
Fri, 02 Feb, 19:58 |
Richard Rodseth |
Re: Usual remedy for "Under Replicated" and "Offline Partitions" |
Fri, 02 Feb, 20:00 |
Geoffrey Holmes |
Moving data from one cluster to another with Kafka Streams |
Fri, 02 Feb, 22:54 |
Bykov, Serge |
Kafka streams API for .net |
Fri, 02 Feb, 23:03 |
Matthias J. Sax |
Re: Moving data from one cluster to another with Kafka Streams |
Fri, 02 Feb, 23:36 |
Dmitry Minkovsky |
Shouldn't KStream#through let you specify a Consumed? |
Fri, 02 Feb, 23:54 |
Dylan Martin |
Recovering Under Replicated Partitions |
Sat, 03 Feb, 00:12 |
Matthias J. Sax |
Re: Shouldn't KStream#through let you specify a Consumed? |
Sat, 03 Feb, 00:22 |
Matan Givo |
Choosing Kafka for Real Time Dashboard Application |
Sat, 03 Feb, 02:50 |
Dmitry Minkovsky |
Re: Shouldn't KStream#through let you specify a Consumed? |
Sat, 03 Feb, 03:24 |
Devendar Rao |
Partition rebalancing when both leader and follower is down? |
Sat, 03 Feb, 20:45 |
Matthias J. Sax |
Re: Shouldn't KStream#through let you specify a Consumed? |
Sat, 03 Feb, 21:20 |
dizzy0ny |
Store not ready |
Sun, 04 Feb, 03:39 |
adrien ruffie |
Strange Topic ... |
Sun, 04 Feb, 19:14 |
Ted Yu |
Re: Strange Topic ... |
Sun, 04 Feb, 19:37 |
naresh Goud |
Re: Strange Topic ... |
Sun, 04 Feb, 19:47 |
adrien ruffie |
RE: Strange Topic ... |
Sun, 04 Feb, 19:48 |
Wouter Bancken |
Re: Kafka Consumer Offsets unavailable during rebalancing |
Sun, 04 Feb, 19:51 |
Hans Jespersen |
Re: Kafka Consumer Offsets unavailable during rebalancing |
Sun, 04 Feb, 20:25 |
Wouter Bancken |
Re: Kafka Consumer Offsets unavailable during rebalancing |
Sun, 04 Feb, 22:16 |
Hans Jespersen |
Re: Kafka Consumer Offsets unavailable during rebalancing |
Sun, 04 Feb, 23:13 |
Geoffrey Holmes |
Re: Moving data from one cluster to another with Kafka Streams |
Mon, 05 Feb, 01:49 |
Tony John |
Kafka Streams : Connection to node -1 could not be established. Broker may not be available. |
Mon, 05 Feb, 08:00 |
Krishnakumar Gurumurthy |
Issues with Kafka Group Coordinator Failover |
Mon, 05 Feb, 08:10 |
Wouter Bancken |
Re: Kafka Consumer Offsets unavailable during rebalancing |
Mon, 05 Feb, 08:22 |
Pegerto Fernandez Torres |
kafka-streams using throught |
Mon, 05 Feb, 11:27 |
Claudia Wegmann |
Custom window implementation |
Mon, 05 Feb, 12:51 |
naresh Goud |
Re: Choosing Kafka for Real Time Dashboard Application |
Mon, 05 Feb, 17:02 |
Saïd Bouras |
Which record is processed when topology restart ? |
Mon, 05 Feb, 17:09 |
Matthias J. Sax |
Re: kafka-streams using throught |
Mon, 05 Feb, 18:29 |
Matthias J. Sax |
Re: Which record is processed when topology restart ? |
Mon, 05 Feb, 18:34 |
Maria Pilar |
Consumer group |
Mon, 05 Feb, 18:59 |
Guozhang Wang |
Re: Kafka Streams : Connection to node -1 could not be established. Broker may not be available. |
Mon, 05 Feb, 21:51 |
Dmitry Minkovsky |
Re: Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Mon, 05 Feb, 23:48 |
Ewen Cheslack-Postava |
[VOTE] 1.0.1 RC0 |
Tue, 06 Feb, 03:48 |
Tony John |
Re: Kafka Streams : Connection to node -1 could not be established. Broker may not be available. |
Tue, 06 Feb, 16:16 |
Bryan Baugher |
Kafka Utilities |
Tue, 06 Feb, 20:13 |
Raghav |
log.retention.bytes not working as expected |
Tue, 06 Feb, 20:24 |
M. Manna |
Re: log.retention.bytes not working as expected |
Tue, 06 Feb, 20:26 |
Raghav |
Re: Kafka per topic retention.bytes and global log.retention.bytes not working |
Tue, 06 Feb, 20:27 |
Raghav |
Re: log.retention.bytes not working as expected |
Tue, 06 Feb, 20:29 |
M. Manna |
Re: log.retention.bytes not working as expected |
Tue, 06 Feb, 20:32 |
Raghav |
Re: log.retention.bytes not working as expected |
Tue, 06 Feb, 20:56 |
Ted Yu |
Re: log.retention.bytes not working as expected |
Tue, 06 Feb, 21:09 |
Guozhang Wang |
Re: Kafka Streams : Connection to node -1 could not be established. Broker may not be available. |
Tue, 06 Feb, 21:35 |
Raghav |
Re: log.retention.bytes not working as expected |
Tue, 06 Feb, 21:36 |
Ted Yu |
Re: log.retention.bytes not working as expected |
Tue, 06 Feb, 21:38 |
Raghav |
Re: log.retention.bytes not working as expected |
Tue, 06 Feb, 21:51 |
Ted Yu |
Re: [VOTE] 1.0.1 RC0 |
Wed, 07 Feb, 00:30 |
Jeff Widman |
How to calculate consumer lag in wall-clock time by querying the broker? |
Wed, 07 Feb, 05:39 |
Puneet Lakhina |
Re: How to calculate consumer lag in wall-clock time by querying the broker? |
Wed, 07 Feb, 07:10 |
Tony John |
Re: Kafka Streams : Connection to node -1 could not be established. Broker may not be available. |
Wed, 07 Feb, 16:15 |
Russell Teabeault |
Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 18:37 |
Vahid S Hashemian |
Re: [VOTE] 1.0.1 RC0 |
Wed, 07 Feb, 19:06 |
Matthias J. Sax |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 19:33 |
Tony Liu |
Any idea why zookeeper will run into connection issue. |
Wed, 07 Feb, 19:39 |
Vahid S Hashemian |
Bay Area Apache Kafka Meetup - Morning of Feb 20 |
Wed, 07 Feb, 20:19 |
James Buchan |
Consume latest offset after rebalance |
Wed, 07 Feb, 20:47 |
Guozhang Wang |
Re: [VOTE] 1.0.1 RC0 |
Wed, 07 Feb, 22:01 |
Russell Teabeault |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 22:45 |
Russell Teabeault |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 23:09 |
Bill Bejeck |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 23:12 |
Russell Teabeault |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 23:16 |
Matthias J. Sax |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 23:23 |
Russell Teabeault |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 23:25 |
Bill Bejeck |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 23:38 |
Matthias J. Sax |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 23:53 |
Russell Teabeault |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 23:56 |
? ? |
how to enhance Kafka streaming Consumer rate ? |
Thu, 08 Feb, 08:30 |
Xavier Noria |
are offsets per consumer or per consumer group? |
Thu, 08 Feb, 12:58 |
Luke Steensen |
Re: are offsets per consumer or per consumer group? |
Thu, 08 Feb, 15:27 |
Xavier Noria |
Re: are offsets per consumer or per consumer group? |
Thu, 08 Feb, 15:37 |
Luke Steensen |
Re: are offsets per consumer or per consumer group? |
Thu, 08 Feb, 16:00 |
Xavier Noria |
Re: are offsets per consumer or per consumer group? |
Thu, 08 Feb, 16:16 |
Krishnakumar Gurumurthy |
RE: Issues with Kafka Group Coordinator Failover |
Thu, 08 Feb, 17:09 |