张家利 |
Re: Kafka/zookeeper logs in every command |
Sat, 24 Feb, 10:01 |
Saïd Bouras |
Which record is processed when topology restart ? |
Mon, 05 Feb, 17:09 |
Gerd König |
Re: Zookeeper Error |
Sun, 18 Feb, 10:49 |
Michal Hariš |
connecting to 2 different clusters with different sasl realms in a single process |
Mon, 19 Feb, 14:40 |
Sönke Liebau |
Re: commiting consumed offsets synchronously (every message) |
Wed, 21 Feb, 14:59 |
Sönke Liebau |
Re: commiting consumed offsets synchronously (every message) |
Wed, 21 Feb, 16:04 |
Sönke Liebau |
Re: Restricting client access to zookeeper metadata |
Sat, 24 Feb, 06:50 |
Sönke Liebau |
Re: Restricting client access to zookeeper metadata |
Tue, 27 Feb, 04:05 |
星月夜 |
Re: How start with Kafka? |
Fri, 09 Feb, 07:12 |
Josef Ludvíček |
Producer blocks on send to topic that doesn't exist if auto create is disabled |
Thu, 22 Feb, 14:45 |
? ? |
how to enhance Kafka streaming Consumer rate ? |
Thu, 08 Feb, 08:30 |
? ?? |
NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics |
Thu, 01 Feb, 06:11 |
? ?? |
Re: RE: NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics |
Thu, 01 Feb, 08:18 |
Affan Syed |
Re: Issues with Kafka |
Tue, 20 Feb, 16:24 |
Andras Beni |
Re: Who is assigned to which partitions |
Tue, 20 Feb, 19:57 |
Andras Beni |
Re: difference between 2 options |
Tue, 27 Feb, 05:16 |
Andras Beni |
Re: Kafka 0.8.2 Producers -> Kafka Brokers 0.9.x |
Tue, 27 Feb, 06:24 |
Andras Beni |
Re: difference between 2 options |
Tue, 27 Feb, 14:41 |
Andras Beni |
Re: unsubscribe me |
Wed, 28 Feb, 07:04 |
Andrew Otto |
Re: Cross-cluster mirror making |
Mon, 12 Feb, 13:59 |
Andrey Falko |
Re: Recommended max number of topics (and data separation) |
Fri, 02 Feb, 01:28 |
Andy |
How start with Kafka? |
Thu, 08 Feb, 23:44 |
Arunkumar |
Zookeeper and Kafka JMX metrics |
Tue, 27 Feb, 22:19 |
Avinash Herle |
Kafka cluster instablility |
Wed, 14 Feb, 17:38 |
Behrang |
Consumer group intermittently can not read any records from a cluster with 3 nodes that has one node down |
Tue, 20 Feb, 08:00 |
Behrang |
Re: Consumer group intermittently can not read any records from a cluster with 3 nodes that has one node down |
Tue, 20 Feb, 11:50 |
Biju N |
Spike in Metarequest call timings in Java client |
Thu, 15 Feb, 17:22 |
Biju N |
Recovering from disk full |
Fri, 16 Feb, 17:41 |
Bill Bejeck |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 23:12 |
Bill Bejeck |
Re: Kafka Streams balancing of tasks across nodes |
Wed, 07 Feb, 23:38 |
Bill Bejeck |
Re: Doubts in KStreams |
Wed, 21 Feb, 15:18 |
Bill Bejeck |
Re: Consumer group describe issue |
Thu, 22 Feb, 14:39 |
Bill Bejeck |
Re: Kafka Streams : TimeoutException Expiring Records |
Thu, 22 Feb, 19:45 |
Bill Bejeck |
Re: ProcessorTopology |
Fri, 23 Feb, 17:10 |
Bill Bejeck |
Re: question on doing deduplication with KafkaStreams |
Tue, 27 Feb, 15:52 |
Biplob Biswas |
Zookeeper server failover with kakfa |
Mon, 26 Feb, 08:53 |
Bryan Baugher |
Kafka Utilities |
Tue, 06 Feb, 20:13 |
Bykov, Serge |
Kafka streams API for .net |
Fri, 02 Feb, 23:03 |
Claudia Wegmann |
Custom window implementation |
Mon, 05 Feb, 12:51 |
Cody Koeninger |
Re: org.apache.kafka.clients.consumer.OffsetOutOfRangeException |
Mon, 12 Feb, 22:48 |
Cody Koeninger |
Re: KafkaUtils.createStream(..) is removed for API |
Mon, 19 Feb, 21:09 |
Damian Guy |
Re: Kafka Stream tuning. |
Tue, 13 Feb, 08:48 |
Damian Guy |
Re: question on serialization .. |
Tue, 13 Feb, 08:54 |
Damian Guy |
Re: [VOTE] 1.0.1 RC1 |
Tue, 13 Feb, 11:03 |
Damian Guy |
Re: [VOTE] 1.0.1 RC1 |
Tue, 13 Feb, 17:52 |
Damian Guy |
Re: [VOTE] 1.0.1 RC1 |
Tue, 13 Feb, 18:00 |
Damian Guy |
[VOTE] 1.1.0 RC0 |
Sat, 24 Feb, 16:16 |
Damian Guy |
Re: [VOTE] 1.1.0 RC0 |
Wed, 28 Feb, 19:35 |
Debasish Ghosh |
question on serialization .. |
Sat, 10 Feb, 19:00 |
Debasish Ghosh |
Re: question on serialization .. |
Sat, 10 Feb, 21:10 |
Debasish Ghosh |
Re: question on serialization .. |
Sun, 11 Feb, 06:34 |
Debasish Ghosh |
Re: question on serialization .. |
Mon, 12 Feb, 10:16 |
Debasish Ghosh |
Re: question on serialization .. |
Tue, 13 Feb, 05:39 |
Debasish Ghosh |
Re: question on serialization .. |
Tue, 13 Feb, 14:36 |
Debraj Manna |
Java Consumer Not reading message - |
Fri, 16 Feb, 11:53 |
Debraj Manna |
Re: Java Consumer Not reading message - |
Fri, 16 Feb, 13:13 |
Debraj Manna |
Re: Java Consumer Not reading message - |
Mon, 19 Feb, 03:32 |
Debraj Manna |
Kafka broker throwing ConfigException Invalid value configuration log.segment.bytes: Not a number of type INT |
Mon, 19 Feb, 17:39 |
Dennis |
questions about replication factor of __consumer_offsets topic |
Wed, 14 Feb, 03:47 |
Devendar Rao |
Partition rebalancing when both leader and follower is down? |
Sat, 03 Feb, 20:45 |
Devendar Rao |
Re: Partition rebalancing when both leader and follower is down? |
Fri, 09 Feb, 00:23 |
Devendar Rao |
Finding consumer group coordinator from CLI? |
Wed, 14 Feb, 08:06 |
Dmitriy Vsekhvalnov |
kafka-streams died with org.apache.kafka.clients.consumer.CommitFailedException |
Tue, 27 Feb, 16:06 |
Dmitriy Vsekhvalnov |
Re: kafka-streams died with org.apache.kafka.clients.consumer.CommitFailedException |
Tue, 27 Feb, 19:19 |
Dmitry Minkovsky |
Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Thu, 01 Feb, 02:19 |
Dmitry Minkovsky |
Re: Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Thu, 01 Feb, 10:10 |
Dmitry Minkovsky |
Re: Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Fri, 02 Feb, 04:57 |
Dmitry Minkovsky |
Shouldn't KStream#through let you specify a Consumed? |
Fri, 02 Feb, 23:54 |
Dmitry Minkovsky |
Re: Shouldn't KStream#through let you specify a Consumed? |
Sat, 03 Feb, 03:24 |
Dmitry Minkovsky |
Re: Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Mon, 05 Feb, 23:48 |
Dylan Martin |
Recovering Under Replicated Partitions |
Sat, 03 Feb, 00:12 |
Dylan Martin |
Cancel partition reassignment? |
Fri, 09 Feb, 00:12 |
Ewen Cheslack-Postava |
[VOTE] 1.0.1 RC0 |
Tue, 06 Feb, 03:48 |
Ewen Cheslack-Postava |
Re: [VOTE] 1.0.1 RC0 |
Sat, 10 Feb, 00:06 |
Ewen Cheslack-Postava |
[VOTE] 1.0.1 RC1 |
Mon, 12 Feb, 18:15 |
Ewen Cheslack-Postava |
Re: [VOTE] 1.0.1 RC1 |
Mon, 12 Feb, 18:16 |
Ewen Cheslack-Postava |
Re: [VOTE] 1.0.1 RC1 |
Tue, 13 Feb, 00:01 |
Ewen Cheslack-Postava |
Re: [VOTE] 1.0.1 RC1 |
Tue, 13 Feb, 17:41 |
Ewen Cheslack-Postava |
Re: [VOTE] 1.0.1 RC1 |
Tue, 20 Feb, 21:23 |
Ewen Cheslack-Postava |
[VOTE] 1.0.1 RC2 |
Thu, 22 Feb, 00:06 |
Feiran Wang |
Total ordering of messages across partitions |
Wed, 28 Feb, 00:13 |
Gabriel Giussi |
Testing with MockConsumer |
Mon, 19 Feb, 12:39 |
Gabriel Giussi |
Re: Testing with MockConsumer |
Mon, 19 Feb, 18:56 |
Geoffrey Holmes |
Moving data from one cluster to another with Kafka Streams |
Fri, 02 Feb, 22:54 |
Geoffrey Holmes |
Re: Moving data from one cluster to another with Kafka Streams |
Mon, 05 Feb, 01:49 |
Guozhang Wang |
Re: Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? |
Thu, 01 Feb, 18:53 |
Guozhang Wang |
Re: Kafka Streams : Connection to node -1 could not be established. Broker may not be available. |
Mon, 05 Feb, 21:51 |
Guozhang Wang |
Re: Kafka Streams : Connection to node -1 could not be established. Broker may not be available. |
Tue, 06 Feb, 21:35 |
Guozhang Wang |
Re: [VOTE] 1.0.1 RC0 |
Wed, 07 Feb, 22:01 |
Guozhang Wang |
Re: Kafka Stream tuning. |
Wed, 14 Feb, 19:35 |
Guozhang Wang |
Re: unable to find custom JMX metrics |
Wed, 14 Feb, 22:09 |
Guozhang Wang |
Re: [VOTE] 1.0.1 RC1 |
Thu, 15 Feb, 02:31 |
Guozhang Wang |
Re: Error handling |
Wed, 21 Feb, 22:01 |
Guozhang Wang |
Re: kafka 1.0.1? |
Tue, 27 Feb, 00:36 |
Guozhang Wang |
Re: aggregation tables mirrored in kafka & rocksdb |
Wed, 28 Feb, 21:31 |
Hans Jespersen |
Re: Kafka Consumer Offsets unavailable during rebalancing |
Sun, 04 Feb, 20:25 |
Hans Jespersen |
Re: Kafka Consumer Offsets unavailable during rebalancing |
Sun, 04 Feb, 23:13 |
Hans Jespersen |
Re: replica.fetch.max.bytes split message or not ? |
Sun, 25 Feb, 16:30 |
Husna Hadi |
Cross-cluster mirror making |
Thu, 08 Feb, 22:21 |
Ian Ewing |
error when attempting a unit test of spring kafka producer |
Wed, 14 Feb, 04:03 |