| Nicolas Fouché |
Kafka Streams: consume 6 months old data VS windows maintain durations |
Thu, 12 Jan, 09:15 |
| Nicolas Fouché |
Re: Kafka Streams: consume 6 months old data VS windows maintain durations |
Thu, 12 Jan, 21:21 |
| Nicolas Fouché |
Kafka Streams: from a KStream, aggregating records with the same key and updated metrics ? |
Thu, 12 Jan, 22:19 |
| Nicolas Fouché |
Kafka Streams: setting the compression codec for intermediate and output topics |
Sun, 15 Jan, 21:25 |
| Nicolas Fouché |
Re: Kafka Streams: from a KStream, aggregating records with the same key and updated metrics ? |
Sun, 15 Jan, 22:10 |
| Nicolas Fouché |
Re: Kafka Streams: setting the compression codec for intermediate and output topics |
Mon, 16 Jan, 10:50 |
| Nicolas Fouché |
Kafka Streams: got bit by WindowedSerializer (only window.start is serialized) |
Mon, 16 Jan, 11:17 |
| Nicolas Fouché |
Re: Kafka Streams: got bit by WindowedSerializer (only window.start is serialized) |
Mon, 16 Jan, 14:48 |
| Nicolas Fouché |
Re: Kafka Streams: from a KStream, aggregating records with the same key and updated metrics ? |
Mon, 16 Jan, 14:52 |
| Nicolas Fouché |
Re: Kafka Streams: got bit by WindowedSerializer (only window.start is serialized) |
Mon, 16 Jan, 18:46 |
| Nicolas Fouché |
Re: Kafka Streams: from a KStream, aggregating records with the same key and updated metrics ? |
Mon, 16 Jan, 22:15 |
| Nicolas Fouché |
Re: Kafka Streams: got bit by WindowedSerializer (only window.start is serialized) |
Mon, 16 Jan, 22:47 |
| Nicolas Fouché |
Re: Kafka Streams: got bit by WindowedSerializer (only window.start is serialized) |
Mon, 16 Jan, 22:52 |
| Nicolas Fouché |
Kafka Streams: how can I get the name of the Processor when calling `KStream.process` |
Wed, 18 Jan, 13:47 |
| Nicolas Fouché |
Re: Kafka Streams: how can I get the name of the Processor when calling `KStream.process` |
Wed, 18 Jan, 16:18 |
| Nicolas Fouché |
Re: Kafka Streams: how can I get the name of the Processor when calling `KStream.process` |
Wed, 18 Jan, 16:29 |
| Nicolas Fouché |
Re: Kafka Streams: how can I get the name of the Processor when calling `KStream.process` |
Thu, 19 Jan, 09:21 |
| Stevo Slavić |
Re: Reg: Need info on Kafka Brokers |
Mon, 02 Jan, 12:43 |
| Stevo Slavić |
When publishing to non existing topic, TimeoutException is thrown instead of UnknownTopicOrPartitionException |
Fri, 27 Jan, 12:09 |
| Stevo Slavić |
Re: When publishing to non existing topic, TimeoutException is thrown instead of UnknownTopicOrPartitionException |
Fri, 27 Jan, 13:43 |
| Fred(刘福才) |
a question about kafka connect |
Mon, 09 Jan, 09:19 |
| 赖剑清 |
Consumer don't consume |
Tue, 24 Jan, 08:55 |
| Aaron Niskode-Dossett |
Re: Trademark review |
Wed, 04 Jan, 19:47 |
| Abhishek Agarwal |
Re: kafka.log:type=LogFlushStats,name=LogFlushRateAndTimeMs Not Reported |
Tue, 03 Jan, 11:23 |
| Abhishek Agarwal |
Re: Under-replicated Partitions while rolling Kafka nodes in AWS |
Tue, 10 Jan, 11:38 |
| Abhishek Agrawal |
Interpreting value of JMX metric for partition count |
Wed, 11 Jan, 03:25 |
| Akashdeep Singh |
Kafka broker behind Reverse Proxy |
Tue, 10 Jan, 11:59 |
| Alberto.Fo...@natwestmarkets.com.INVALID |
Per topic MBeans leaking |
Fri, 13 Jan, 16:12 |
| Alberto.Fo...@natwestmarkets.com.INVALID |
RE: Per topic MBeans leaking |
Fri, 13 Jan, 17:02 |
| Alexander Demidko |
Kafka Streams window retention period question |
Thu, 05 Jan, 01:16 |
| Alexander Demidko |
Re: Kafka Streams window retention period question |
Fri, 06 Jan, 05:14 |
| Alexander Demidko |
Re: Kafka Streams window retention period question |
Fri, 06 Jan, 06:19 |
| Amrit Jangid |
Re: Viewing timestamps with console consumer (0.10.1.1) |
Mon, 30 Jan, 18:09 |
| Andy Chambers |
Re: KafkaAvroSerializer to produce to a single topic with different schemas used for records |
Mon, 30 Jan, 16:32 |
| Anjani Gupta |
kafka_2.10-0.8.1 simple consumer retrieves junk data in the message |
Fri, 27 Jan, 18:19 |
| Anjani Gupta |
Re: kafka_2.10-0.8.1 simple consumer retrieves junk data in the message |
Tue, 31 Jan, 18:00 |
| Apurva Mehta |
Re: [VOTE] Vote for KIP-101 - Leader Epochs |
Wed, 04 Jan, 17:25 |
| Apurva Mehta |
Re: Leader imbalance issue |
Fri, 20 Jan, 19:16 |
| Apurva Mehta |
Re: Messages are lost |
Mon, 23 Jan, 17:48 |
| Ara Ebrahimi |
kafka streams consumer partition assignment is uneven |
Mon, 09 Jan, 17:52 |
| Ara Ebrahimi |
Re: kafka streams consumer partition assignment is uneven |
Mon, 09 Jan, 20:05 |
| Asaf Mesika |
Re: Apache Kafka integration using Apache Camel |
Thu, 12 Jan, 05:02 |
| Avi Flax |
Re: Consumers in the same group but consuming different topics? |
Tue, 03 Jan, 20:54 |
| Avi Flax |
Re: Strategy for true random producer keying |
Tue, 24 Jan, 18:52 |
| Avi Flax |
Re: Strategy for true random producer keying |
Tue, 24 Jan, 19:51 |
| Barot, Abhishek |
Kafka - topics not getting deleted |
Tue, 17 Jan, 12:27 |
| Barot, Abhishek |
Failing to get Topic Configuration |
Fri, 20 Jan, 14:22 |
| Barot, Abhishek |
Topic with retention period of 10 mins |
Tue, 24 Jan, 15:59 |
| Becket Qin |
Re: [ANNOUNCE] New committer: Grant Henke |
Wed, 11 Jan, 22:25 |
| Ben Stopford |
[VOTE] Vote for KIP-101 - Leader Epochs |
Wed, 04 Jan, 17:24 |
| Ben Stopford |
Re: [VOTE] Vote for KIP-101 - Leader Epochs |
Thu, 05 Jan, 19:11 |
| Ben Stopford |
Re: [VOTE] Vote for KIP-101 - Leader Epochs |
Fri, 06 Jan, 09:32 |
| Ben Stopford |
Re: [VOTE] Vote for KIP-101 - Leader Epochs |
Wed, 11 Jan, 18:44 |
| Ben Stopford |
Re: [VOTE] Vote for KIP-101 - Leader Epochs |
Wed, 11 Jan, 18:48 |
| Ben Stopford |
Re: [VOTE] Vote for KIP-101 - Leader Epochs |
Wed, 11 Jan, 18:53 |
| Ben Stopford |
[VOTE] KIP-106 - Default unclean.leader.election.enabled True => False |
Wed, 11 Jan, 18:56 |
| Ben Stopford |
Re: [ANNOUNCE] New committer: Grant Henke |
Wed, 11 Jan, 20:06 |
| Benjamin Black |
Aggregated windowed counts |
Wed, 04 Jan, 20:48 |
| Benjamin Black |
Re: Aggregated windowed counts |
Wed, 04 Jan, 22:09 |
| Benjamin Black |
Re: Aggregated windowed counts |
Thu, 05 Jan, 16:13 |
| Berryman, Eric |
kafka-connect log4j |
Tue, 10 Jan, 15:42 |
| Berryman, Eric |
RE: kafka-connect log4j |
Wed, 11 Jan, 14:04 |
| BigData dev |
Reg: Kafka ACLS |
Wed, 25 Jan, 21:08 |
| Brian Krahmer |
Problem with processor API partition assignments |
Thu, 05 Jan, 10:58 |
| Brian Krahmer |
Re: Re: Problem with processor API partition assignments |
Mon, 09 Jan, 14:19 |
| Brian Krahmer |
Re: ZK, Kafka, Streamclient not cleanly starting up (two issues) |
Tue, 31 Jan, 19:13 |
| Buntu Dev |
Kafka JDBC connector vs Sqoop |
Thu, 26 Jan, 20:43 |
| Cas Apanowicz |
Kafka as a data ingest |
Tue, 10 Jan, 00:56 |
| Check Peck |
java.lang.OutOfMemoryError: Java heap space while running kafka-consumer-perf-test.sh |
Wed, 11 Jan, 22:59 |
| Check Peck |
Re: java.lang.OutOfMemoryError: Java heap space while running kafka-consumer-perf-test.sh |
Thu, 12 Jan, 23:24 |
| Chriss Vincelette |
broker randomly shuts down |
Thu, 26 Jan, 08:44 |
| Christian |
Problem connecting to ZooKeeper with Kafka SASL enabled |
Sat, 07 Jan, 14:54 |
| Christian |
Re: Problem connecting to ZooKeeper with Kafka SASL enabled |
Sat, 07 Jan, 15:58 |
| Christian |
Kafka SASL_PLAINTEXT and authentication/authorization backend failure |
Thu, 19 Jan, 18:37 |
| Christian |
Re: Kafka SASL_PLAINTEXT and authentication/authorization backend failure |
Thu, 19 Jan, 19:59 |
| Christian |
Re: Kafka SASL_PLAINTEXT and authentication/authorization backend failure |
Sat, 21 Jan, 03:22 |
| Daisuke Moriya |
changelog topic with in-memory state store |
Wed, 11 Jan, 06:10 |
| Daisuke Moriya |
Re: changelog topic with in-memory state store |
Thu, 12 Jan, 13:05 |
| Damian Guy |
Re: Problem with processor API partition assignments |
Thu, 05 Jan, 12:37 |
| Damian Guy |
Re: Re: Problem with processor API partition assignments |
Mon, 09 Jan, 14:56 |
| Damian Guy |
Re: changelog topic with in-memory state store |
Wed, 11 Jan, 12:08 |
| Damian Guy |
Re: [ANNOUNCE] New committer: Grant Henke |
Thu, 12 Jan, 08:58 |
| Damian Guy |
Re: Kafka Streams: setting the compression codec for intermediate and output topics |
Mon, 16 Jan, 09:07 |
| Damian Guy |
Re: Kafka Streams: got bit by WindowedSerializer (only window.start is serialized) |
Mon, 16 Jan, 11:31 |
| Damian Guy |
Re: Kafka Streams: how can I get the name of the Processor when calling `KStream.process` |
Wed, 18 Jan, 14:22 |
| Damian Guy |
Re: Kafka Streams: how can I get the name of the Processor when calling `KStream.process` |
Wed, 18 Jan, 14:31 |
| Damian Guy |
Re: Table a KStream |
Tue, 24 Jan, 16:53 |
| Damian Guy |
Re: Track Latest Count - Unique Key |
Wed, 25 Jan, 12:37 |
| Damian Guy |
Re: How to log/analyze the consumer lag in kafka streaming application |
Fri, 27 Jan, 09:01 |
| Damian Guy |
Re: How to log/analyze the consumer lag in kafka streaming application |
Fri, 27 Jan, 14:57 |
| Damian Guy |
Re: Fwd: [DISCUSS] KIP-114: KTable materialization and improved semantics |
Fri, 27 Jan, 15:51 |
| Damian Guy |
Re: [DISCUSS] KIP-114: KTable materialization and improved semantics |
Sat, 28 Jan, 09:23 |
| Damian Guy |
Re: ZK, Kafka, Streamclient not cleanly starting up (two issues) |
Tue, 31 Jan, 18:18 |
| Dave Hamilton |
Error finding consumer coordinators after restart |
Thu, 12 Jan, 19:29 |
| Dave Hamilton |
Re: Error finding consumer coordinators after restart |
Fri, 13 Jan, 19:24 |
| David Garcia |
Re: min hardware requirement |
Tue, 24 Jan, 20:13 |
| David Garcia |
Re: min hardware requirement |
Tue, 24 Jan, 20:14 |
| Davor |
Dimensioning / sizing Kafka consumers |
Tue, 03 Jan, 01:23 |
| Dhwani Katagade |
Re: General question about kafka to use in a correct way |
Fri, 20 Jan, 06:26 |
| Dmitry Minkovsky |
What are wall clock-driven alternatives to punctuate()? |
Sun, 22 Jan, 03:30 |