kafka-dev mailing list archives: June 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · Next »Thread · Author · Date
Jason Gustafson Re: [VOTE] KIP-281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User Fri, 01 Jun, 00:05
Jason Gustafson (JIRA) [jira] [Created] (KAFKA-6979) Add max.block.ms to consumer for default behavior Fri, 01 Jun, 01:00
Jason Gustafson Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position Fri, 01 Jun, 01:00
Dong Lin Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position Fri, 01 Jun, 01:09
Guozhang Wang Re: [DISCUSS] KIP-307: Allow to define custom processor names with KStreams DSL Fri, 01 Jun, 01:40
逐风者的祝福 回复: [DISCUSS] Why don't support web UI Fri, 01 Jun, 03:29
Skrzypek, Jonathan RE: [VOTE] KIP-235 Add DNS alias support for secured connection Fri, 01 Jun, 10:28
Manikumar (JIRA) [jira] [Resolved] (KAFKA-3743) kafka-server-start.sh: Unhelpful error message Fri, 01 Jun, 10:35
Rajini Sivaram Re: Apache Kafka 2.0.0 Release Progress Fri, 01 Jun, 10:35
John Lu (JIRA) [jira] [Created] (KAFKA-6980) Recommended MaxDirectMemorySize for consumers Fri, 01 Jun, 13:39
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-6936) Scala API Wrapper for Streams uses default serializer for table aggregate Fri, 01 Jun, 14:13
Ismael Juma (JIRA) [jira] [Resolved] (KAFKA-6973) setting invalid timestamp causes Kafka broker restart to fail Fri, 01 Jun, 14:15
Manikumar (JIRA) [jira] [Resolved] (KAFKA-6581) ConsumerGroupCommand hangs if even one of the partition is unavailable Fri, 01 Jun, 14:21
Manikumar (JIRA) [jira] [Resolved] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition. Fri, 01 Jun, 14:33
Manikumar (JIRA) [jira] [Resolved] (KAFKA-3503) Throw exception on missing/non-existent partition Fri, 01 Jun, 14:37
Manikumar (JIRA) [jira] [Resolved] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied Fri, 01 Jun, 14:58
Manikumar (JIRA) [jira] [Resolved] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned Fri, 01 Jun, 14:59
Manikumar (JIRA) [jira] [Resolved] (KAFKA-3011) Consumer.poll(0) blocks if Kafka not accessible Fri, 01 Jun, 15:23
Manikumar (JIRA) [jira] [Resolved] (KAFKA-3457) KafkaConsumer.committed(...) hangs forever if port number is wrong Fri, 01 Jun, 15:32
Manikumar (JIRA) [jira] [Resolved] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected Fri, 01 Jun, 15:32
Manikumar (JIRA) [jira] [Resolved] (KAFKA-4571) Consumer fails to retrieve messages if started before producer Fri, 01 Jun, 15:59
Manikumar (JIRA) [jira] [Resolved] (KAFKA-4751) kafka-clients-0.9.0.2.4.2.11-1 issue not throwing exception. Fri, 01 Jun, 16:31
Manikumar (JIRA) [jira] [Resolved] (KAFKA-5304) Kafka Producer throwing infinite NullPointerExceptions Fri, 01 Jun, 16:41
Vahid S Hashemian Re: [VOTE] KIP-231: Improve the Required ACL of ListGroups API Fri, 01 Jun, 17:21
Manikumar (JIRA) [jira] [Resolved] (KAFKA-5424) KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster Fri, 01 Jun, 18:30
Guozhang Wang Re: [DISCUSS] KIP-280: Enhanced log compaction Fri, 01 Jun, 18:51
Koen De Groote Someone to review KAFKA-6919, one line change for faulty documentation Fri, 01 Jun, 20:02
Arseniy Tashoyan [DISCUSS] KIP-308: GetOffsetShell: new KafkaConsumer API, support for multiple topics, minimize the number of requests to server Fri, 01 Jun, 21:32
Apache Jenkins Server Build failed in Jenkins: kafka-1.0-jdk7 #194 Fri, 01 Jun, 22:53
Arjun Satish (JIRA) [jira] [Created] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters Fri, 01 Jun, 23:48
Ismael Juma (JIRA) [jira] [Resolved] (KAFKA-6760) responses not logged properly in controller Fri, 01 Jun, 23:49
Ismael Juma (JIRA) [jira] [Resolved] (KAFKA-6965) log4j:WARN log messages printed when running kafka-console-producer OOB Sat, 02 Jun, 00:26
wade wu (JIRA) [jira] [Created] (KAFKA-6982) java.lang.ArithmeticException: / by zero Sat, 02 Jun, 00:53
wade wu (JIRA) [jira] [Created] (KAFKA-6983) Error while deleting segments - The process cannot access the file because it is being used by another process Sat, 02 Jun, 01:04
Apache Jenkins Server Build failed in Jenkins: kafka-trunk-jdk8 #2692 Sat, 02 Jun, 02:35
Apache Jenkins Server Build failed in Jenkins: kafka-1.1-jdk7 #139 Sat, 02 Jun, 04:09
Remil (JIRA) [jira] [Created] (KAFKA-6984) Question Sat, 02 Jun, 07:51
Ranjeet Ranjan (JIRA) [jira] [Created] (KAFKA-6985) Error connection between cluster node Sat, 02 Jun, 09:11
Boyang Chen (JIRA) [jira] [Created] (KAFKA-6986) Export Admin Client metrics through Stream Threads Sat, 02 Jun, 19:18
Apache Jenkins Server Build failed in Jenkins: kafka-trunk-jdk10 #161 Sat, 02 Jun, 22:30
Apache Jenkins Server Jenkins build is back to normal : kafka-trunk-jdk8 #2693 Sat, 02 Jun, 23:37
Jason Gustafson (JIRA) [jira] [Resolved] (KAFKA-6743) ConsumerPerformance fails to consume all messages on topics with large number of partitions Sat, 02 Jun, 23:50
Apache Jenkins Server Jenkins build is back to normal : kafka-trunk-jdk10 #162 Sun, 03 Jun, 01:24
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl Sun, 03 Jun, 18:00
Apache Jenkins Server Build failed in Jenkins: kafka-0.11.0-jdk7 #371 Sun, 03 Jun, 19:56
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-4960) Invalid state store exception Mon, 04 Jun, 05:16
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-5974) Removed unused parameter ProcessorContext Mon, 04 Jun, 05:22
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations Mon, 04 Jun, 05:36
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info Mon, 04 Jun, 05:37
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-5058) Add a sensor to KafkaStreams to track records that have been dropped due to having a null key Mon, 04 Jun, 05:43
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-5739) Rewrite KStreamPeekTest at processor level avoiding driver usage Mon, 04 Jun, 05:45
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-6355) transient failure in org.apache.kafka.streams.integration.EosIntegrationTest.shouldBeAbleToRunWithTwoSubtopologies Mon, 04 Jun, 05:49
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-6092) Time passed in punctuate call is currentTime, not punctuate schedule time. Mon, 04 Jun, 05:59
Andras Beni (JIRA) [jira] [Created] (KAFKA-6987) Reimplement KafkaFuture with CopletableFuture Mon, 04 Jun, 07:44
Luís Cabral [VOTE] KIP-280: Enhanced log compaction Mon, 04 Jun, 09:04
Viktor Somogyi Re: [DISCUSS] KIP-308: GetOffsetShell: new KafkaConsumer API, support for multiple topics, minimize the number of requests to server Mon, 04 Jun, 09:57
lkgen (JIRA) [jira] [Created] (KAFKA-6988) Kafka windows classpath too long Mon, 04 Jun, 14:46
Guozhang Wang Re: [VOTE] KIP-280: Enhanced log compaction Mon, 04 Jun, 16:45
Anil (JIRA) [jira] [Reopened] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException Mon, 04 Jun, 17:01
Guozhang Wang (JIRA) [jira] [Created] (KAFKA-6989) Support Async Processing in Streams Mon, 04 Jun, 17:13
Soumya Acharya Re: [jira] [Created] (KAFKA-6989) Support Async Processing in Streams Mon, 04 Jun, 18:33
Eugen Feller (JIRA) [jira] [Created] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread Mon, 04 Jun, 21:34
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API Mon, 04 Jun, 22:40
Guozhang Wang (JIRA) [jira] [Resolved] (KAFKA-5632) Message headers not supported by Kafka Streams Mon, 04 Jun, 22:48
McCaig, Rhys [DISCUSS] KIP-310: Add a Kafka Source Connector to Kafka Connect Tue, 05 Jun, 01:04
Dong Lin Re: [DISCUSS] KIP-253: Support in-order message delivery with partition expansion Tue, 05 Jun, 01:59
Dong Lin Re: [VOTE] KIP-232: Detect outdated metadata using leaderEpoch and partitionEpoch Tue, 05 Jun, 02:03
Matthias J. Sax Re: [jira] [Created] (KAFKA-6989) Support Async Processing in Streams Tue, 05 Jun, 02:03
Magesh kumar Nandakumar (JIRA) [jira] [Created] (KAFKA-6991) Connect Rest Extension Plugin issue with Class Loader Tue, 05 Jun, 05:15
Chia-Ping Tsai (JIRA) [jira] [Created] (KAFKA-6992) Configuring the batch.size to zero won't disable the batching entirely Tue, 05 Jun, 06:44
Ismael Juma (JIRA) [jira] [Resolved] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException Tue, 05 Jun, 07:02
Lee Dongjin (JIRA) [jira] [Created] (KAFKA-6993) Defective documentations for KStream/KTable methods Tue, 05 Jun, 07:39
Virgil Palanciuc How to initiate a KIP? Tue, 05 Jun, 08:54
Edoardo Comar (JIRA) [jira] [Created] (KAFKA-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent Tue, 05 Jun, 09:48
Manikumar (JIRA) [jira] [Resolved] (KAFKA-5940) kafka-delete-records.sh doesn't give any feedback when the JSON offset configuration file is invalid Tue, 05 Jun, 10:03
Manikumar (JIRA) [jira] [Resolved] (KAFKA-6972) Kafka ACL does not work expected with wildcard Tue, 05 Jun, 10:54
Manikumar (JIRA) [jira] [Resolved] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer Tue, 05 Jun, 10:54
Manikumar (JIRA) [jira] [Resolved] (KAFKA-6982) java.lang.ArithmeticException: / by zero Tue, 05 Jun, 10:57
Apache Jenkins Server Build failed in Jenkins: kafka-trunk-jdk8 #2701 Tue, 05 Jun, 14:56
Boyang Chen (JIRA) [jira] [Created] (KAFKA-6995) Make config "internal.leave.group.on.close" public Tue, 05 Jun, 15:07
Zeynep Arikoglu (JIRA) [jira] [Created] (KAFKA-6996) ConsumerGroupCommand.scala uses deprecated components Tue, 05 Jun, 15:11
Paolo Patierno KIP-176 and related PR : today deadline for merging in 2.0.0 Tue, 05 Jun, 15:15
Ismael Juma (JIRA) [jira] [Resolved] (KAFKA-6996) ConsumerGroupCommand.scala uses deprecated components Tue, 05 Jun, 15:23
Jason Gustafson Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position Tue, 05 Jun, 15:57
Richard Tjerngren I'd like permission to create a KIP Tue, 05 Jun, 17:09
Guozhang Wang Re: How to initiate a KIP? Tue, 05 Jun, 17:24
Guozhang Wang Re: I'd like permission to create a KIP Tue, 05 Jun, 17:26
Guozhang Wang Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position Tue, 05 Jun, 17:33
Bill Bejeck Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position Tue, 05 Jun, 18:48
Apache Jenkins Server Jenkins build is back to normal : kafka-trunk-jdk8 #2702 Tue, 05 Jun, 19:19
Aarti Gupta Discount code for kafka summit SF 2018 Tue, 05 Jun, 19:31
Magesh kumar Nandakumar (JIRA) [jira] [Created] (KAFKA-6997) Kafka run class doesn't exclude test-sources jar Tue, 05 Jun, 19:56
Matthias J. Sax (JIRA) [jira] [Resolved] (KAFKA-6730) Simplify state store recovery Tue, 05 Jun, 20:37
Apache Jenkins Server Build failed in Jenkins: kafka-1.1-jdk7 #140 Tue, 05 Jun, 20:56
Ewen Cheslack-Postava (JIRA) [jira] [Resolved] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters Tue, 05 Jun, 21:00
Dhruvil Shah Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position Tue, 05 Jun, 21:59
Jason Gustafson Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position Tue, 05 Jun, 22:17
Ted Yu Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position Tue, 05 Jun, 22:29
Matthias J. Sax (JIRA) [jira] [Created] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes Tue, 05 Jun, 22:45
Matthias J. Sax (JIRA) [jira] [Created] (KAFKA-6999) Document read-write lock usage of caching enabled stores Tue, 05 Jun, 22:47
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · Next »Thread · Author · Date
Box list
Dec 2019190
Nov 2019761
Oct 2019900
Sep 2019864
Aug 2019879
Jul 2019781
Jun 2019789
May 2019944
Apr 2019675
Mar 2019528
Feb 2019682
Jan 2019795
Dec 2018573
Nov 2018601
Oct 2018881
Sep 2018955
Aug 20181082
Jul 2018926
Jun 2018920
May 20181048
Apr 2018828
Mar 2018885
Feb 2018581
Jan 2018811
Dec 2017916
Nov 20171191
Oct 20171324
Sep 20171528
Aug 20171295
Jul 2017978
Jun 20172385
May 20173221
Apr 20171914
Mar 20172018
Feb 20172077
Jan 20172579
Dec 20161810
Nov 20161739
Oct 20161645
Sep 20161882
Aug 20161631
Jul 20161405
Jun 20161926
May 20162130
Apr 20162180
Mar 20162400
Feb 20161722
Jan 20161762
Dec 20151451
Nov 20152204
Oct 20151848
Sep 20151540
Aug 20151944
Jul 20152245
Jun 20151192
May 20151538
Apr 20151993
Mar 20151856
Feb 20151752
Jan 20151609
Dec 2014881
Nov 20141219
Oct 20141647
Sep 20141243
Aug 20141131
Jul 20141357
Jun 2014606
May 2014791
Apr 20141276
Mar 20141039
Feb 20141133
Jan 2014526
Dec 2013509
Nov 2013549
Oct 2013587
Sep 2013508
Aug 2013589
Jul 2013558
Jun 2013289
May 2013294
Apr 2013560
Mar 2013578
Feb 2013454
Jan 2013803
Dec 2012494
Nov 2012444
Oct 2012760
Sep 2012589
Aug 2012532
Jul 2012445
Jun 2012380
May 2012195
Apr 2012142
Mar 2012324
Feb 2012315
Jan 2012301
Dec 2011146
Nov 2011459
Oct 2011482
Sep 2011199
Aug 2011371
Jul 2011116