[
https://issues.apache.org/jira/browse/KAFKA-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1486:
-
Assignee: (was: Raul Castro Fernandez)
> Move all request/responses to
[
https://issues.apache.org/jira/browse/KAFKA-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14106264#comment-14106264
]
Raul Castro Fernandez commented on KAFKA-1486:
--
Please do!
> M
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1524:
-
Attachment: KAFKA-1524_2014-08-20_09:14:59.patch
> Implement transactio
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14104085#comment-14104085
]
Raul Castro Fernandez commented on KAFKA-1524:
--
Updated reviewboard h
/apache/kafka/common/record/RecordTest.java
2765913d5bfd40117b60de9ee2eb6f47fe34486c
Diff: https://reviews.apache.org/r/24411/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103205#comment-14103205
]
Raul Castro Fernandez commented on KAFKA-1565:
--
If this patch is
[
https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1527:
-
Attachment: KAFKA-1527_2014-08-19_18:22:26.patch
> SimpleConsumer should
[
https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1569:
-
Summary: Tool for performance and correctness of transactions end-to-end
(was
[
https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103195#comment-14103195
]
Raul Castro Fernandez commented on KAFKA-1527:
--
Updated reviewboard h
/23906/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102543#comment-14102543
]
Raul Castro Fernandez commented on KAFKA-1526:
--
Updated reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1526:
-
Attachment: KAFKA-1526_2014-08-19_10:54:51.patch
> Producer performance t
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1527:
-
Attachment: KAFKA-1527_2014-08-19_10:39:53.patch
> SimpleConsumer should
[
https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102513#comment-14102513
]
Raul Castro Fernandez commented on KAFKA-1527:
--
Updated reviewboard h
://reviews.apache.org/r/23906/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1524:
-
Attachment: KAFKA-1524_2014-08-18_09:39:34.patch
> Implement transactio
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14100825#comment-14100825
]
Raul Castro Fernandez commented on KAFKA-1524:
--
Updated reviewboard h
t/java/org/apache/kafka/common/record/RecordTest.java
2765913d5bfd40117b60de9ee2eb6f47fe34486c
Diff: https://reviews.apache.org/r/24411/diff/
Testing
---
Thanks,
Raul Castro Fernandez
ality out of the constructor,
however I am not sure how to address it, as putting it in the
begin/abort/commit would have similar problems as the asynchronicity commented
above. I think we should discuss this further.
- Raul
---
Th
[
https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1569:
-
Summary: Tooling for performance and corectness of transactions end-to-end
(was
Raul Castro Fernandez created KAFKA-1579:
Summary: End-to-End tool to measure performance and correctness
test
Key: KAFKA-1579
URL: https://issues.apache.org/jira/browse/KAFKA-1579
Project
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1541:
-
Attachment: KAFKA-1541.patch
> Add transactional request definitions to clie
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14088142#comment-14088142
]
Raul Castro Fernandez commented on KAFKA-1541:
--
Created reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14088133#comment-14088133
]
Raul Castro Fernandez commented on KAFKA-1524:
--
Created reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1524:
-
Attachment: KAFKA-1524.patch
> Implement transactional produ
: https://reviews.apache.org/r/24417/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1524:
-
Attachment: (was: KAFKA-1524.patch)
> Implement transactional produ
/TransactionContextTest.java
PRE-CREATION
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java
94a11121e207d5cf94dbc94443a8aa7edf387782
Diff: https://reviews.apache.org/r/24411/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1569:
-
Attachment: KAFKA-1569.patch
> Create tool to test correctness of transacti
[
https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14085385#comment-14085385
]
Raul Castro Fernandez commented on KAFKA-1569:
--
Created reviewboard h
-CREATION
core/src/main/scala/kafka/tools/TransactionalProducerTest.scala PRE-CREATION
Diff: https://reviews.apache.org/r/24268/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14085369#comment-14085369
]
Raul Castro Fernandez commented on KAFKA-1541:
--
Created reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1541:
-
Attachment: KAFKA-1541.patch
> Add transactional request definitions to clie
clients/src/main/java/org/apache/kafka/common/requests/TransactionResponse.java
PRE-CREATION
Diff: https://reviews.apache.org/r/24267/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14085352#comment-14085352
]
Raul Castro Fernandez commented on KAFKA-1524:
--
Created reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1524:
-
Attachment: KAFKA-1524.patch
> Implement transactional produ
/TransactionContextTest.java
PRE-CREATION
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java
94a11121e207d5cf94dbc94443a8aa7edf387782
Diff: https://reviews.apache.org/r/24265/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14085193#comment-14085193
]
Raul Castro Fernandez commented on KAFKA-1569:
--
Created reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1569:
-
Attachment: KAFKA-1569.patch
> Create tool to test correctness of transacti
/TransactionalConsumerTest.scala PRE-CREATION
core/src/main/scala/kafka/tools/TransactionalProducerTest.scala PRE-CREATION
Diff: https://reviews.apache.org/r/24255/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1569:
-
Summary: Create tool to test correctness of transactions end-to-end (was
[
https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1569:
-
Summary: Create tool to test end-to-end correctness when using transactions
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14085171#comment-14085171
]
Raul Castro Fernandez commented on KAFKA-1541:
--
Created reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1541:
-
Attachment: KAFKA-1541.patch
> Add transactional request definitions to clie
-CREATION
clients/src/main/java/org/apache/kafka/common/requests/TransactionResponse.java
PRE-CREATION
Diff: https://reviews.apache.org/r/24253/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1524:
-
Attachment: KAFKA-1524.patch
> Implement transactional produ
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14085063#comment-14085063
]
Raul Castro Fernandez commented on KAFKA-1524:
--
Created reviewboard h
/TransactionContextTest.java
PRE-CREATION
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java
94a11121e207d5cf94dbc94443a8aa7edf387782
Diff: https://reviews.apache.org/r/24245/diff/
Testing
---
Thanks,
Raul Castro Fernandez
Raul Castro Fernandez created KAFKA-1569:
Summary: Creat tool to test end-to-end correctness in
transactional mode
Key: KAFKA-1569
URL: https://issues.apache.org/jira/browse/KAFKA-1569
; > May need to unnecessarily wait. i.e., who interrupts?
True. My intention was to check if all ACKs are received, otherwise wait a
fraction of the total timeout. Instead of wait(remainingWaitMs) it would be
something like wait(remainingWaitMs/4).
- Raul
[
https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1527:
-
Attachment: KAFKA-1527.patch
> SimpleConsumer should be transaction-aw
[
https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073830#comment-14073830
]
Raul Castro Fernandez commented on KAFKA-1527:
--
Created reviewboard h
/main/scala/kafka/consumer/SimpleConsumer.scala
0e64632210385ef63c2ad3445b55ac4f37a63df2
core/src/main/scala/kafka/tools/SimpleConsumerPerformance.scala
7602b8d705970a5dab49ed36d117346a960701ac
Diff: https://reviews.apache.org/r/23906/diff/
Testing
---
Thanks,
Raul Castro Fernandez
/main/scala/kafka/consumer/SimpleConsumer.scala
0e64632210385ef63c2ad3445b55ac4f37a63df2
core/src/main/scala/kafka/tools/SimpleConsumerPerformance.scala
7602b8d705970a5dab49ed36d117346a960701ac
Diff: https://reviews.apache.org/r/23905/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065194#comment-14065194
]
Raul Castro Fernandez commented on KAFKA-1524:
--
Created reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1526:
-
Attachment: (was: KAFKA-1526.patch)
> Producer performance tool should h
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1524:
-
Attachment: KAFKA-1524.patch
> Implement transactional produ
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1524:
-
Attachment: (was: KAFKA-1524.patch)
> Implement transactional produ
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065192#comment-14065192
]
Raul Castro Fernandez commented on KAFKA-1526:
--
Created reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1526:
-
Attachment: KAFKA-1526.patch
> Producer performance tool should have an opt
/ProducerPerformance.scala
fc3e7241dda0672deb8c5ce5d7c983c320ec45ee
Diff: https://reviews.apache.org/r/23647/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1541:
-
Attachment: (was: KAFKA-1541.patch)
> Add transactional request definiti
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065171#comment-14065171
]
Raul Castro Fernandez commented on KAFKA-1541:
--
Created reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1541:
-
Attachment: KAFKA-1541.patch
> Add transactional request definitions to clie
-CREATION
clients/src/main/java/org/apache/kafka/common/requests/TransactionResponse.java
PRE-CREATION
Diff: https://reviews.apache.org/r/23646/diff/
Testing
---
Thanks,
Raul Castro Fernandez
-CREATION
clients/src/main/java/org/apache/kafka/common/requests/TransactionResponse.java
PRE-CREATION
Diff: https://reviews.apache.org/r/23645/diff/
Testing
---
Thanks,
Raul Castro Fernandez
-CREATION
clients/src/main/java/org/apache/kafka/common/requests/TransactionResponse.java
PRE-CREATION
Diff: https://reviews.apache.org/r/23644/diff/
Testing
---
Thanks,
Raul Castro Fernandez
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1541:
-
Attachment: KAFKA-1541.patch
> Add transactional request definitions to clie
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1541:
-
Attachment: (was: KAFKA-1541.patch)
> Add transactional request definiti
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1541:
-
Attachment: KAFKA-1541.patch
> Add transactional request definitions to clie
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1541:
-
Attachment: (was: KAFKA-1541.patch)
> Add transactional request definiti
[
https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1524:
-
Attachment: KAFKA-1524.patch
> Implement transactional produ
[
https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1526:
-
Attachment: KAFKA-1526.patch
> Producer performance tool should have an opt
[
https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1541:
-
Attachment: KAFKA-1541.patch
> Add transactional request definitions to clie
[
https://issues.apache.org/jira/browse/KAFKA-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Castro Fernandez updated KAFKA-1525:
-
Assignee: Dong Lin (was: Raul Castro Fernandez)
> DumpLogSegments should pr
[
https://issues.apache.org/jira/browse/KAFKA-179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14029711#comment-14029711
]
Raul Castro Fernandez commented on KAFKA-179:
-
Just tried it. It seems tha
[
https://issues.apache.org/jira/browse/KAFKA-179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14029712#comment-14029712
]
Raul Castro Fernandez commented on KAFKA-179:
-
Should I mark it as so
[
https://issues.apache.org/jira/browse/KAFKA-179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14028219#comment-14028219
]
Raul Castro Fernandez commented on KAFKA-179:
-
The function recoverLog(
80 matches
Mail list logo