Trunk by SylviaVargasCTL · Pull Request #42 · apache/kafka

SylviaVargasCTL · 2015-01-15T18:50:01Z

No description provided.

… Holoman reviewed by Gwen Shapira and Joe Stein

… reviewed by Jun Rao

…in; reviewed by Jun Rao

…t any data cause process to not start; reviewed by Neha Narkhede

…t; patched by Jun Rao; reviewed by Neha Narkhede

…work again; reviewed by Neha Narkhede

…; reviewed by Joel Koshy

…e Spike to 100% when network connection is lost; patched by Ewen Cheslack-Postava; patched by Ewen Cheslack-Postava; reviewed by Jun Rao

…the new java client; patched by Jun Rao; reviewed by Jay Kreps

…pi to the new java client; patched by Jun Rao; reviewed by Neha Narkhede

…ddress patch by Jeff Holoman reviewed by Jay Krepps and Gwen Shapira

…/deserializer api to the new java client; patched by Jun Rao; reviewed by Manikumar Reddy and Neha Narkhede

…ly contains unknown partitions; patched by Jun Rao; reviewed by Neha Narkhede

…ewed by Neha Narkhede and Ewen Cheslack-Postava

… reviewed by Neha Narkhede

…erializer api to the new java client; patched by Jun Rao

…hed by Manikumar Reddy; reviewed by Jay Kreps and Jun Rao

…ence of a jira.ini file, during patch submission; reviewed by Neha Narkhede

… by Jun Rao

… producer more standard; patched by Manikumar Reddy; reviewed by Jun Rao

…oshy

… false if not explicitly set; patched by Jun Rao; reviewed by Jeol Koshy

…Java API; patched by Jun Rao; reviewed by Jeol Koshy and Sriharsha Chintalapani

…by Jun Rao; reviewed by Jeol Koshy, Neha Narkhede, and Gwen Shapira

…lt is 2; patched by Manikumar Reddy; reviewed by Jun Rao

… fails with TimeoutException while trying to fetch metadata for topic; patched by jaikiran pai; reviewed by Jun Rao

…on; patched by Jun Rao; reviewed by Joe Stein and Sriharsha Chintalapani

…ableByteChannel.read(buffer); patched by Dong Lin; reviewed by Jun Rao

asfbot · 2015-07-16T23:39:00Z

kafka-trunk-git-pr #6 FAILURE
Looks like there's a problem with this pull request

…eritskiy; reviewed by Jun Rao

asfbot · 2015-07-17T00:26:18Z

kafka-trunk-git-pr #8 FAILURE
Looks like there's a problem with this pull request

ijuma · 2015-07-17T00:28:31Z

Can you please close this pull request? It's triggering builds in the CI server and we cannot close it ourselves without asking Apache Infra. Thanks!

…estFromPropsToProps; patched by Jason Gustafson; reviewed by Jun Rao

asfbot · 2015-07-17T00:29:42Z

kafka-trunk-git-pr #9 FAILURE
Looks like there's a problem with this pull request

… Cheslack-Postava; reviewed by Jun Rao

asfbot · 2015-07-17T00:57:33Z

kafka-trunk-git-pr #10 FAILURE
Looks like there's a problem with this pull request

Author: Ismael Juma <ismael@juma.me.uk> Closes #82 from ijuma/kafka-2324 and squashes the following commits: d71bf5c [Ismael Juma] KAFKA-2324; Update to Scala 2.11.7

asfbot · 2015-07-17T04:47:44Z

kafka-trunk-git-pr #11 FAILURE
Looks like there's a problem with this pull request

…ows ZkNodeExistsException; patched by Ashish Singh; reviewed by Sriharsha Chintalapani and Ismael Juma

asfbot · 2015-07-17T17:34:07Z

kafka-trunk-git-pr #14 FAILURE
Looks like there's a problem with this pull request

asfbot · 2015-07-17T17:50:32Z

kafka-trunk-git-pr #15 FAILURE
Looks like there's a problem with this pull request

Add RocksDB KeyValueStore

[LOGBROKER-1543] fix OfflinePartitionLeaderSelector

…pache#42) TICKET = LI_DESCRIPTION = This Patch separates Kafka Controller Node from non-controller (data) Node. Summary of changes: 1)Add “preferred.controller” broker config (its type is boolean) to indicate whether a broker is used as a preferred controller node. 2)Add “allow.preferred.controller.fallback” broker config that determines whether a non-preferred controller node (data node) is allowed to become controller in the absence of preferred controller nodes. If “allow.preferred.controller.fallback” is set to “false”, a non-preferred controller node never tries to become controller, and only preferred controller nodes can be elected as controller. If “allow.preferred.controller.fallback” is set to “true”, a non-preferred controller node tries to elect itself as controller only in the absence of preferred controller node and a non-preferred active controller resigns as controller when it detects any live preferred controller. 3)Add ActivePreferredControllerCount metric to track whether the current broker is preferred controller node and is elected as Kafka controller 4)Add StandbyPreferredControllerCount metric to track whether the current broker is preferred controller node and is not elected as controller. EXIT_CRITERIA = MANUAL [""]

… cluster model sanity check failure. (apache#42)

Fixed local and effective logStartOffset updation when segments are deleted locally but not in the remote tiered storage.

…pache#42) TICKET = LI_DESCRIPTION = This Patch separates Kafka Controller Node from non-controller (data) Node. Summary of changes: 1)Add “preferred.controller” broker config (its type is boolean) to indicate whether a broker is used as a preferred controller node. 2)Add “allow.preferred.controller.fallback” broker config that determines whether a non-preferred controller node (data node) is allowed to become controller in the absence of preferred controller nodes. If “allow.preferred.controller.fallback” is set to “false”, a non-preferred controller node never tries to become controller, and only preferred controller nodes can be elected as controller. If “allow.preferred.controller.fallback” is set to “true”, a non-preferred controller node tries to elect itself as controller only in the absence of preferred controller node and a non-preferred active controller resigns as controller when it detects any live preferred controller. 3)Add ActivePreferredControllerCount metric to track whether the current broker is preferred controller node and is elected as Kafka controller 4)Add StandbyPreferredControllerCount metric to track whether the current broker is preferred controller node and is not elected as controller. EXIT_CRITERIA = MANUAL [""]

…pache#42) TICKET = LI_DESCRIPTION = This Patch separates Kafka Controller Node from non-controller (data) Node. Summary of changes: 1) Add "preferred.controller” broker config (its type is boolean) to indicate whether a broker is used as a preferred controller node. 2) Add "allow.preferred.controller.fallback” broker config that determines whether a non-preferred controller node (data node) is allowed to become controller in the absence of preferred controller nodes. If "allow.preferred.controller.fallback” is set to "false”, a non-preferred controller node never tries to become controller, and only preferred controller nodes can be elected as controller. If "allow.preferred.controller.fallback” is set to "true”, a non-preferred controller node tries to elect itself as controller only in the absence of preferred controller node and a non-preferred active controller resigns as controller when it detects any live preferred controller. 3) Add ActivePreferredControllerCount metric to track whether the current broker is preferred controller node and is elected as Kafka controller 4) Add StandbyPreferredControllerCount metric to track whether the current broker is preferred controller node and is not elected as controller. EXIT_CRITERIA = MANUAL [""]

…ator node is discovered. (apache#42) * Fixing flaky test * ensure coordinator is known. * Update CommitRequestManager.java * Update BaseAsyncConsumerTest.scala

) Reviewers: Sagar Rao <sagarmeansocean@gmail.com>, Chris Egerton <chrise@aiven.io> Co-authored-by: Matthew de Detrich <matthew.dedetrich@aiven.io>

Minor refactoring

…apache#3) Remediates 3 MINOR QA findings — all broken anchor fragments in docs/security-audit/findings/07-external-function-callback-misuse.md. The previous anchor fragments used MkDocs-style semantic IDs that do not resolve against GitHub-flavored markdown auto-generated heading slugs. This commit aligns each fragment to the GitHub-computed slug for the target heading. Fixes: * Line 197: #oauth -> apache#32-security--oauth Target: ### 3.2 Security - OAuth (accepted-mitigations.md:201) (double-hyphen comes from the two spaces around the em-dash; the em-dash itself is stripped by the GitHub slug algorithm) * Line 227: #oauth -> apache#32-security--oauth (both visible text and URL) Target: same as Line 197 (second occurrence in the 'Cross-References' section) * Line 232: apache#62-restclient-forwarding -> apache#42-connect-restclient- forwards-the-inbound-authorization-header-to-outbound-worker- peer-calls-062 Target: ### 4.2 Connect RestClient forwards the inbound Authorization header to outbound worker-peer calls (06.2) (findings/06-network-subprocess-access.md:90) (URL fragment updated; visible short identifier retained for readability per QA suggested-fix guidance) Validation: * Runtime re-verification: all 88 anchor-bearing links across the 24 audit markdown files now resolve (0 broken anchors). * File inventory unchanged: 25 files, surgical 6-line diff (3 insertions, 3 deletions). * Visual Architecture Documentation rule preserved: all 7 diagrams still referenced by name across findings and supporting docs. * Audit Only rule preserved: zero source-code modifications; only the audit deliverable under docs/security-audit/ is touched. QA report: QA Final Checkpoint apache#3 - Link Integrity + Cross-References + License Headers (Issues 1-3, all MINOR, all in findings/07).

joestein and others added 30 commits December 12, 2014 03:46

KAFKA-1812 Allow IpV6 in configuration with parseCsvMap patch by Jeff…

e8ffbd0

… Holoman reviewed by Gwen Shapira and Joe Stein

kafka-1815; ServerShutdownTest fails in trunk; patched by Chris Cope;…

0ef631b

… reviewed by Jun Rao

kafka-1813; Build fails for scala 2.9.2; patched by Anatoly Fayngeler…

523b365

…in; reviewed by Jun Rao

KAFKA-742: Existing directories under the Kafka data directory withou…

ae0bb84

…t any data cause process to not start; reviewed by Neha Narkhede

kafka-1797; add the serializer/deserializer api to the new java clien…

92d1d4c

…t; patched by Jun Rao; reviewed by Neha Narkhede

KAFKA-1824 - fix ConsoleProducer so parse.key and key.separator will …

8452187

…work again; reviewed by Neha Narkhede

KAFKA-1650; (Follow-up patch) to support no data loss in mirror maker…

10c6dec

…; reviewed by Joel Koshy

kafka-1642; (followup patch) [Java New Producer Kafka Trunk] CPU Usag…

4471dc0

…e Spike to 100% when network connection is lost; patched by Ewen Cheslack-Postava; patched by Ewen Cheslack-Postava; reviewed by Jun Rao

kafka-1797; (follow-up patch) add the serializer/deserializer api to …

50b7346

…the new java client; patched by Jun Rao; reviewed by Jay Kreps

kafka-1797; (delta follow-up patch) add the serializer/deserializer a…

517503d

…pi to the new java client; patched by Jun Rao; reviewed by Neha Narkhede

KAFKA-1512 Fixes for limit the maximum number of connections per ip a…

f82518a

…ddress patch by Jeff Holoman reviewed by Jay Krepps and Gwen Shapira

kafka-1797; (addressing Manikumar Reddy's comment) add the serializer…

a93ef19

…/deserializer api to the new java client; patched by Jun Rao; reviewed by Manikumar Reddy and Neha Narkhede

kafka-1851; OffsetFetchRequest returns extra partitions when input on…

e52a618

…ly contains unknown partitions; patched by Jun Rao; reviewed by Neha Narkhede

KAFKA-1070 Auto assign broker id; reviewed by Neha Narkhede

b1b8086

KAFKA-1836 metadata.fetch.timeout.ms set to zero blocks forever; revi…

ad4883a

…ewed by Neha Narkhede and Ewen Cheslack-Postava

KAFKA-1819 Cleaner gets confused about deleted and re-created topics;…

14779dd

… reviewed by Neha Narkhede

kafka-1797; (missed parametric in a few files) add the serializer/des…

6f4dea9

…erializer api to the new java client; patched by Jun Rao

KAFKA-1723; make the metrics name in new producer more standard; patc…

688e38c

…hed by Manikumar Reddy; reviewed by Jay Kreps and Jun Rao

KAFKA-1854 Allow JIRA username and password to be prompted in the abs…

e79ebdf

…ence of a jira.ini file, during patch submission; reviewed by Neha Narkhede

trivial change to add byte serializer to ProducerPerformance; patched…

bfb2da3

… by Jun Rao

KAFKA-1723 (delta patch to fix javadoc); make the metrics name in new…

a611178

… producer more standard; patched by Manikumar Reddy; reviewed by Jun Rao

KAFKA-1499; Broker-side compression configuration; reviewed by Joel K…

1c8f89b

…oshy

KAFKA-1499; Trivial follow-up (fix comments and whitespace)

45697ed

kafka-1868; ConsoleConsumer shouldn't override dual.commit.enabled to…

602d572

… false if not explicitly set; patched by Jun Rao; reviewed by Jeol Koshy

kafka-1870; Cannot commit with simpleConsumer on Zookeeper only with …

1769642

…Java API; patched by Jun Rao; reviewed by Jeol Koshy and Sriharsha Chintalapani

kafka-1864; Revisit defaults for the internal offsets topic; patched …

5174df5

…by Jun Rao; reviewed by Jeol Koshy, Neha Narkhede, and Gwen Shapira

trivial change to remove -UseCompressedOops option from script

09234f0

KAFKA-1723; num.partitions documented default is 1 while actual defau…

49d7f8e

…lt is 2; patched by Manikumar Reddy; reviewed by Jun Rao

KAFKA-1878; ProducerFailureHandlingTest.testCannotSendToInternalTopic…

07cff76

… fails with TimeoutException while trying to fetch metadata for topic; patched by jaikiran pai; reviewed by Jun Rao

KAFKA-1876; pom file for scala 2.11 should reference a specific versi…

5d648cf

…on; patched by Jun Rao; reviewed by Joe Stein and Sriharsha Chintalapani

kafka-2241; AbstractFetcherThread.shutdown() should not block on Read…

8fa24a6

…ableByteChannel.read(buffer); patched by Dong Lin; reviewed by Jun Rao

kafka-2174; Wrong TopicMetadata deserialization; patched by Alexey Oz…

1e0ed7a

…eritskiy; reviewed by Jun Rao

kafka-2271; transient unit test failure in KafkaConfigConfigDefTest.t…

5033b96

…estFromPropsToProps; patched by Jason Gustafson; reviewed by Jun Rao

kafka-2103; kafka.producer.AsyncProducerTest failure; patched by Ewen…

31f6217

… Cheslack-Postava; reviewed by Jun Rao

KAFKA-2324; Update to Scala 2.11.7

15cba9f

Author: Ismael Juma <ismael@juma.me.uk> Closes #82 from ijuma/kafka-2324 and squashes the following commits: d71bf5c [Ismael Juma] KAFKA-2324; Update to Scala 2.11.7

KAFKA-2345; Attempt to delete a topic already marked for deletion thr…

a5b1188

…ows ZkNodeExistsException; patched by Ashish Singh; reviewed by Sriharsha Chintalapani and Ismael Juma

Adding a file missed while committing KAFKA-2345

8463627

abayer closed this Jul 20, 2015

guozhangwang referenced this pull request in confluentinc/kafka Aug 5, 2015

Merge pull request #42 from guozhangwang/RocksDBStore

7e95bc7

Add RocksDB KeyValueStore

resetius added a commit to resetius/kafka that referenced this pull request Jun 7, 2016

Merge pull request apache#42 from aozeritsky/0.9.0-stbx

8bde1e9

[LOGBROKER-1543] fix OfflinePartitionLeaderSelector

efeg pushed a commit to efeg/kafka that referenced this pull request Jan 29, 2020

Change comparison epsilon percent to 0.1% for large clusters to avoid…

4426659

… cluster model sanity check failure. (apache#42)

satishd referenced this pull request in satishd/kafka Mar 30, 2020

Merge pull request #42 from satishd/log-start-offset-fix

0987ad5

Fixed local and effective logStartOffset updation when segments are deleted locally but not in the remote tiered storage.

patrik-marton pushed a commit to patrik-marton/kafka that referenced this pull request Mar 11, 2025

CSMDS-432: Use internalized Gradle distribution (apache#42)

7660c03

fvaleri added a commit to fvaleri/kafka that referenced this pull request Nov 27, 2025

Merge pull request apache#42 from fvaleri/minor-refs

41c51d5

Minor refactoring

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Trunk#42

Trunk#42
SylviaVargasCTL wants to merge 575 commits into0.8.1from
trunk

SylviaVargasCTL commented Jan 15, 2015

Uh oh!

asfbot commented Jul 16, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

ijuma commented Jul 17, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

20 participants

Conversation

SylviaVargasCTL commented Jan 15, 2015

Uh oh!

asfbot commented Jul 16, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

ijuma commented Jul 17, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

asfbot commented Jul 17, 2015

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

20 participants