| 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 |