[GitHub] kafka pull request: Trunk kafka 3054

[ZoneMayor]

GitHub user ZoneMayor opened a pull request:

https://github.com/apache/kafka/pull/782

Trunk kafka 3054

The exceptions may propagate to DistributedHerder when start or stop 
connectors or tasks;
The best solution is to track the track the status of connectors and tasks; 
This patch catch exceptions to guard the DistributedHerder; this a 
short-term solution;

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ZoneMayor/kafka trunk-KAFKA-3054

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/782.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #782


commit 34240b52e1b70aa172b65155f6042243d838b420
Author: ZoneMayor 
Date:   2015-12-18T07:22:20Z

Merge pull request #12 from apache/trunk

2015-12-18

commit 52d02f333e86d06cfa8fff5facd18999b3db6d83
Author: ZoneMayor 
Date:   2015-12-30T03:08:08Z

Merge pull request #13 from apache/trunk

2015-12-30

commit d56be0b9e0849660c07d656c6019f9cc2f17ae55
Author: ZoneMayor 
Date:   2016-01-10T09:24:06Z

Merge pull request #14 from apache/trunk

2016-1-10

commit e75c8bbb3329868f92becc86645d31fa21c6c7f4
Author: jinxing 
Date:   2016-01-17T03:11:45Z

KAFKA-3054: Connect Herder fail if sent a wrong connector config or task 
config, catch exceptions to guard




---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] kafka pull request: Trunk kafka 2839

[ZoneMayor]

Github user ZoneMayor closed the pull request at:

https://github.com/apache/kafka/pull/602


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] kafka pull request: Trunk kafka 2839

[ZoneMayor]

GitHub user ZoneMayor opened a pull request:

https://github.com/apache/kafka/pull/602

Trunk kafka 2839

I believe there is a bug in KafkaBasedLogTest implementation;
Records are appended to "KafkaBasedLog" by :
consumer.addRecord(new ConsumerRecord<>(TOPIC, 0, 0, TP0_KEY, TP0_VALUE));
consumer.addRecord(new ConsumerRecord<>(TOPIC, 0, 1, TP0_KEY, 
TP0_VALUE_NEW));
consumer.addRecord(new ConsumerRecord<>(TOPIC, 1, 0, TP1_KEY, TP1_VALUE));
consumer.addRecord(new ConsumerRecord<>(TOPIC, 1, 1, TP1_KEY, 
TP1_VALUE_NEW));
and achieved by "consumedRecords";
Inside of "ConsumerRecords", in order to turn "records", which is a 
HashMap>>, into 
Iterator>;
We can just guarantee the sequence underneath same key, while we cannot 
assure the sequence under different keys;
Am I wrong?
@gwenshap 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ZoneMayor/kafka trunk-KAFKA-2839

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/602.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #602


commit 95374147a28208d4850f6e73f714bf418935fc2d
Author: ZoneMayor 
Date:   2015-11-27T03:49:34Z

Merge pull request #1 from apache/trunk

merge

commit 0875176f90dbece21e1777902a079cf67ad157a7
Author: jinxing 
Date:   2015-11-30T03:39:29Z

KAFKA-2839:  fix KafkaBasedLogTest testSendAndReadToEnd failing




---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] kafka pull request: Trunk

[abayer]

Github user abayer closed the pull request at:

https://github.com/apache/kafka/pull/42


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] kafka pull request: Trunk

[SylviaVargasCTL]

GitHub user SylviaVargasCTL opened a pull request:

https://github.com/apache/kafka/pull/42

Trunk



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/apache/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/42.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #42


commit de6066e8e78e62739e3eb6f771d0739bf9b73dfd
Author: Stevo Slavic ssla...@apache.org
Date:   2014-04-09T15:13:53Z

kafka-1370; Gradle startup script for Windows; patched by Stevo Slavic; 
reviewed by Jun Rao

commit 75d5f5bff8519b36d5eb0a904ebbd0d3c0b7c8cc
Author: Stevo Slavic ssla...@apache.org
Date:   2014-04-09T15:24:13Z

kafka-1375; Formatting for in README.md is broken; patched by Stevo Slavic; 
reviewed by Jun Rao

commit 8d15de85114da6012530f0dd837f131bd1e367cd
Author: Joel Koshy jjko...@gmail.com
Date:   2014-04-08T21:21:46Z

KAFKA-1373; Set first dirty (uncompacted) offset to first offset of the
log if no checkpoint exists. Reviewed by Neha Narkhede and Timothy Chen.

commit 911ff524515148421ff58b41f271c21f792ed9de
Author: Guozhang Wang guw...@linkedin.com
Date:   2014-04-09T21:49:17Z

kafka-1364; ReplicaManagerTest hard-codes log dir; patched by Guozhang 
Wang; reviewed by Jun Rao

commit 47019a849e69209c16defa81001055aa9f57674d
Author: Jun Rao jun...@gmail.com
Date:   2014-04-09T21:53:03Z

kafka-1376; transient test failure in UncleanLeaderElectionTest; patched by 
Jun Rao; reviewed by Joel Koshy

commit 44ee6b7c9d9da207bebe6d927b38ed7df1388df3
Author: Guozhang Wang guw...@linkedin.com
Date:   2014-04-10T01:52:23Z

kafka-1353;report capacity used by request thread pool and network thread 
pool; patched by Guozhang Wang; reviewed by Jun Rao

commit 2d429e19da22416aeb7de68b9e00f33a337e31a0
Author: Guozhang Wang guw...@linkedin.com
Date:   2014-04-11T21:39:35Z

kafka-1337; follow-up patch to add broker list for new producer in system 
test overriden function; patched by Guozhang Wang; reviewed by Neha Narkhede, 
Jun Rao

commit a3a2cba842a9945d4ce7b032e311d17956c33249
Author: Timothy Chen tnac...@gmail.com
Date:   2014-04-12T03:31:13Z

kafka-1363; testTopicConfigChangesDuringDeleteTopic hangs; patched by 
Timothy Chen; reviewed by Guozhang Wang, Neha Narkhede and Jun Rao

commit 6bb616e5ae6a2f45cfa190e245c9217a8bf9771a
Author: Jun Rao jun...@gmail.com
Date:   2014-04-12T04:29:09Z

trivial change to add kafka doap project file

commit 05612ac44de775cf3bc8ffdc15c033920d4a1440
Author: Jun Rao jun...@gmail.com
Date:   2014-04-12T20:47:13Z

kafka-1377; transient unit test failure in LogOffsetTest; patched by Jun 
Rao; reviewed by Neha Narkhede

commit d37ca7f627551c9960e2edb8498784bf2487d53e
Author: Jun Rao jun...@gmail.com
Date:   2014-04-12T20:48:57Z

kafka-1378; transient unit test failure in LogRecoveryTest; patched by Jun 
Rao; reviewed by Neha Narkhede

commit 2bfd49b955831f3455ff486ce4f613d73239a317
Author: Jun Rao jun...@gmail.com
Date:   2014-04-12T20:51:29Z

kafka-1381; transient unit test failure in AddPartitionsTest; patched by 
Jun Rao; reviewed by Neha Narkhede

commit 4bd33e5ba792667913991638a15f0a2c9f20d7b5
Author: Stevo Slavic ssla...@apache.org
Date:   2014-04-13T15:43:53Z

kafka-1210; Windows Bat files are not working properly; patched by Stevo 
Slavic; reviewed by Jun Rao

commit 9a6f7113ed630d8e6bb50f4a58846d976a2d5f97
Author: Jun Rao jun...@gmail.com
Date:   2014-04-15T20:46:54Z

kafka-1390; TestUtils.waitUntilLeaderIsElectedOrChanged may wait longer 
than it needs; patched by Jun Rao; reviewed by Guozhang Wang

commit ec075c5a853e4168ff30cf133493588671aa2fac
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-04-16T17:19:18Z

KAFKA-1359: Ensure all topic/server metrics registered at once.

commit 97f13ec73255f3978c1cbb80ea26f446cf756515
Author: Joel Koshy jjko...@gmail.com
Date:   2014-04-15T21:08:21Z

KAFKA-1323; Fix regression due to KAFKA-1315 (support for relative
directories in log.dirs property broke). Patched by Timothy Chen and
Guozhang Wang; reviewed by Joel Koshy, Neha Narkhede and Jun Rao.

commit b9351e04f0a26f2f9e4abc7ec526ed802495f991
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-04-18T00:07:27Z

KAFKA-1398 dynamic config changes are broken.

commit 8b052150f55fb9a6f8c4aedc6b3fa0528719671e
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-04-17T00:32:43Z

KAFKA-1337: Fix incorrect producer configs after config renaming.

commit 037c054be260bcc3b470b9724572cb814b704bff
Author: Joel Koshy jjko...@gmail.com
Date:   2014-04-18T20:10:34Z

KAFKA-1362; Publish sources and javadoc jars; (also removed Scala 
2.8.2-specific actions). Reviewed by Jun Rao and Joe Stein

commit 89f040c8c9807fc4f9e219f0b57279b692b6e45d
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-04-18T18:03:37Z

[GitHub] kafka pull request: Trunk

[futtre]

GitHub user futtre opened a pull request:

https://github.com/apache/kafka/pull/35

Trunk



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/apache/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/35.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #35


commit 5de68ef4aef7812fd9f2d5e4fb6158bf753658e3
Author: Sriram Subramanian sriram@gmail.com
Date:   2014-02-24T09:50:02Z

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

Conflicts:
core/src/main/scala/kafka/controller/KafkaController.scala

commit 3955915a5f8a0daa7b96be69a87b3fbd013c9501
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-02-24T22:44:32Z

KAFKA-1279 Socket server should close all connections when it is shutdown.

commit 5b80758b57d8063b8a8124562cc5c83854a99e00
Author: Sriram Subramanian sriram@gmail.com
Date:   2014-02-25T08:22:04Z

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

commit 00afb619cb1f2aaca0ddc785ab1d649428f9c93e
Author: Sriram Subramanian sriram@gmail.com
Date:   2014-02-25T08:26:14Z

Check delete state of topic

commit edbed2823fc3e4948bb56ec3bee02fe4ad1bbdca
Author: Nathan Brown nbrown...@gmail.com
Date:   2014-02-25T17:37:15Z

kafka-1278; More flexible helper scripts; patched by Nathan Brown; reviewed 
by Jun Rao

commit 57be6c81a748a30e583037ddc70d2eec9acc7832
Author: Jun Rao jun...@gmail.com
Date:   2014-02-26T02:09:59Z

kafka-1280; exclude kafka-clients jar from dependant-libs dir; patched by 
Jun Rao; reviewed by Neha Narkhede

commit 5e2a9a560d847bd0cf364d86bd6784f70d99c71a
Author: Guozhang Wang guw...@linkedin.com
Date:   2014-02-27T18:50:15Z

KAFKA-1260 Integration Test for New Producer Part II: Broker Failure 
Handling; reviewed by Jay Kreps, Neha Narkhede and Jun Rao

commit eb6da57492caad7a6b71692ad184a95c89035b67
Author: Guozhang Wang guw...@linkedin.com
Date:   2014-02-27T22:15:41Z

kafka-1212; System test exception handling does not stop background 
producer threads; patched by Guozhang Wang; reviewed by Neha Narkhede, Joel 
Koshy, and Jun Rao

commit a810b8ecbe66f36f8ef58a440d439a54762b3d9c
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-02-27T22:25:02Z

TRIVIAL: Fix failing producer integration tests.

commit f1a53b972eb1f8e75db54d3272d9eb7c398e238a
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-02-21T04:17:01Z

KAFKA-1250 Add logging to new producer.

commit 8cdb234ad81ec324f15c9c1f8e484861926076f9
Author: Rajasekar Elango e.rajase...@gmail.com
Date:   2014-02-28T16:02:42Z

kafka-1041; Number of file handles increases indefinitely in producer if 
broker host is unresolvable; patched by Rajasekar Elango; reviewed by Jun Rao

commit 220cc842a6e866806e3f53c394b5547fe7c44b3e
Author: Jun Rao jun...@gmail.com
Date:   2014-02-28T21:53:37Z

kafka-1285; enable log4j in unit test; patched by Jun Rao; reviewed by Neha 
Narkhede

commit 40c6555eb0d0db25d6bd06c5eb4040246805c79f
Author: Jun Rao jun...@gmail.com
Date:   2014-03-03T17:35:21Z

kafka-1287; enable log4j in command line tools using the new producer; 
patched by Jun Rao; reviewed by Guozhang Wang and Neha Narkhede

commit 77118a935ee28da80c67d4050f41a1e7e838ebaa
Author: Joe Stein joe.st...@stealth.ly
Date:   2014-03-04T20:30:59Z

KAFKA-1289 Misc. nitpicks in log cleaner for new 0.8.1 features patch by 
Jay Kreps, reviewed by Sriram Subramanian and Jun Rao

commit 153ac8aa604014351e6958dce5d479e4875031fa
Author: Joe Stein joe.st...@stealth.ly
Date:   2014-03-04T20:49:12Z

KAFKA-1288 add enclosing dir in release tar gz patch by Jun Rao, reviewed 
by Neha Narkhede

commit 5ba48348b3abb8f84fda0798d992ff2e0a04051d
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-03-05T04:05:51Z

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

commit 2404191be9f4323fc6144a8f56ae36f794d50da6
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-03-05T21:32:08Z

KAFKA-1286 Follow-up comment from Jun: Change the backoff default time 
configuration.

commit 4524f384dc041f33297b47b181be6b59061577b4
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-03-05T22:35:07Z

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

commit 6319f26e6f47350f1e7926dea153ed848f464d2e
Author: Jay Kreps jay.kr...@gmail.com
Date:   2014-03-06T16:26:12Z

TRIVIAL: Fix spurious logging in console consumer.

commit c3520fe7e0e50f0eeb4f82ad1ed961bdd39440fc
Author: Martin Kleppmann mar...@rapportive.com
Date:   2014-03-06T17:34:37Z

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

commit 74c54c7eeb236cbf66710751165ea9f632cf3f52
Author: Neha Narkhede neha.narkh...@gmail.com
Date:   2014-03-07T02:08:55Z

KAFKA-1281 add the new producer to existing tools;