Trunk by futtre · Pull Request #35 · apache/kafka

futtre · 2014-10-31T22:52:31Z

No description provided.

…into trunk Conflicts: core/src/main/scala/kafka/controller/KafkaController.scala

…down.

…into trunk

…viewed by Jun Rao

…d by Jun Rao; reviewed by Neha Narkhede

…Handling; reviewed by Jay Kreps, Neha Narkhede and Jun Rao

…roducer threads; patched by Guozhang Wang; reviewed by Neha Narkhede, Joel Koshy, and Jun Rao

… if broker host is unresolvable; patched by Rajasekar Elango; reviewed by Jun Rao

…y Neha Narkhede

…; patched by Jun Rao; reviewed by Guozhang Wang and Neha Narkhede

… by Jay Kreps, reviewed by Sriram Subramanian and Jun Rao

…ewed by Neha Narkhede

…e configuration.

…o and Guozhang Wang

…cer client; patched by Jun Rao; reviewed by Neha Narkhede

…d by Jun Rao; reviewed by Jay Kreps

…uozhang Wang and Neha Narkhede

…il and Joel Koshy; feedback and reviews from Neha Narkhede, Jun Rao, Guozhang Wang, Sriram Subramanian, Joe Stein, Chris Riccomini

… availability; reviewed by Neha Narkhede and Jay Kreps

…aConversions API in javaapi.OffsetCommitRequest; reviewed by Neha Narkhede

…wed by Jay Kreps, Guozhang Wang and Neha Narkhede

… Jay Kreps

…ched by Ivan Lyutov; reviewed by Jun Rao

…always logged; reviewed by Neha Narkhede

…Rao; reviewed by Sriharsha Chintalapani and Neha Narkhede

…ue; patched by Ewen Cheslack-Postava; reviewed by Jun Rao

…ed by Neha Narkhede

…uchi; reviewed by Jun Rao

if the checkpointed offset is invalid; reviewed by Joel Koshy

…date; patched by Geoffrey Anderson; reviewed by Jun Rao

…ducer; patched by Joe Crobak; reviewed by Jun Rao

…t and break a few tests; reviewed by Neha Narkhede

…xits; reviewed by Neha Narkhede, Joel Koshy and Guozhang Wang

…y Neha Narkhede

ReplicaManager and refactor KafkaApis; reviewed by Joel Koshy and Jun Rao

unavailable, otherwise replication offset checkpoints (high water marks) can be lost on hard kills and restarts; reviewed by Joel Koshy, Neha Narkhede, Jun Rao and Guozhang Wang

fix mergeStreamGroup

logging exceptions

[LOGBROKER-1394] lost+found

…duce memory consumption (apache#35)

* KAFKA-15270; [1/N] Integration tests for Simple Consume * Minor fixes for positions & logs * Adding unit test for position

…e#12644) (apache#35) Implements KIP-862: https://cwiki.apache.org/confluence/x/WSf1D Reviewers: Guozhang Wang <guozhang@apache.org>, Austin Heyne <aheyne>, John Roesler <vvcephei@apache.org> Co-authored-by: Vicky Papavasileiou <vpapavas@users.noreply.github.com>

…FoundException (#35) (#16919) This patch updates getOrMaybeCreateClassicGroup to only throw GroupIdNotFoundException as we did for other internal methods. The callers are responsible for translating the error to the appropriate one depending on the context. There is only one case. Reviewers: Chia-Ping Tsai <chia7712@gmail.com>

This patch adds some refactoring aroung mirror fetchers. Once this is merged, I'll open dedicated PRs to fix a bunch of issues in this area (see apache#35). Signed-off-by: Federico Valeri <fedevaleri@gmail.com>

sriramsub and others added 30 commits February 24, 2014 01:50

Merge branch 'trunk' of http://git-wip-us.apache.org/repos/asf/kafka …

5de68ef

…into trunk Conflicts: core/src/main/scala/kafka/controller/KafkaController.scala

KAFKA-1279 Socket server should close all connections when it is shut…

3955915

…down.

Merge branch 'trunk' of http://git-wip-us.apache.org/repos/asf/kafka …

5b80758

…into trunk

Check delete state of topic

00afb61

kafka-1278; More flexible helper scripts; patched by Nathan Brown; re…

edbed28

…viewed by Jun Rao

kafka-1280; exclude kafka-clients jar from dependant-libs dir; patche…

57be6c8

…d by Jun Rao; reviewed by Neha Narkhede

KAFKA-1260 Integration Test for New Producer Part II: Broker Failure …

5e2a9a5

…Handling; reviewed by Jay Kreps, Neha Narkhede and Jun Rao

kafka-1212; System test exception handling does not stop background p…

eb6da57

…roducer threads; patched by Guozhang Wang; reviewed by Neha Narkhede, Joel Koshy, and Jun Rao

TRIVIAL: Fix failing producer integration tests.

a810b8e

KAFKA-1250 Add logging to new producer.

f1a53b9

kafka-1041; Number of file handles increases indefinitely in producer…

8cdb234

… if broker host is unresolvable; patched by Rajasekar Elango; reviewed by Jun Rao

kafka-1285; enable log4j in unit test; patched by Jun Rao; reviewed b…

220cc84

…y Neha Narkhede

kafka-1287; enable log4j in command line tools using the new producer…

40c6555

…; patched by Jun Rao; reviewed by Guozhang Wang and Neha Narkhede

KAFKA-1289 Misc. nitpicks in log cleaner for new 0.8.1 features patch…

77118a9

… by Jay Kreps, reviewed by Sriram Subramanian and Jun Rao

KAFKA-1288 add enclosing dir in release tar gz patch by Jun Rao, revi…

153ac8a

…ewed by Neha Narkhede

KAFKA-1286 Retry can block. Patch from Guozhang, reviewed by jay.

5ba4834

KAFKA-1286 Follow-up comment from Jun: Change the backoff default tim…

2404191

…e configuration.

KAFKA-1286: Trivial fix up: Use || instead of |.

4524f38

TRIVIAL: Fix spurious logging in console consumer.

6319f26

kafka-server-stop.sh doesn't stop broker; reviewed by Neha Narkhede

c3520fe

KAFKA-1281 add the new producer to existing tools; reviewed by Jun Ra…

74c54c7

…o and Guozhang Wang

kafka-1240; Add ability to existing system tests to use the new produ…

c765d7b

…cer client; patched by Jun Rao; reviewed by Neha Narkhede

kafka-1301; system testcase_0206 fails using the new producer; patche…

c124bbb

…d by Jun Rao; reviewed by Jay Kreps

kafka-1302; cleanup logging in new producer; reviewed by Jay Kreps, G…

84a3a9a

…uozhang Wang and Neha Narkhede

KAFKA-1012; Consumer offset management in Kafka; patched by Tejas Pat…

a670537

…il and Joel Koshy; feedback and reviews from Neha Narkhede, Jun Rao, Guozhang Wang, Sriram Subramanian, Joe Stein, Chris Riccomini

KAFKA-1028 per topic configuration of preference for consistency over…

616086b

… availability; reviewed by Neha Narkhede and Jay Kreps

KAFKA-1028 follow up: New test UncleanLeaderElectionTest

53e4061

KAFKA-1309; Fix cross-compilation issue (due to use of deprecated Jav…

423d9d5

…aConversions API in javaapi.OffsetCommitRequest; reviewed by Neha Narkhede

kafka-1307; potential socket leak in new producer and clean up; revie…

cc859dc

…wed by Jay Kreps, Guozhang Wang and Neha Narkhede

kafka-1304; unregistered mbean exception in new producer; reviewed by…

74e2209

… Jay Kreps

edgefox and others added 14 commits October 17, 2014 12:30

kafka-1671; uploaded archives are missing for Scala version 2.11; pat…

5f1ad10

…ched by Ivan Lyutov; reviewed by Jun Rao

KAFKA-1108 When controlled shutdown attempt fails, the reason is not …

5152fb7

…always logged; reviewed by Neha Narkhede

kafka-1717; remove netty dependency through ZK 3.4.x; patched by Jun …

2d322a7

…Rao; reviewed by Sriharsha Chintalapani and Neha Narkhede

kafka-1698; Validator.ensureValid() only validates default config val…

4b09576

…ue; patched by Ewen Cheslack-Postava; reviewed by Jun Rao

KAFKA-1653 Duplicate broker ids allowed in replica assignment; review…

e8923ae

…ed by Neha Narkhede

kafka-1727; Fix comment about message format; patched by Muneyuki Nog…

cda1f73

…uchi; reviewed by Jun Rao

KAFKA-1641; Reset first dirty offset for compaction to earliest offset

35f589b

if the checkpointed offset is invalid; reviewed by Joel Koshy

kafka-1700; examples directory - README and shell scripts are out of …

b770996

…date; patched by Geoffrey Anderson; reviewed by Jun Rao

kafka-1711; WARN Property topic is not valid when running console pro…

e402c7b

…ducer; patched by Joe Crobak; reviewed by Jun Rao

KAFKA-1725 Configuration file bugs in system tests add noise to outpu…

12ce4b1

…t and break a few tests; reviewed by Neha Narkhede

KAFKA-1719 Make mirror maker exit when one consumer/producer thread e…

43cb192

…xits; reviewed by Neha Narkhede, Joel Koshy and Guozhang Wang

KAFKA-1732 DumpLogSegments tool fails when path has a '.'; reviewed b…

20f5b01

…y Neha Narkhede

KAFKA-1583; Encapsulate replicated log implementation details into

8983120

ReplicaManager and refactor KafkaApis; reviewed by Joel Koshy and Jun Rao

KAFKA-1647; Create replicas on follower transition even if leader is

1ed9cf6

unavailable, otherwise replication offset checkpoints (high water marks) can be lost on hard kills and restarts; reviewed by Joel Koshy, Neha Narkhede, Jun Rao and Guozhang Wang

futtre closed this Oct 31, 2014

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

Merge pull request #35 from ymatsuda/fix_group_merge

9b9f980

fix mergeStreamGroup

rhauch pushed a commit to rhauch/kafka that referenced this pull request Sep 4, 2015

Merge pull request apache#35 from ymatsuda/streaming

572d5a2

logging exceptions

resetius added a commit to resetius/kafka that referenced this pull request Apr 22, 2016

Merge pull request apache#35 from aozeritsky/LOGBROKER-1394

e78819d

[LOGBROKER-1394] lost+found

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

Add an identity map for TopicPartition in the metric aggregator to re…

8b641a2

…duce memory consumption (apache#35)

lianetm added a commit to lianetm/kafka that referenced this pull request Aug 4, 2023

KAFKA-15270 - Simple Consume Integration tests (apache#35)

5a8af23

* KAFKA-15270; [1/N] Integration tests for Simple Consume * Minor fixes for positions & logs * Adding unit test for position

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

CSMDS-335: Add ART approval PR check (apache#35)

dba3267

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Trunk#35

Trunk#35
futtre wants to merge 293 commits into
0.8.1from
trunk

futtre commented Oct 31, 2014

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

19 participants

Conversation

futtre commented Oct 31, 2014

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

19 participants