You are viewing a plain text version of this content. The canonical link for it is here.
- Closing socket connection to /127.0.0.1. (kafka.network.Processor) - posted by Anjani Gupta <an...@salesforce.com> on 2017/02/01 00:09:34 UTC, 0 replies.
- Re: "End of Batch" event - posted by "Matthias J. Sax" <ma...@confluent.io> on 2017/02/01 00:31:00 UTC, 4 replies.
- Kafka docs for current trunk - posted by "Matthias J. Sax" <ma...@confluent.io> on 2017/02/01 01:57:36 UTC, 6 replies.
- Flood of error messages on broker shutdown (can't connect to self) - posted by Stephane Maarek <st...@simplemachines.com.au> on 2017/02/01 02:49:42 UTC, 0 replies.
- Kafka Connect in different hosts than Kafka - posted by Guillermo Ortiz <ko...@gmail.com> on 2017/02/01 10:50:52 UTC, 1 replies.
- Kafka Streams punctuate with slow-changing KTables - posted by Elliot Crosby-McCullough <el...@gmail.com> on 2017/02/01 15:37:55 UTC, 9 replies.
- Using KafkaConsumer to consume the internal office __consumer_offsets in Kafka 10, using Java - posted by "Wang, Howard" <Ho...@washpost.com> on 2017/02/01 16:09:48 UTC, 0 replies.
- Re: [DISCUSS] KIP-114: KTable materialization and improved semantics - posted by Eno Thereska <en...@gmail.com> on 2017/02/01 17:04:03 UTC, 0 replies.
- Anyone have guide for setting up the rest proxy using SSL and Client authentication - posted by Gene Robichaux <Ge...@match.com> on 2017/02/01 17:52:30 UTC, 5 replies.
- Kafka Connect in different nodes than Kafka. - posted by Guillermo Ortiz <ko...@gmail.com> on 2017/02/01 19:08:30 UTC, 3 replies.
- kafka-streams ktable recovery after rebalance crash - posted by Ara Ebrahimi <ar...@argyledata.com> on 2017/02/01 20:08:20 UTC, 1 replies.
- kafka-consumer-offset-checker complaining about NoNode for X in zk - posted by Ara Ebrahimi <ar...@argyledata.com> on 2017/02/01 20:14:08 UTC, 3 replies.
- kafka 0.8 producer when zookeeper 3.4.6 is shut down - posted by Raghu Toppur <to...@gmail.com> on 2017/02/01 22:17:06 UTC, 0 replies.
- Re: KAFKA Support - posted by Gwen Shapira <gw...@confluent.io> on 2017/02/01 23:26:24 UTC, 0 replies.
- [VOTE] 0.10.2.0 RC0 - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/01 23:44:50 UTC, 0 replies.
- Re: Using KafkaConsumer to consume the internal office __consumer_offsets in Kafka 10, using Java - posted by Manikumar <ma...@gmail.com> on 2017/02/02 06:24:34 UTC, 0 replies.
- Re: Cannot access Kafka Streams JMX metrics using jmxterm - posted by Sachin Mittal <sj...@gmail.com> on 2017/02/02 07:14:37 UTC, 0 replies.
- Kafka Streams delivery semantics and state store - posted by "Krzysztof Lesniewski, Nexiot AG" <kr...@nexiot.ch> on 2017/02/02 14:38:30 UTC, 9 replies.
- Streams InvalidStateStoreException: Store ... is currently closed - posted by Mathieu Fenniak <ma...@replicon.com> on 2017/02/02 16:12:20 UTC, 2 replies.
- Does KafkaStreams be configured to use multiple broker clusters in the same topology - posted by Roger Vandusen <Ro...@ticketmaster.com> on 2017/02/02 16:51:15 UTC, 8 replies.
- Will KafkaStreams 0.10.2.0 work with 0.10.0.0 Kafka broker cluster - posted by Roger Vandusen <Ro...@ticketmaster.com> on 2017/02/02 21:09:13 UTC, 1 replies.
- Surveying for Applications of Kafka - posted by Collin Lee <cs...@cs.stanford.edu> on 2017/02/03 00:55:26 UTC, 0 replies.
- KAFKA-3703: Graceful close for consumers and producer with acks=0 - posted by "Pascu, Ciprian (Nokia - FI/Espoo)" <ci...@nokia.com> on 2017/02/03 05:28:32 UTC, 1 replies.
- Re: At Least Once semantics for Kafka Streams - posted by Mahendra Kariya <ma...@go-jek.com> on 2017/02/03 08:39:52 UTC, 10 replies.
- Re: Running cluster of stream processing application - posted by Sachin Mittal <sj...@gmail.com> on 2017/02/03 09:07:30 UTC, 3 replies.
- [DISCUSS] KIP-118: Drop Support for Java 7 in Kafka 0.11 - posted by Ismael Juma <is...@juma.me.uk> on 2017/02/03 10:38:33 UTC, 7 replies.
- KIP-119: Drop Support for Scala 2.10 in Kafka 0.11 - posted by Ismael Juma <is...@juma.me.uk> on 2017/02/03 14:30:44 UTC, 5 replies.
- [DISCUSS] KIP-120: Cleanup Kafka Streams builder API - posted by "Matthias J. Sax" <ma...@confluent.io> on 2017/02/03 23:33:20 UTC, 17 replies.
- Re: How to log/analyze the consumer lag in kafka streaming application - posted by Sachin Mittal <sj...@gmail.com> on 2017/02/04 10:37:33 UTC, 1 replies.
- Potential memory leak in rocksdb - posted by Pierre Coquentin <pi...@gmail.com> on 2017/02/04 16:18:19 UTC, 18 replies.
- Fwd: IoT at the ASF -- ApacheCon and Project DOAPs [was: Does your project play in the IoT space?] - posted by Trevor Grant <tr...@gmail.com> on 2017/02/04 20:31:31 UTC, 0 replies.
- Fault tolerance not working in Kafka - posted by Nitin Shende <ni...@gmail.com> on 2017/02/06 04:15:37 UTC, 2 replies.
- Need help in understanding bunch of rocksdb errors on kafka_2.10-0.10.1.1 - posted by Sachin Mittal <sj...@gmail.com> on 2017/02/06 05:42:55 UTC, 17 replies.
- trying to understand CommitFailedException - posted by Sachin Mittal <sj...@gmail.com> on 2017/02/06 06:21:22 UTC, 1 replies.
- log.retention.hours - posted by Алексей Федосов <al...@yandex.ru> on 2017/02/06 06:46:51 UTC, 0 replies.
- How does one deploy to consumers without causing re-balancing for real time use case? - posted by Praveen <pr...@gmail.com> on 2017/02/06 07:27:32 UTC, 8 replies.
- "auto offset commit failed" - posted by Jon Yeargers <jo...@cedexis.com> on 2017/02/06 12:38:03 UTC, 1 replies.
- Broker becoming unresponsive and bringing down the entire cluster down with it - posted by Robert Zuljevic <r....@levi9.com> on 2017/02/06 15:20:49 UTC, 0 replies.
- Re: log.retention.hours - posted by Akhilesh Pathodia <pa...@gmail.com> on 2017/02/06 18:44:03 UTC, 0 replies.
- Next week: Streams Processing meetup with speakers from LinkedIn, Uber, and Optimizely - posted by Ed Yakabosky <ey...@linkedin.com.INVALID> on 2017/02/06 19:49:56 UTC, 0 replies.
- SASL Security Roadmap in Kafka Connect - posted by Stephane Maarek <st...@simplemachines.com.au> on 2017/02/06 22:34:24 UTC, 2 replies.
- KIP-121 [Discuss]: Add KStream peek method - posted by Steven Schlansker <ss...@opentable.com> on 2017/02/06 23:35:36 UTC, 11 replies.
- users@kafka.apache.org - posted by James Teng <te...@outlook.com> on 2017/02/07 02:18:34 UTC, 0 replies.
- Format Kafka raw message to avro json format programatically + KafkaUtils - posted by kush batra <ku...@gmail.com> on 2017/02/07 03:41:07 UTC, 1 replies.
- Kafka Producer Protocol - posted by "Hopson, Stephen" <st...@gb.unisys.com> on 2017/02/07 14:57:57 UTC, 1 replies.
- Kafka Connect - Unknown magic byte - posted by Nick DeCoursin <n....@foodpanda.com> on 2017/02/07 18:49:59 UTC, 7 replies.
- Reg: Kafka Kerberos - posted by BigData dev <bi...@gmail.com> on 2017/02/08 00:25:32 UTC, 0 replies.
- How to measure the load capacity of kafka cluster - posted by Jiecxy <25...@qq.com> on 2017/02/08 01:45:20 UTC, 1 replies.
- KTable and cleanup.policy=compact - posted by Mathieu Fenniak <ma...@replicon.com> on 2017/02/08 02:39:22 UTC, 9 replies.
- KIP-122: Add a tool to Reset Consumer Group Offsets - posted by Jorge Esteban Quilcate Otoya <qu...@gmail.com> on 2017/02/08 02:43:16 UTC, 21 replies.
- Kafka Streams: Is automatic repartitioning before joins public/stable API? - posted by Dmitry Minkovsky <dm...@gmail.com> on 2017/02/08 03:06:10 UTC, 2 replies.
- Kafka Client 0.8.2.2 talks to Kafka Server 0.10.1.1 - posted by Jeffrey Zhang <xi...@salesforce.com> on 2017/02/08 03:42:34 UTC, 9 replies.
- Getting CommitFailedException in 0.10.2.0 due to member id is not valid or unknown - posted by Sachin Mittal <sj...@gmail.com> on 2017/02/08 08:49:52 UTC, 10 replies.
- FINAL REMINDER: CFP for ApacheCon closes February 11th - posted by Rich Bowen <rb...@apache.org> on 2017/02/08 14:09:58 UTC, 0 replies.
- jmxterm workaround for getting metrics; Problem with custom metrics reporter - posted by Jendrik Poloczek <je...@madewithtea.com> on 2017/02/08 16:20:32 UTC, 0 replies.
- Reg: Reading consumer groups and lag - posted by Sumit Maheshwari <su...@gmail.com> on 2017/02/08 16:50:54 UTC, 2 replies.
- Re: Kerberos/SASL Enabled Kafka - broker fails NoAuth due ACL - posted by Ashish Bhushan <as...@gmail.com> on 2017/02/08 18:18:26 UTC, 4 replies.
- Kafka Streams: How to best maintain changelog indices using the DSL? - posted by Dmitry Minkovsky <dm...@gmail.com> on 2017/02/08 18:22:09 UTC, 4 replies.
- Shutting down a Streams job - posted by Elias Levy <fe...@gmail.com> on 2017/02/08 19:15:40 UTC, 4 replies.
- KIP-121 [VOTE]: Add KStream peek method - posted by Steven Schlansker <ss...@opentable.com> on 2017/02/09 00:45:54 UTC, 10 replies.
- Kafka monitoring - posted by Nabajyoti Dash <na...@gmail.com> on 2017/02/09 08:49:16 UTC, 1 replies.
- Reducing replication factor of Kafka Topic - posted by Shaik M <mu...@gmail.com> on 2017/02/09 10:35:52 UTC, 2 replies.
- Kafka consumer offset location - posted by Igor Kuzmenko <f1...@gmail.com> on 2017/02/09 14:26:31 UTC, 2 replies.
- ProcessorContext commit question - posted by Adrian McCague <Ad...@zopa.com> on 2017/02/09 16:06:55 UTC, 3 replies.
- ConsumerInterceptor in Tomcat app - posted by Isabelle Giguère <ig...@opentext.com> on 2017/02/09 17:27:16 UTC, 0 replies.
- mirror-maker and firewalls - posted by Robert Friberg <ro...@devrex.se> on 2017/02/09 22:01:26 UTC, 0 replies.
- Partitioning behavior of Kafka Streams without explicit StreamPartitioner - posted by Steven Schlansker <ss...@opentable.com> on 2017/02/09 23:49:41 UTC, 6 replies.
- Fw: Exception when using simple consumer fetching offsets. - posted by James Teng <te...@outlook.com> on 2017/02/10 06:14:08 UTC, 0 replies.
- Messages not received (C/C++ client) - posted by 飘落 <sk...@qq.com> on 2017/02/10 09:50:37 UTC, 0 replies.
- about producer and consumer api - posted by VIVEK KUMAR MISHRA 13BIT0066 <vi...@vit.ac.in> on 2017/02/10 10:21:55 UTC, 1 replies.
- Old producer slow/no recovery on broker failure - posted by Thomas Becker <to...@Tivo.com> on 2017/02/10 15:10:07 UTC, 0 replies.
- [VOTE] 0.10.2.0 RC1 - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/10 16:51:20 UTC, 5 replies.
- Passing SSL client principal to custom JAAS module with SSL or SASL_SSL - posted by Christopher Shannon <ch...@gmail.com> on 2017/02/10 17:46:33 UTC, 4 replies.
- Is anyone running Kafka on CoreOS? - posted by James Cheng <wu...@gmail.com> on 2017/02/10 18:07:32 UTC, 0 replies.
- Re: Table a KStream - posted by Nick DeCoursin <n....@foodpanda.com> on 2017/02/10 21:49:28 UTC, 5 replies.
- Kafka 0.10 and ZK 3.4.8 dependency upgrade - posted by R Krishna <kr...@gmail.com> on 2017/02/11 00:54:28 UTC, 0 replies.
- consumer metrics for Spark streaming - posted by Mohammad Kargar <mk...@phemi.com> on 2017/02/11 02:08:49 UTC, 0 replies.
- sending mailchimp data to kafka cluster using producer api - posted by VIVEK KUMAR MISHRA 13BIT0066 <vi...@vit.ac.in> on 2017/02/11 11:45:41 UTC, 0 replies.
- Error while committing offsets. java.io.EOFException: Received -1 when reading from channel, socket has likely been closed. - posted by Upendra Yadav <up...@gmail.com> on 2017/02/13 14:38:58 UTC, 1 replies.
- Producer accept InputStream or ByteBuffer - posted by Per Steffensen <pe...@gmail.com> on 2017/02/13 16:29:29 UTC, 0 replies.
- KTable TTL - posted by Ara Ebrahimi <ar...@argyledata.com> on 2017/02/13 16:57:28 UTC, 1 replies.
- Kafka streams: Getting a state store associated to a processor - posted by Adam Warski <ad...@warski.org> on 2017/02/13 18:59:41 UTC, 8 replies.
- Re: Need suggestion on sending XML files via kafka - posted by Prashanth Venkatesan <pr...@gmail.com> on 2017/02/13 19:36:58 UTC, 1 replies.
- Can I maintain several open connection mechanisms in a Secure cluster? - posted by Stephane Maarek <st...@simplemachines.com.au> on 2017/02/14 01:07:58 UTC, 1 replies.
- Can principal be groups for SASL Kerberos? - posted by Stephane Maarek <st...@simplemachines.com.au> on 2017/02/14 04:39:02 UTC, 1 replies.
- What to set for Super users for Kafka cluster? - posted by Stephane Maarek <st...@simplemachines.com.au> on 2017/02/14 06:36:09 UTC, 1 replies.
- Request for JIRA access - posted by Thomas Dutta <th...@gmail.com> on 2017/02/14 08:31:44 UTC, 2 replies.
- Purpose of the metadata field of Offset Commit and Fetch - posted by Henning Røigaard-Petersen <hr...@edlund.dk> on 2017/02/14 09:12:32 UTC, 0 replies.
- get function - posted by Samy CHBINOU <sa...@greenflops.com> on 2017/02/14 16:38:14 UTC, 0 replies.
- [VOTE] 0.10.2.0 RC2 - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/14 18:39:59 UTC, 6 replies.
- Auto creation of Topic and Security - posted by Stephane Maarek <st...@simplemachines.com.au> on 2017/02/15 03:05:52 UTC, 0 replies.
- KTable Windowed state store name - posted by Shimi Kiviti <sh...@gmail.com> on 2017/02/15 08:35:06 UTC, 2 replies.
- Schema registry - posted by 陈江枫 <ka...@gmail.com> on 2017/02/15 09:48:28 UTC, 0 replies.
- How to choose one broker as Group Coordinator - posted by Yuanjia <yu...@163.com> on 2017/02/15 09:59:08 UTC, 3 replies.
- 答复: Re: How to choose one broker as Group Coordinator - posted by Hu Xi <hu...@hotmail.com> on 2017/02/15 10:17:29 UTC, 0 replies.
- Kafka Lag monitor + SASL - posted by Shrikant Patel <SP...@pdxinc.com> on 2017/02/15 13:52:57 UTC, 0 replies.
- RocksDB error when running Kafka with a larger data set - posted by Frank Lyaruu <fl...@gmail.com> on 2017/02/15 14:38:30 UTC, 3 replies.
- Reg: Kafka HDFS Connector with (HDFS SSL enabled) - posted by BigData dev <bi...@gmail.com> on 2017/02/15 19:03:39 UTC, 1 replies.
- Kafka topics for logging from multiple apps - posted by Ram Vittal <ra...@xpo.com> on 2017/02/15 19:54:59 UTC, 0 replies.
- Re: Kafka Connect gets into a rebalance loop - posted by Willy Hoang <wi...@blueapron.com.INVALID> on 2017/02/15 20:49:24 UTC, 0 replies.
- Changing offsets.retention.minutes - posted by Neelesh <ne...@gmail.com> on 2017/02/16 01:39:32 UTC, 4 replies.
- Re: [kafka-clients] [VOTE] 0.10.2.0 RC2 - posted by Jun Rao <ju...@confluent.io> on 2017/02/16 02:04:12 UTC, 3 replies.
- Kafka exception - posted by 揣立武 <ch...@meituan.com> on 2017/02/16 06:29:25 UTC, 2 replies.
- Is there any command can be used to get broker.id on one of broker with command? - posted by kay James <my...@gmail.com> on 2017/02/16 06:42:24 UTC, 4 replies.
- Powered by Kafka - posted by Martin Dobmeier <ma...@gmail.com> on 2017/02/16 07:36:13 UTC, 0 replies.
- Role of Zookeeper in Kafka Rest Proxy - posted by Stephane Maarek <st...@simplemachines.com.au> on 2017/02/16 22:55:47 UTC, 4 replies.
- Can't produce message with SASL: timeout error - posted by Stephane Maarek <st...@simplemachines.com.au> on 2017/02/17 05:04:53 UTC, 2 replies.
- System went OutOfMemory when running Kafka-Streaming - posted by Deepak Pengoria <de...@gmail.com> on 2017/02/17 13:30:40 UTC, 1 replies.
- conflicts between consumer groups? seeing many duplicate records - posted by Jon Yeargers <jo...@cedexis.com> on 2017/02/17 16:31:39 UTC, 0 replies.
- Newbie question: kerberos with Kafka and zookeeper - posted by Raghav <ra...@gmail.com> on 2017/02/17 16:56:07 UTC, 1 replies.
- Re: log.flush.interval.messages setting of Kafka 0.9.0.0 - posted by Colin McCabe <cm...@apache.org> on 2017/02/17 17:52:05 UTC, 0 replies.
- Kafka 0.9.0.1 Direct buffer memory OOM - posted by vinay gupta <vi...@yahoo.com.INVALID> on 2017/02/17 19:39:27 UTC, 0 replies.
- optimal retention and deletion policy - posted by mohammad ahmad <mn...@gmail.com> on 2017/02/18 04:32:08 UTC, 0 replies.
- Producer acks=1, clean broker shutdown and data loss - posted by Nick Travers <n....@gmail.com> on 2017/02/19 01:04:41 UTC, 0 replies.
- Storm kafka integration - posted by pradeep s <sr...@gmail.com> on 2017/02/19 19:49:11 UTC, 2 replies.
- Frequently shrink/expand ISR on one broker - posted by Jun MA <mj...@gmail.com> on 2017/02/19 22:13:05 UTC, 1 replies.
- Log twice ProducerConfig & ConsumerConfig values - posted by Simon Teles <st...@isi.nc> on 2017/02/20 00:04:57 UTC, 1 replies.
- Kafka Schema Registry JAAS file - posted by Stephane Maarek <st...@simplemachines.com.au> on 2017/02/20 00:21:43 UTC, 0 replies.
- Security Documentation contradiction / misleading ? - posted by Stephane Maarek <st...@simplemachines.com.au> on 2017/02/20 00:28:30 UTC, 2 replies.
- JMX metrics for replica lag time - posted by Jun MA <mj...@gmail.com> on 2017/02/20 03:56:52 UTC, 6 replies.
- Kafka to connect to Azure Data Lake - posted by An...@cognizant.com on 2017/02/20 15:39:55 UTC, 0 replies.
- metric.reporters vs. kafka.metrics.reporters? - posted by Mohammad Kargar <mk...@phemi.com> on 2017/02/20 15:46:49 UTC, 0 replies.
- Where is offset recorded? - posted by Jean Changyi <je...@gmail.com> on 2017/02/21 01:02:23 UTC, 3 replies.
- Need guidance to create a pipeline - posted by Raymond Xie <xi...@gmail.com> on 2017/02/21 02:19:08 UTC, 0 replies.
- Implementing a non-key in Kafka Streams using the Processor API - posted by Frank Lyaruu <fl...@gmail.com> on 2017/02/21 07:35:37 UTC, 8 replies.
- Heartbeats while consuming a message in kafka-python - posted by Martin Sucha <ms...@exponea.com> on 2017/02/21 15:24:12 UTC, 6 replies.
- hitting the throughput limit on a cluster? - posted by Jon Yeargers <jo...@cedexis.com> on 2017/02/21 15:29:33 UTC, 3 replies.
- Kafka colapsed due to OutOfMemory - posted by Fernando Bugni <fe...@gmail.com> on 2017/02/21 17:48:16 UTC, 0 replies.
- KTable send old values API - posted by Dmitry Minkovsky <dm...@gmail.com> on 2017/02/21 22:01:40 UTC, 4 replies.
- Kafka with SSL (question about certificate management) - posted by Raghav <ra...@gmail.com> on 2017/02/21 23:52:21 UTC, 0 replies.
- How to stop Kafka Mirror Maker - posted by Qian Zhu <qi...@trulia.com> on 2017/02/22 01:14:55 UTC, 1 replies.
- Consumption on a explicitly (dynamically) created topic has a 5 minute delay - posted by Jaikiran Pai <ja...@gmail.com> on 2017/02/22 07:46:20 UTC, 0 replies.
- [ANNOUNCE] Apache Kafka 0.10.2.0 Released - posted by Ewen Cheslack-Postava <ew...@apache.org> on 2017/02/22 08:33:02 UTC, 14 replies.
- [KIP-94] SessionWindows - IndexOutOfBoundsException in simple use case - posted by Marco Abitabile <ma...@gmail.com> on 2017/02/22 09:35:02 UTC, 1 replies.
- Consumer / Streams causes deletes in __consumer_offsets? - posted by Mathieu Fenniak <ma...@replicon.com> on 2017/02/22 16:08:21 UTC, 8 replies.
- Scaling To Many Kafka Consumers For Particular Topic - posted by Antony Vo <an...@gmail.com> on 2017/02/22 17:17:13 UTC, 2 replies.
- Current offset for partition out of range; reset offset - posted by "Ghosh, Achintya (Contractor)" <Ac...@comcast.com> on 2017/02/22 19:33:52 UTC, 0 replies.
- Question about messages in __consumer_offsets topic - posted by Jun MA <mj...@gmail.com> on 2017/02/22 23:50:11 UTC, 6 replies.
- Simple data-driven app design using Kafka - posted by Peter Figliozzi <pe...@gmail.com> on 2017/02/23 03:29:17 UTC, 2 replies.
- How to change the logging level or logging place of KafkaServerStable? - posted by 이산하 <sa...@gmail.com> on 2017/02/23 08:20:40 UTC, 0 replies.
- Creating topic partitions automatically using python - posted by VIVEK KUMAR MISHRA 13BIT0066 <vi...@vit.ac.in> on 2017/02/23 13:13:22 UTC, 2 replies.
- Pattern to create Task with dependencies (DI) - posted by Petr Novak <os...@gmail.com> on 2017/02/23 13:47:43 UTC, 0 replies.
- kafka streams locking issue in 0.10.20.0 - posted by Ara Ebrahimi <ar...@argyledata.com> on 2017/02/23 18:25:33 UTC, 3 replies.
- Overriding JAAS config for connector - posted by Stephen Durfey <sj...@gmail.com> on 2017/02/23 20:09:01 UTC, 4 replies.
- Immutable Record with Kafka Stream - posted by Kohki Nishio <ta...@gmail.com> on 2017/02/24 15:20:13 UTC, 8 replies.
- Scaling up kafka consumers - posted by Jakub Stransky <st...@gmail.com> on 2017/02/24 15:30:03 UTC, 3 replies.
- Creating topic partitions using python - posted by VIVEK KUMAR MISHRA 13BIT0066 <vi...@vit.ac.in> on 2017/02/24 18:59:35 UTC, 0 replies.
- Is there a list of companies using Kafka Streams? - posted by Tianji Li <sk...@gmail.com> on 2017/02/25 02:21:21 UTC, 0 replies.
- Kafka Streams vs Spark Streaming - posted by Tianji Li <sk...@gmail.com> on 2017/02/25 02:22:45 UTC, 21 replies.
- No main class set in JAR; please specify one with --class and java.lang.ClassNotFoundException - posted by Raymond Xie <xi...@gmail.com> on 2017/02/25 20:50:05 UTC, 7 replies.
- Kafka SASL and custom LoginModule and Authorizer - posted by Christian <en...@gmail.com> on 2017/02/26 02:48:04 UTC, 2 replies.
- Re: Getting NotLeaderForPartitionException in kafka broker - posted by 宋鑫/NemoVisky <xi...@cimc.com> on 2017/02/26 04:23:42 UTC, 0 replies.
- Does kafka send the acks response to the producer after flush the messages to the disk or just keep them in the memory - posted by Jiecxy <25...@qq.com> on 2017/02/26 09:39:55 UTC, 1 replies.
- Lock Exception - Failed to lock the state directory - posted by Dan Ofir <da...@personali.com> on 2017/02/26 13:37:02 UTC, 2 replies.
- creating partitions programmatically - posted by VIVEK KUMAR MISHRA 13BIT0066 <vi...@vit.ac.in> on 2017/02/26 14:42:38 UTC, 4 replies.
- partition creation using python api - posted by VIVEK KUMAR MISHRA 13BIT0066 <vi...@vit.ac.in> on 2017/02/27 06:20:31 UTC, 0 replies.
- Kafka Connect - posted by VIVEK KUMAR MISHRA 13BIT0066 <vi...@vit.ac.in> on 2017/02/27 13:35:27 UTC, 4 replies.
- Stream topology with multiple Kaka clusters - posted by Mahendra Kariya <ma...@go-jek.com> on 2017/02/27 13:37:57 UTC, 2 replies.
- Large state directory with Kafka Streams - posted by Ian Duffy <ia...@ianduffy.ie> on 2017/02/27 14:04:03 UTC, 5 replies.
- Updation of data in kafka topic based on changes in data sources. - posted by VIVEK KUMAR MISHRA 13BIT0066 <vi...@vit.ac.in> on 2017/02/27 14:41:00 UTC, 0 replies.
- zookeeper.set.acl=false not considered by ZookeeperLeaderElector - posted by Stevo Slavić <ss...@gmail.com> on 2017/02/27 15:03:40 UTC, 2 replies.
- Kafka MirrorMaker issues - posted by Le Cyberian <le...@gmail.com> on 2017/02/27 19:27:32 UTC, 0 replies.
- Kafka offset being reset - posted by Vishnu Gopal <vi...@live.com> on 2017/02/27 23:50:06 UTC, 2 replies.
- Kafkaconnect - posted by VIVEK KUMAR MISHRA 13BIT0066 <vi...@vit.ac.in> on 2017/02/28 11:55:22 UTC, 2 replies.
- slow consumer recovery after gc pause - posted by Mahdi Ben Hamida <ma...@signalfx.com> on 2017/02/28 17:10:00 UTC, 0 replies.
- Wait a few seconds before initializing state stores, so others don't have to wait before joining. - posted by Nicolas Fouché <nf...@onfocus.io> on 2017/02/28 17:10:08 UTC, 3 replies.
- Kafka streams questions - posted by Neil Moore <ne...@adobe.com> on 2017/02/28 21:31:17 UTC, 1 replies.
- Chatty StreamThread commit messages - posted by Steven Schlansker <ss...@opentable.com> on 2017/02/28 21:35:08 UTC, 0 replies.
- error in kafka producer - posted by shyla deshpande <de...@gmail.com> on 2017/02/28 22:22:29 UTC, 0 replies.