kafka-dev mailing list archives: January 2019

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · Next »Thread · Author · Date
Re: Kafka tests on a remote cluster
Pere Urbón Bayes   Re: Kafka tests on a remote cluster Tue, 01 Jan, 20:01
Pere Urbón Bayes [Discuss] Question on KIP-298: Error Handling in Kafka Connect Tue, 01 Jan, 20:11
Re: [EXTERNAL] [VOTE] KIP-382 MirrorMaker 2.0
McCaig, Rhys   Re: [EXTERNAL] [VOTE] KIP-382 MirrorMaker 2.0 Wed, 02 Jan, 03:46
Mickael Maison     Re: [EXTERNAL] [VOTE] KIP-382 MirrorMaker 2.0 Wed, 02 Jan, 11:10
Skrzypek, Jonathan       RE: [EXTERNAL] [VOTE] KIP-382 MirrorMaker 2.0 Wed, 02 Jan, 11:25
Ryanne Dolan         Re: [EXTERNAL] [VOTE] KIP-382 MirrorMaker 2.0 Thu, 03 Jan, 17:15
Jun Rao   Re: [VOTE] KIP-382 MirrorMaker 2.0 Fri, 04 Jan, 16:33
Ryanne Dolan     Re: [VOTE] KIP-382 MirrorMaker 2.0 Mon, 07 Jan, 23:49
Jun Rao       Re: [VOTE] KIP-382 MirrorMaker 2.0 Thu, 10 Jan, 00:11
Ryanne Dolan         Re: [VOTE] KIP-382 MirrorMaker 2.0 Thu, 10 Jan, 03:16
Jun Rao           Re: [VOTE] KIP-382 MirrorMaker 2.0 Thu, 10 Jan, 17:11
Becket Qin             Re: [VOTE] KIP-382 MirrorMaker 2.0 Sat, 12 Jan, 03:48
Ryanne Dolan               Re: [VOTE] KIP-382 MirrorMaker 2.0 Tue, 22 Jan, 17:43
[jira] [Created] (KAFKA-7779) Avoid unnecessary loop iteration in leastLoadedNode
huxihx (JIRA)   [jira] [Created] (KAFKA-7779) Avoid unnecessary loop iteration in leastLoadedNode Wed, 02 Jan, 09:23
[jira] [Created] (KAFKA-7780) Kafka client should validate topic-level configs and update only unique values
Manohar Vanam (JIRA)   [jira] [Created] (KAFKA-7780) Kafka client should validate topic-level configs and update only unique values Wed, 02 Jan, 11:20
[jira] [Created] (KAFKA-7781) Add validation check for Topic retention.ms property
Kamal Chandraprakash (JIRA)   [jira] [Created] (KAFKA-7781) Add validation check for Topic retention.ms property Wed, 02 Jan, 11:43
Manikumar (JIRA)   [jira] [Resolved] (KAFKA-7781) Add validation check for Topic retention.ms property Sun, 13 Jan, 13:20
[jira] [Created] (KAFKA-7782) cleanup policy for offsets topic should be configurable
Nir Barel (JIRA)   [jira] [Created] (KAFKA-7782) cleanup policy for offsets topic should be configurable Wed, 02 Jan, 12:03
Re: Permission to Create Content
Matthias J. Sax   Re: Permission to Create Content Wed, 02 Jan, 14:12
Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted.
Adam Bellemare   Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted. Wed, 02 Jan, 14:30
Jan Filipiak     Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted. Wed, 02 Jan, 20:06
Adam Bellemare       Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted. Wed, 02 Jan, 20:35
Jan Filipiak         Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted. Wed, 02 Jan, 20:52
John Roesler         Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted. Wed, 02 Jan, 22:44
Jan Filipiak           Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted. Mon, 07 Jan, 23:06
John Roesler             Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted. Fri, 11 Jan, 20:29
Jan Filipiak               Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted. Sun, 13 Jan, 21:05
Re: [DISCUSS] KIP-396: Add Commit/List Offsets Operations to AdminClient
Mickael Maison   Re: [DISCUSS] KIP-396: Add Commit/List Offsets Operations to AdminClient Wed, 02 Jan, 16:15
Re: [DISCUSS] KIP-345: Reduce multiple consumer rebalances by specifying member id
Mayuresh Gharat   Re: [DISCUSS] KIP-345: Reduce multiple consumer rebalances by specifying member id Wed, 02 Jan, 16:30
Boyang Chen   Re: [DISCUSS] KIP-345: Reduce multiple consumer rebalances by specifying member id Wed, 02 Jan, 17:24
Re: [DISCUSS] : KIP-410: Add metric for request handler thread pool utilization by request type
Mayuresh Gharat   Re: [DISCUSS] : KIP-410: Add metric for request handler thread pool utilization by request type Wed, 02 Jan, 16:36
Jenkins build is back to normal : kafka-trunk-jdk8 #3276
Apache Jenkins Server   Jenkins build is back to normal : kafka-trunk-jdk8 #3276 Wed, 02 Jan, 17:30
RE: [EXTERNAL] - Re: [DISCUSS] KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer
ChienHsing Wu   RE: [EXTERNAL] - Re: [DISCUSS] KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer Wed, 02 Jan, 17:54
ChienHsing Wu     RE: [EXTERNAL] - Re: [DISCUSS] KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer Mon, 07 Jan, 14:23
ChienHsing Wu       RE: [EXTERNAL] - Re: [DISCUSS] KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer Mon, 14 Jan, 14:12
ChienHsing Wu         RE: [EXTERNAL] - Re: [DISCUSS] KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer Mon, 21 Jan, 17:46
ChienHsing Wu           RE: [EXTERNAL] - Re: [DISCUSS] KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer Mon, 28 Jan, 14:49
Colin McCabe             Re: [EXTERNAL] - Re: [DISCUSS] KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer Tue, 29 Jan, 21:00
ChienHsing Wu               RE: [EXTERNAL] - Re: [DISCUSS] KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer Tue, 29 Jan, 21:35
Re: [VOTE] KIP-345: Introduce static membership protocol to reduce consumer rebalances
Boyang Chen   Re: [VOTE] KIP-345: Introduce static membership protocol to reduce consumer rebalances Wed, 02 Jan, 17:59
Harsha     Re: [VOTE] KIP-345: Introduce static membership protocol to reduce consumer rebalances Thu, 03 Jan, 23:44
Guozhang Wang     Re: [VOTE] KIP-345: Introduce static membership protocol to reduce consumer rebalances Fri, 04 Jan, 19:33
Boyang Chen       Re: [VOTE] KIP-345: Introduce static membership protocol to reduce consumer rebalances Fri, 04 Jan, 21:01
Jason Gustafson         Re: [VOTE] KIP-345: Introduce static membership protocol to reduce consumer rebalances Fri, 04 Jan, 23:50
Boyang Chen         Re: [VOTE] KIP-345: Introduce static membership protocol to reduce consumer rebalances Sat, 05 Jan, 00:58
Boyang Chen         Re: [VOTE] KIP-345: Introduce static membership protocol to reduce consumer rebalances Tue, 08 Jan, 21:41
Re: [Discuss] KIP-389: Enforce group.max.size to cap member metadata growth
Gwen Shapira   Re: [Discuss] KIP-389: Enforce group.max.size to cap member metadata growth Wed, 02 Jan, 18:59
Boyang Chen     Re: [Discuss] KIP-389: Enforce group.max.size to cap member metadata growth Wed, 02 Jan, 23:59
Stanislav Kozlovski       Re: [Discuss] KIP-389: Enforce group.max.size to cap member metadata growth Mon, 07 Jan, 08:21
Boyang Chen         Re: [Discuss] KIP-389: Enforce group.max.size to cap member metadata growth Mon, 07 Jan, 20:50
Stanislav Kozlovski           Re: [Discuss] KIP-389: Enforce group.max.size to cap member metadata growth Wed, 09 Jan, 12:25
Gwen Shapira             Re: [Discuss] KIP-389: Enforce group.max.size to cap member metadata growth Wed, 09 Jan, 18:54
Stanislav Kozlovski               Re: [Discuss] KIP-389: Enforce group.max.size to cap member metadata growth Thu, 10 Jan, 06:20
Re: [DISCUSS] KIP-392: Allow consumers to fetch from the closest replica
Jason Gustafson   Re: [DISCUSS] KIP-392: Allow consumers to fetch from the closest replica Wed, 02 Jan, 19:06
Jun Rao     Re: [DISCUSS] KIP-392: Allow consumers to fetch from the closest replica Fri, 11 Jan, 18:39
[jira] [Created] (KAFKA-7783) Improve testing of idempotent/transactional producer shutdown
Jason Gustafson (JIRA)   [jira] [Created] (KAFKA-7783) Improve testing of idempotent/transactional producer shutdown Wed, 02 Jan, 22:54
[jira] [Resolved] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId
Jason Gustafson (JIRA)   [jira] [Resolved] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId Wed, 02 Jan, 23:07
[jira] [Resolved] (KAFKA-1705) Add MR layer to Kafka
Gwen Shapira (JIRA)   [jira] [Resolved] (KAFKA-1705) Add MR layer to Kafka Thu, 03 Jan, 01:33
[jira] [Resolved] (KAFKA-1927) Replace requests in kafka.api with requests in org.apache.kafka.common.requests
Gwen Shapira (JIRA)   [jira] [Resolved] (KAFKA-1927) Replace requests in kafka.api with requests in org.apache.kafka.common.requests Thu, 03 Jan, 01:37
Build failed in Jenkins: kafka-2.0-jdk8 #209
Apache Jenkins Server   Build failed in Jenkins: kafka-2.0-jdk8 #209 Thu, 03 Jan, 02:27
Apache Jenkins Server     Build failed in Jenkins: kafka-2.0-jdk8 #210 Tue, 08 Jan, 19:56
Apache Jenkins Server       Jenkins build is back to normal : kafka-2.0-jdk8 #211 Wed, 09 Jan, 11:27
tinawenqiao Use KafkaAdminClient to get broker dynamic config “leader.replication.throttled.rate” and “follower.replication.throttled.rate” ,but returned null Thu, 03 Jan, 02:33
Rajini Sivaram   Re: Use KafkaAdminClient to get broker dynamic config “leader.replication.throttled.rate” and “follower.replication.throttled.rate” ,but returned null Thu, 03 Jan, 12:36
Jenkins build is back to normal : kafka-2.1-jdk8 #92
Apache Jenkins Server   Jenkins build is back to normal : kafka-2.1-jdk8 #92 Thu, 03 Jan, 03:24
Apache Jenkins Server Build failed in Jenkins: kafka-2.1-jdk8 #93 Thu, 03 Jan, 09:24
Apache Jenkins Server   Jenkins build is back to normal : kafka-2.1-jdk8 #94 Fri, 04 Jan, 04:43
[jira] [Created] (KAFKA-7784) Producer & message format : better management when inter.broker.protocol.version is overrided
Hervé RIVIERE (JIRA)   [jira] [Created] (KAFKA-7784) Producer & message format : better management when inter.broker.protocol.version is overrided Thu, 03 Jan, 10:20
[jira] [Created] (KAFKA-7785) Move DefaultPartitionGrouper (and PartitionGrouper) to o.a.k.streams.processor.internals package
Jacek Laskowski (JIRA)   [jira] [Created] (KAFKA-7785) Move DefaultPartitionGrouper (and PartitionGrouper) to o.a.k.streams.processor.internals package Thu, 03 Jan, 14:54
Re: Suggestion to make 0 grace period the default for suppress
Guozhang Wang   Re: Suggestion to make 0 grace period the default for suppress Thu, 03 Jan, 19:16
Boyang Chen   Re: Suggestion to make 0 grace period the default for suppress Thu, 03 Jan, 20:05
Matthias J. Sax     Re: Suggestion to make 0 grace period the default for suppress Thu, 03 Jan, 20:35
Guozhang Wang       Re: Suggestion to make 0 grace period the default for suppress Fri, 04 Jan, 19:26
Re: [DISCUSS] KIP-360: Improve handling of unknown producer
Guozhang Wang   Re: [DISCUSS] KIP-360: Improve handling of unknown producer Thu, 03 Jan, 21:37
Jason Gustafson     Re: [DISCUSS] KIP-360: Improve handling of unknown producer Mon, 07 Jan, 23:52
Guozhang Wang       Re: [DISCUSS] KIP-360: Improve handling of unknown producer Tue, 08 Jan, 00:41
Re: [DISCUSS] KIP-262 Metadata should include the number of state stores for task
Richard Yu   Re: [DISCUSS] KIP-262 Metadata should include the number of state stores for task Thu, 03 Jan, 21:41
Matthias J. Sax     Re: [DISCUSS] KIP-262 Metadata should include the number of state stores for task Sat, 05 Jan, 14:55
Re: [DISCUSS] KIP-408: Add Asynchronous Processing to Kafka Streams
Richard Yu   Re: [DISCUSS] KIP-408: Add Asynchronous Processing to Kafka Streams Thu, 03 Jan, 21:42
Boyang Chen     Re: [DISCUSS] KIP-408: Add Asynchronous Processing to Kafka Streams Fri, 04 Jan, 03:28
Richard Yu       Re: [DISCUSS] KIP-408: Add Asynchronous Processing to Kafka Streams Fri, 04 Jan, 04:26
Richard Yu         Re: [DISCUSS] KIP-408: Add Asynchronous Processing to Kafka Streams Fri, 04 Jan, 23:42
Re: Tests to emulate leader change(investigation of KAFKA-7680)
Guozhang Wang   Re: Tests to emulate leader change(investigation of KAFKA-7680) Thu, 03 Jan, 21:54
[jira] [Resolved] (KAFKA-7734) Metrics tags should use LinkedHashMap to guarantee ordering
Guozhang Wang (JIRA)   [jira] [Resolved] (KAFKA-7734) Metrics tags should use LinkedHashMap to guarantee ordering Fri, 04 Jan, 01:15
Apache Jenkins Server Build failed in Jenkins: kafka-trunk-jdk8 #3278 Fri, 04 Jan, 01:56
Apache Jenkins Server   Build failed in Jenkins: kafka-trunk-jdk8 #3279 Fri, 04 Jan, 03:56
Apache Jenkins Server     Jenkins build is back to normal : kafka-trunk-jdk8 #3280 Fri, 04 Jan, 14:34
[jira] [Created] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH
Anna Povzner (JIRA)   [jira] [Created] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH Fri, 04 Jan, 07:13
Jason Gustafson (JIRA)   [jira] [Resolved] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH Wed, 09 Jan, 19:28
[jira] [Resolved] (KAFKA-7752) zookeeper-security-migration.sh does not remove ACL on kafka-acl-extended
Manikumar (JIRA)   [jira] [Resolved] (KAFKA-7752) zookeeper-security-migration.sh does not remove ACL on kafka-acl-extended Fri, 04 Jan, 10:47
[jira] [Resolved] (KAFKA-7580) Unit Test 'shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir' fails when run as root user
Sarvesh Tamba (JIRA)   [jira] [Resolved] (KAFKA-7580) Unit Test 'shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir' fails when run as root user Fri, 04 Jan, 13:59
Re: [DISCUSS] KIP-411: Add option to make Kafka Connect task client ID values unique
Ewen Cheslack-Postava   Re: [DISCUSS] KIP-411: Add option to make Kafka Connect task client ID values unique Fri, 04 Jan, 15:38
Konstantine Karantasis     Re: [DISCUSS] KIP-411: Add option to make Kafka Connect task client ID values unique Sat, 05 Jan, 01:54
Paul Davidson       Re: [DISCUSS] KIP-411: Add option to make Kafka Connect task client ID values unique Mon, 07 Jan, 01:24
Ryanne Dolan         Re: [DISCUSS] KIP-411: Add option to make Kafka Connect task client ID values unique Mon, 07 Jan, 18:27
Paul Davidson           Re: [DISCUSS] KIP-411: Add option to make Kafka Connect task client ID values unique Mon, 07 Jan, 19:18
Randall Hauch             Re: [DISCUSS] KIP-411: Add option to make Kafka Connect task client ID values unique Wed, 09 Jan, 03:16
Paul Davidson               Re: [DISCUSS] KIP-411: Add option to make Kafka Connect task client ID values unique Fri, 11 Jan, 23:39
Paul Davidson     Re: [DISCUSS] KIP-411: Add option to make Kafka Connect task client ID values unique Mon, 07 Jan, 01:16
[jira] [Resolved] (KAFKA-6928) StreamsPartitionAssignor is double retrying within InternalTopicManager
Guozhang Wang (JIRA)   [jira] [Resolved] (KAFKA-6928) StreamsPartitionAssignor is double retrying within InternalTopicManager Fri, 04 Jan, 18:52
Re: Vote for KIP-393 (Fix time windowed serde to deserialize changelog topic)
Guozhang Wang   Re: Vote for KIP-393 (Fix time windowed serde to deserialize changelog topic) Fri, 04 Jan, 19:35
Shawn Nguyen     Re: Vote for KIP-393 (Fix time windowed serde to deserialize changelog topic) Fri, 04 Jan, 21:47
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · Next »Thread · Author · Date
Box list
Feb 2019215
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