You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Guozhang Wang <gu...@linkedin.com> on 2014/04/16 19:11:34 UTC
Re: Review Request 20380: Fix KAFKA-1395: incorporate Jun's comment
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/
-----------------------------------------------------------
(Updated April 16, 2014, 5:11 p.m.)
Review request for kafka.
Summary (updated)
-----------------
Fix KAFKA-1395: incorporate Jun's comment
Bugs: KAFKA-1395
https://issues.apache.org/jira/browse/KAFKA-1395
Repository: kafka
Description (updated)
-------
remove waitUntilLeaderIsElectedOrChanged
KAFKA-1395.v1
Diffs (updated)
-----
core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 1415773dc34d2111eb923eee812b6dc89a353441
Diff: https://reviews.apache.org/r/20380/diff/
Testing
-------
Thanks,
Guozhang Wang
Re: Review Request 20380: Fix KAFKA-1395: Address Jun's comments
Posted by Jun Rao <ju...@gmail.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/#review41521
-----------------------------------------------------------
Looks good. Just the following minor comment.
core/src/test/scala/unit/kafka/utils/TestUtils.scala
<https://reviews.apache.org/r/20380/#comment74967>
Could we add a comment on producerProps?
- Jun Rao
On April 25, 2014, 6:03 p.m., Guozhang Wang wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/20380/
> -----------------------------------------------------------
>
> (Updated April 25, 2014, 6:03 p.m.)
>
>
> Review request for kafka.
>
>
> Bugs: KAFKA-1395
> https://issues.apache.org/jira/browse/KAFKA-1395
>
>
> Repository: kafka
>
>
> Description
> -------
>
> Address Jun's comments round two
>
>
> minor fix 2
>
>
> minor fix
>
>
> Move create server/producer and create topic to setUp in LogRecoveryTest
>
>
> Address Jun's comments
>
>
> Incoporate Neha's comments
>
>
> remove waitUntilLeaderIsElectedOrChanged
>
>
> KAFKA-1395.v1
>
>
> Diffs
> -----
>
> core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 7125ec9c03e634d7625a315a944eaf5088074eed
> core/src/test/scala/unit/kafka/integration/FetcherTest.scala 4075068a80d6e71a3446a579112541d5b4892854
> core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala 731ee59e67e302f4cb1da12b1d4ae7ff59010aea
> core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala d1d969e6c7a5183fa9877fcd12cf49de0cead62a
> core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala 16e716440099d62198af3bbadaf5b7d7bc496735
> core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala 7a0ef6faeaa419553f912c8a6d44099818e19833
> core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala 481a400067ec97ed97a2bbd8506b34960a5ec000
> core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala addd11ab8be2a1c5de0e43f006de1087032fa6d8
> core/src/test/scala/unit/kafka/utils/TestUtils.scala 130b6be8414268b9a992514ecbc7561872ccaca7
>
> Diff: https://reviews.apache.org/r/20380/diff/
>
>
> Testing
> -------
>
>
> Thanks,
>
> Guozhang Wang
>
>
Re: Review Request 20380: Fix KAFKA-1395: Address Jun's comments
Posted by Guozhang Wang <gu...@linkedin.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/
-----------------------------------------------------------
(Updated April 25, 2014, 9:09 p.m.)
Review request for kafka.
Bugs: KAFKA-1395
https://issues.apache.org/jira/browse/KAFKA-1395
Repository: kafka
Description (updated)
-------
Added comments 2
Added comments
minor fix
Address Jun's comments round two
minor fix 2
minor fix
Move create server/producer and create topic to setUp in LogRecoveryTest
Address Jun's comments
Incoporate Neha's comments
remove waitUntilLeaderIsElectedOrChanged
KAFKA-1395.v1
Diffs (updated)
-----
core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 7125ec9c03e634d7625a315a944eaf5088074eed
core/src/test/scala/unit/kafka/integration/FetcherTest.scala 4075068a80d6e71a3446a579112541d5b4892854
core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala 731ee59e67e302f4cb1da12b1d4ae7ff59010aea
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala d1d969e6c7a5183fa9877fcd12cf49de0cead62a
core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala 16e716440099d62198af3bbadaf5b7d7bc496735
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala 1b87acf11f48f81d1186f5eb2e00017079eaef60
core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala faf466b4ed3d408e548db6e454f03020c2ff4808
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala addd11ab8be2a1c5de0e43f006de1087032fa6d8
core/src/test/scala/unit/kafka/utils/TestUtils.scala 498941d8d894fbb2120bfa10c5be1e046691f73b
Diff: https://reviews.apache.org/r/20380/diff/
Testing
-------
Thanks,
Guozhang Wang
Re: Review Request 20380: Fix KAFKA-1395: Address Jun's comments
Posted by Guozhang Wang <gu...@linkedin.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/
-----------------------------------------------------------
(Updated April 25, 2014, 6:03 p.m.)
Review request for kafka.
Bugs: KAFKA-1395
https://issues.apache.org/jira/browse/KAFKA-1395
Repository: kafka
Description (updated)
-------
Address Jun's comments round two
minor fix 2
minor fix
Move create server/producer and create topic to setUp in LogRecoveryTest
Address Jun's comments
Incoporate Neha's comments
remove waitUntilLeaderIsElectedOrChanged
KAFKA-1395.v1
Diffs (updated)
-----
core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 7125ec9c03e634d7625a315a944eaf5088074eed
core/src/test/scala/unit/kafka/integration/FetcherTest.scala 4075068a80d6e71a3446a579112541d5b4892854
core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala 731ee59e67e302f4cb1da12b1d4ae7ff59010aea
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala d1d969e6c7a5183fa9877fcd12cf49de0cead62a
core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala 16e716440099d62198af3bbadaf5b7d7bc496735
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala 7a0ef6faeaa419553f912c8a6d44099818e19833
core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala 481a400067ec97ed97a2bbd8506b34960a5ec000
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala addd11ab8be2a1c5de0e43f006de1087032fa6d8
core/src/test/scala/unit/kafka/utils/TestUtils.scala 130b6be8414268b9a992514ecbc7561872ccaca7
Diff: https://reviews.apache.org/r/20380/diff/
Testing
-------
Thanks,
Guozhang Wang
Re: Review Request 20380: Fix KAFKA-1395: Address Jun's comments
Posted by Jun Rao <ju...@gmail.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/#review41472
-----------------------------------------------------------
Great cleanup patch! Some minor comments.
1. TestUtils.createProducer: Could we keep the props parameter and treat it as the list of properties that we want to override?
2. Unused imports in ServerShutdownTest and LogRecoveryTest.
- Jun Rao
On April 24, 2014, 11:22 p.m., Guozhang Wang wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/20380/
> -----------------------------------------------------------
>
> (Updated April 24, 2014, 11:22 p.m.)
>
>
> Review request for kafka.
>
>
> Bugs: KAFKA-1395
> https://issues.apache.org/jira/browse/KAFKA-1395
>
>
> Repository: kafka
>
>
> Description
> -------
>
> minor fix 2
>
>
> minor fix
>
>
> Move create server/producer and create topic to setUp in LogRecoveryTest
>
>
> Address Jun's comments
>
>
> Incoporate Neha's comments
>
>
> remove waitUntilLeaderIsElectedOrChanged
>
>
> KAFKA-1395.v1
>
>
> Diffs
> -----
>
> core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 7125ec9c03e634d7625a315a944eaf5088074eed
> core/src/test/scala/unit/kafka/integration/FetcherTest.scala 4075068a80d6e71a3446a579112541d5b4892854
> core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala 731ee59e67e302f4cb1da12b1d4ae7ff59010aea
> core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala d1d969e6c7a5183fa9877fcd12cf49de0cead62a
> core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala 16e716440099d62198af3bbadaf5b7d7bc496735
> core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala 7a0ef6faeaa419553f912c8a6d44099818e19833
> core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala 481a400067ec97ed97a2bbd8506b34960a5ec000
> core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala addd11ab8be2a1c5de0e43f006de1087032fa6d8
> core/src/test/scala/unit/kafka/utils/TestUtils.scala 130b6be8414268b9a992514ecbc7561872ccaca7
>
> Diff: https://reviews.apache.org/r/20380/diff/
>
>
> Testing
> -------
>
>
> Thanks,
>
> Guozhang Wang
>
>
Re: Review Request 20380: Fix KAFKA-1395: Address Jun's comments
Posted by Guozhang Wang <gu...@linkedin.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/
-----------------------------------------------------------
(Updated April 24, 2014, 11:22 p.m.)
Review request for kafka.
Summary (updated)
-----------------
Fix KAFKA-1395: Address Jun's comments
Bugs: KAFKA-1395
https://issues.apache.org/jira/browse/KAFKA-1395
Repository: kafka
Description (updated)
-------
minor fix 2
minor fix
Move create server/producer and create topic to setUp in LogRecoveryTest
Address Jun's comments
Incoporate Neha's comments
remove waitUntilLeaderIsElectedOrChanged
KAFKA-1395.v1
Diffs (updated)
-----
core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 7125ec9c03e634d7625a315a944eaf5088074eed
core/src/test/scala/unit/kafka/integration/FetcherTest.scala 4075068a80d6e71a3446a579112541d5b4892854
core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala 731ee59e67e302f4cb1da12b1d4ae7ff59010aea
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala d1d969e6c7a5183fa9877fcd12cf49de0cead62a
core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala 16e716440099d62198af3bbadaf5b7d7bc496735
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala 7a0ef6faeaa419553f912c8a6d44099818e19833
core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala 481a400067ec97ed97a2bbd8506b34960a5ec000
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala addd11ab8be2a1c5de0e43f006de1087032fa6d8
core/src/test/scala/unit/kafka/utils/TestUtils.scala 130b6be8414268b9a992514ecbc7561872ccaca7
Diff: https://reviews.apache.org/r/20380/diff/
Testing
-------
Thanks,
Guozhang Wang
Re: Review Request 20380: Fix KAFKA-1395: incorporate Neha's comment,
ensure createProducer use ack = -1 and type = async,
with configurable serializer and partitioner
Posted by Guozhang Wang <gu...@linkedin.com>.
> On April 22, 2014, 10 p.m., Jun Rao wrote:
> > core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala, lines 114-116
> > <https://reviews.apache.org/r/20380/diff/3/?file=564586#file564586line114>
> >
> > For this particular test, resending in the producer could introduce duplicates and the test is sensitive to # of duplicates. So, we probably have to create the topic before hand using TestUtils.createTopic().
>
> Guozhang Wang wrote:
> Great point. Will go through all the modified tests once again to check any other issues.
Have gone through all the tests for this issue. Will wait for KAFKA-1389 to commit first then rebase follow-up on it.
- Guozhang
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/#review41070
-----------------------------------------------------------
On April 22, 2014, 5:43 p.m., Guozhang Wang wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/20380/
> -----------------------------------------------------------
>
> (Updated April 22, 2014, 5:43 p.m.)
>
>
> Review request for kafka.
>
>
> Bugs: KAFKA-1395
> https://issues.apache.org/jira/browse/KAFKA-1395
>
>
> Repository: kafka
>
>
> Description
> -------
>
> Incoporate Neha's comments
>
>
> remove waitUntilLeaderIsElectedOrChanged
>
>
> KAFKA-1395.v1
>
>
> Diffs
> -----
>
> core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 1415773dc34d2111eb923eee812b6dc89a353441
> core/src/test/scala/unit/kafka/integration/FetcherTest.scala 9e1a3b76fe118737172debb6e530e6c8863f671e
> core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala 731ee59e67e302f4cb1da12b1d4ae7ff59010aea
> core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala 1bf9462387897e5ad90530a35341a7320993ab29
> core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala 16e716440099d62198af3bbadaf5b7d7bc496735
> core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala ddb24029570329ff9528ea509528b85a5852dab4
> core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala 5305167abf2b2a10ba91d6897f23e70466fefeba
> core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala 1651822f60883e3bb17c75c9b0353ffff00bbd6c
> core/src/test/scala/unit/kafka/utils/TestUtils.scala 4bd59645635cb693de3a638e58ef19363eb742e5
>
> Diff: https://reviews.apache.org/r/20380/diff/
>
>
> Testing
> -------
>
>
> Thanks,
>
> Guozhang Wang
>
>
Re: Review Request 20380: Fix KAFKA-1395: incorporate Neha's comment,
ensure createProducer use ack = -1 and type = async,
with configurable serializer and partitioner
Posted by Guozhang Wang <gu...@linkedin.com>.
> On April 22, 2014, 10 p.m., Jun Rao wrote:
> > core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala, lines 114-116
> > <https://reviews.apache.org/r/20380/diff/3/?file=564586#file564586line114>
> >
> > For this particular test, resending in the producer could introduce duplicates and the test is sensitive to # of duplicates. So, we probably have to create the topic before hand using TestUtils.createTopic().
Great point. Will go through all the modified tests once again to check any other issues.
- Guozhang
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/#review41070
-----------------------------------------------------------
On April 22, 2014, 5:43 p.m., Guozhang Wang wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/20380/
> -----------------------------------------------------------
>
> (Updated April 22, 2014, 5:43 p.m.)
>
>
> Review request for kafka.
>
>
> Bugs: KAFKA-1395
> https://issues.apache.org/jira/browse/KAFKA-1395
>
>
> Repository: kafka
>
>
> Description
> -------
>
> Incoporate Neha's comments
>
>
> remove waitUntilLeaderIsElectedOrChanged
>
>
> KAFKA-1395.v1
>
>
> Diffs
> -----
>
> core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 1415773dc34d2111eb923eee812b6dc89a353441
> core/src/test/scala/unit/kafka/integration/FetcherTest.scala 9e1a3b76fe118737172debb6e530e6c8863f671e
> core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala 731ee59e67e302f4cb1da12b1d4ae7ff59010aea
> core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala 1bf9462387897e5ad90530a35341a7320993ab29
> core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala 16e716440099d62198af3bbadaf5b7d7bc496735
> core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala ddb24029570329ff9528ea509528b85a5852dab4
> core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala 5305167abf2b2a10ba91d6897f23e70466fefeba
> core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala 1651822f60883e3bb17c75c9b0353ffff00bbd6c
> core/src/test/scala/unit/kafka/utils/TestUtils.scala 4bd59645635cb693de3a638e58ef19363eb742e5
>
> Diff: https://reviews.apache.org/r/20380/diff/
>
>
> Testing
> -------
>
>
> Thanks,
>
> Guozhang Wang
>
>
Re: Review Request 20380: Fix KAFKA-1395: incorporate Neha's comment,
ensure createProducer use ack = -1 and type = async,
with configurable serializer and partitioner
Posted by Jun Rao <ju...@gmail.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/#review41070
-----------------------------------------------------------
core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala
<https://reviews.apache.org/r/20380/#comment74453>
For this particular test, resending in the producer could introduce duplicates and the test is sensitive to # of duplicates. So, we probably have to create the topic before hand using TestUtils.createTopic().
core/src/test/scala/unit/kafka/integration/FetcherTest.scala
<https://reviews.apache.org/r/20380/#comment74454>
Same as the above. Sensitive to # produced messages and need to create topic first.
core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala
<https://reviews.apache.org/r/20380/#comment74457>
Same as the above. Sensitive to # produced messages and need to create topic first.
- Jun Rao
On April 22, 2014, 5:43 p.m., Guozhang Wang wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/20380/
> -----------------------------------------------------------
>
> (Updated April 22, 2014, 5:43 p.m.)
>
>
> Review request for kafka.
>
>
> Bugs: KAFKA-1395
> https://issues.apache.org/jira/browse/KAFKA-1395
>
>
> Repository: kafka
>
>
> Description
> -------
>
> Incoporate Neha's comments
>
>
> remove waitUntilLeaderIsElectedOrChanged
>
>
> KAFKA-1395.v1
>
>
> Diffs
> -----
>
> core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 1415773dc34d2111eb923eee812b6dc89a353441
> core/src/test/scala/unit/kafka/integration/FetcherTest.scala 9e1a3b76fe118737172debb6e530e6c8863f671e
> core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala 731ee59e67e302f4cb1da12b1d4ae7ff59010aea
> core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala 1bf9462387897e5ad90530a35341a7320993ab29
> core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala 16e716440099d62198af3bbadaf5b7d7bc496735
> core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala ddb24029570329ff9528ea509528b85a5852dab4
> core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala 5305167abf2b2a10ba91d6897f23e70466fefeba
> core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala 1651822f60883e3bb17c75c9b0353ffff00bbd6c
> core/src/test/scala/unit/kafka/utils/TestUtils.scala 4bd59645635cb693de3a638e58ef19363eb742e5
>
> Diff: https://reviews.apache.org/r/20380/diff/
>
>
> Testing
> -------
>
>
> Thanks,
>
> Guozhang Wang
>
>
Re: Review Request 20380: Fix KAFKA-1395: incorporate Neha's comment,
ensure createProducer use ack = -1 and type = async,
with configurable serializer and partitioner
Posted by Guozhang Wang <gu...@linkedin.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/
-----------------------------------------------------------
(Updated April 22, 2014, 5:43 p.m.)
Review request for kafka.
Summary (updated)
-----------------
Fix KAFKA-1395: incorporate Neha's comment, ensure createProducer use ack = -1 and type = async, with configurable serializer and partitioner
Bugs: KAFKA-1395
https://issues.apache.org/jira/browse/KAFKA-1395
Repository: kafka
Description (updated)
-------
Incoporate Neha's comments
remove waitUntilLeaderIsElectedOrChanged
KAFKA-1395.v1
Diffs (updated)
-----
core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 1415773dc34d2111eb923eee812b6dc89a353441
core/src/test/scala/unit/kafka/integration/FetcherTest.scala 9e1a3b76fe118737172debb6e530e6c8863f671e
core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala 731ee59e67e302f4cb1da12b1d4ae7ff59010aea
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala 1bf9462387897e5ad90530a35341a7320993ab29
core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala 16e716440099d62198af3bbadaf5b7d7bc496735
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala ddb24029570329ff9528ea509528b85a5852dab4
core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala 5305167abf2b2a10ba91d6897f23e70466fefeba
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala 1651822f60883e3bb17c75c9b0353ffff00bbd6c
core/src/test/scala/unit/kafka/utils/TestUtils.scala 4bd59645635cb693de3a638e58ef19363eb742e5
Diff: https://reviews.apache.org/r/20380/diff/
Testing
-------
Thanks,
Guozhang Wang
Re: Review Request 20380: Fix KAFKA-1395: incorporate Jun's comment
Posted by Guozhang Wang <gu...@linkedin.com>.
> On April 21, 2014, 10:11 p.m., Neha Narkhede wrote:
> > core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala, line 122
> > <https://reviews.apache.org/r/20380/diff/2/?file=560977#file560977line122>
> >
> > Is this check for metadata propagation actually required? It seems to me that any test that produces and then consumes data should use acks= -1 which will wait until the data is committed. This will suffice for the test to pass.
acks = -1 itself is not sufficient, we also need to make sure producer.type = sync.
- Guozhang
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/#review40972
-----------------------------------------------------------
On April 16, 2014, 5:11 p.m., Guozhang Wang wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/20380/
> -----------------------------------------------------------
>
> (Updated April 16, 2014, 5:11 p.m.)
>
>
> Review request for kafka.
>
>
> Bugs: KAFKA-1395
> https://issues.apache.org/jira/browse/KAFKA-1395
>
>
> Repository: kafka
>
>
> Description
> -------
>
> remove waitUntilLeaderIsElectedOrChanged
>
>
> KAFKA-1395.v1
>
>
> Diffs
> -----
>
> core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 1415773dc34d2111eb923eee812b6dc89a353441
>
> Diff: https://reviews.apache.org/r/20380/diff/
>
>
> Testing
> -------
>
>
> Thanks,
>
> Guozhang Wang
>
>
Re: Review Request 20380: Fix KAFKA-1395: incorporate Jun's comment
Posted by Neha Narkhede <ne...@gmail.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20380/#review40972
-----------------------------------------------------------
core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala
<https://reviews.apache.org/r/20380/#comment74303>
We need to ensure that TestUtils.createProducer sets acks=-1.
core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala
<https://reviews.apache.org/r/20380/#comment74302>
Is this check for metadata propagation actually required? It seems to me that any test that produces and then consumes data should use acks= -1 which will wait until the data is committed. This will suffice for the test to pass.
- Neha Narkhede
On April 16, 2014, 5:11 p.m., Guozhang Wang wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/20380/
> -----------------------------------------------------------
>
> (Updated April 16, 2014, 5:11 p.m.)
>
>
> Review request for kafka.
>
>
> Bugs: KAFKA-1395
> https://issues.apache.org/jira/browse/KAFKA-1395
>
>
> Repository: kafka
>
>
> Description
> -------
>
> remove waitUntilLeaderIsElectedOrChanged
>
>
> KAFKA-1395.v1
>
>
> Diffs
> -----
>
> core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala 1415773dc34d2111eb923eee812b6dc89a353441
>
> Diff: https://reviews.apache.org/r/20380/diff/
>
>
> Testing
> -------
>
>
> Thanks,
>
> Guozhang Wang
>
>