ijuma commented on pull request #8678:
URL: https://github.com/apache/kafka/pull/8678#issuecomment-629745862
Unrelated Streams failures like:
>
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[false]
ijuma commented on pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-629745896
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426214228
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Repartitioned.scala
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426212066
##
File path:
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/ProducedTest.scala
##
@@ -37,15 +37,15 @@ class ProducedTest
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211984
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala
##
@@ -218,7 +218,7 @@ class KStream[K, V](val
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211787
##
File path:
streams/src/test/java/org/apache/kafka/streams/tests/EosTestClient.java
##
@@ -132,7 +132,8 @@ private KafkaStreams createKafkaStreams(final
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211719
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java
##
@@ -1393,6 +1409,11 @@ public void
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211688
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationWithSslTest.java
##
@@ -42,7 +42,7 @@
private static final
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211685
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##
@@ -213,7 +213,8 @@ private void runSimpleCopyTest(final
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211624
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -484,8 +493,14 @@ private Topology
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211526
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/RepartitionedInternal.java
##
@@ -21,33 +21,33 @@
import
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211555
##
File path:
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java
##
@@ -285,7 +286,28 @@ public void shouldProcessViaThroughTopic() {
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211457
##
File path: streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
##
@@ -925,9 +920,8 @@ void to(final TopicNameExtractor topicExtractor,
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211408
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1082,7 +1081,7 @@ public void cleanUp() {
* This will use the
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211425
##
File path: streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
##
@@ -846,16 +847,13 @@
* from the auto-generated topic using
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211270
##
File path: docs/streams/developer-guide/dsl-api.html
##
@@ -3679,58 +3670,6 @@ KTable-KTable
Foreign-Key
// Write the stream to the output topic, using
mjsax commented on pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#issuecomment-629734751
Call for review @lkokhreidze @vvcephei
Also updates the Scala API...
This is an automated message from the
mjsax opened a new pull request #8679:
URL: https://github.com/apache/kafka/pull/8679
- part of KIP-221
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
ijuma commented on pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-629731366
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
ijuma opened a new pull request #8678:
URL: https://github.com/apache/kafka/pull/8678
This fixes critical bugs in Gradle 6.4:
* Regression: Different daemons are used between IDE and CLI builds for the
same project
* Regression: Main-Class attribute always added to jar manifest
[
https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-1:
-
Assignee: Chris Egerton
> Atomic commit of source connector records and offsets
>
bdbyrne commented on pull request #8658:
URL: https://github.com/apache/kafka/pull/8658#issuecomment-629714866
@cmccabe this is ready for review. Thanks!
This is an automated message from the Apache Git Service.
To respond
bdbyrne commented on pull request #8658:
URL: https://github.com/apache/kafka/pull/8658#issuecomment-629713796
I've applied @d8tltanc's updates to `quota_test.py` and verified their
success:
```
docker exec ducker01 bash -c "cd /opt/kafka-dev && ducktape --cluster-file
abbccdda commented on pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-629694343
Double checked the failures are due to known flaky test
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
[
https://issues.apache.org/jira/browse/KAFKA-9955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-9955.
---
Resolution: Fixed
> Exceptions thrown from SinkTask::close shadow other
guozhangwang merged pull request #8659:
URL: https://github.com/apache/kafka/pull/8659
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-9617.
--
Fix Version/s: 2.6.0
Resolution: Fixed
> Replica Fetcher can mark partition as failed
guozhangwang commented on pull request #8659:
URL: https://github.com/apache/kafka/pull/8659#issuecomment-629677117
Thanks @chia7712
This is an automated message from the Apache Git Service.
To respond to the message,
guozhangwang commented on a change in pull request #8671:
URL: https://github.com/apache/kafka/pull/8671#discussion_r426170554
##
File path: core/src/main/scala/kafka/tools/StreamsResetter.java
##
@@ -673,11 +673,17 @@ private boolean isInternalTopic(final String topicName) {
guozhangwang commented on pull request #8671:
URL: https://github.com/apache/kafka/pull/8671#issuecomment-629672739
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
guozhangwang removed a comment on pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-629664209
test this
This is an automated message from the Apache Git Service.
To respond to the message,
guozhangwang commented on pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-629664171
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
bbejeck commented on a change in pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#discussion_r426163653
##
File path: docs/streams/upgrade-guide.html
##
@@ -35,7 +35,7 @@ Upgrade Guide and API Changes
Upgrading from any older version to
bbejeck commented on a change in pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#discussion_r426163653
##
File path: docs/streams/upgrade-guide.html
##
@@ -35,7 +35,7 @@ Upgrade Guide and API Changes
Upgrading from any older version to
[
https://issues.apache.org/jira/browse/KAFKA-10001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10001:
--
Labels: streams (was: )
> Store's own restore listener should be triggered in store
[
https://issues.apache.org/jira/browse/KAFKA-10001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-10001.
---
Fix Version/s: 2.6.0
Resolution: Fixed
> Store's own restore listener should be
[
https://issues.apache.org/jira/browse/KAFKA-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8918.
--
Resolution: Fixed
> Flaky Test
>
[
https://issues.apache.org/jira/browse/KAFKA-8197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8197.
--
Resolution: Fixed
> Flaky Test kafka.server.DynamicBrokerConfigTest >
>
[
https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109100#comment-17109100
]
Guozhang Wang commented on KAFKA-6579:
--
[~ableegoldman] Is it resolved now?
> Consolidate window
[
https://issues.apache.org/jira/browse/KAFKA-5209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-5209:
Assignee: (was: Umesh Chaudhary)
> Transient failure:
[
https://issues.apache.org/jira/browse/KAFKA-7042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7042.
--
Resolution: Not A Problem
> Fall back to the old behavior when the broker is too old to
[
https://issues.apache.org/jira/browse/KAFKA-5719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-5719.
--
Resolution: Fixed
> Create a quickstart archetype project for Kafka Streams
>
[
https://issues.apache.org/jira/browse/KAFKA-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2045:
-
Labels: newbie++ (was: )
> Memory Management on the consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-3103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-3103.
--
Resolution: Fixed
> Transient Failure in
>
[
https://issues.apache.org/jira/browse/KAFKA-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-1985.
--
Resolution: Fixed
> Document on possible error codes for each response type
>
[
https://issues.apache.org/jira/browse/KAFKA-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-1617.
--
Resolution: Won't Fix
> Move Metadata Cache to TopicManager and handling of Offset Request to
[
https://issues.apache.org/jira/browse/KAFKA-3168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-3168.
--
Resolution: Fixed
> Failure in kafka.integration.PrimitiveApiTest.testPipelinedProduceRequests
[
https://issues.apache.org/jira/browse/KAFKA-3168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-3168:
Assignee: (was: Parag Shah)
> Failure in
[
https://issues.apache.org/jira/browse/KAFKA-3261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-3261:
Assignee: (was: chen zhu)
> Consolidate class kafka.cluster.BrokerEndPoint and
[
https://issues.apache.org/jira/browse/KAFKA-3261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-3261:
-
Labels: newbie (was: )
> Consolidate class kafka.cluster.BrokerEndPoint and
[
https://issues.apache.org/jira/browse/KAFKA-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-3738.
--
Resolution: Fixed
We have soak tests and perf benchmarks today.
> Add load system tests for
[
https://issues.apache.org/jira/browse/KAFKA-3220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-3220.
--
Resolution: Fixed
Did not see this recently.
> Failure in
[
https://issues.apache.org/jira/browse/KAFKA-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-1602.
--
Resolution: Not A Problem
> Use single error code for offset commit response
>
[
https://issues.apache.org/jira/browse/KAFKA-4143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-4143.
--
Resolution: Fixed
Did not see this recently.
> Transient failure in
>
[
https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109054#comment-17109054
]
Yuriy Badalyantc commented on KAFKA-10009:
--
Exactly. I want an offset of a last true record in
[
https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109045#comment-17109045
]
Chia-Ping Tsai commented on KAFKA-10009:
So you want to get end offset which is associated to a
[
https://issues.apache.org/jira/browse/KAFKA-6959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez resolved KAFKA-6959.
--
Resolution: Fixed
> Any impact we foresee if we upgrade Linux version or move to VM
[
https://issues.apache.org/jira/browse/KAFKA-8916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez resolved KAFKA-8916.
--
Resolution: Invalid
Closing this as there is no bug or development required.
Please
[
https://issues.apache.org/jira/browse/KAFKA-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109030#comment-17109030
]
Alexandre Dupriez edited comment on KAFKA-9794 at 5/16/20, 12:13 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109030#comment-17109030
]
Alexandre Dupriez commented on KAFKA-9794:
--
Would you have some data to share? CPU profiles,
[
https://issues.apache.org/jira/browse/KAFKA-8898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109029#comment-17109029
]
Alexandre Dupriez commented on KAFKA-8898:
--
Could you please provide some data on the memory
[
https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109017#comment-17109017
]
Yuriy Badalyantc commented on KAFKA-10009:
--
Even with read_committed isolation level
[
https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109009#comment-17109009
]
Chia-Ping Tsai commented on KAFKA-10009:
If you want to seek to the end offsets in case of
chia7712 commented on a change in pull request #8673:
URL: https://github.com/apache/kafka/pull/8673#discussion_r426134960
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java
##
@@ -297,6 +295,15 @@ public void
Hangleton commented on pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#issuecomment-629612091
@mumrah
I think it would be preferable to avoid using JNI libraries, because it can
add maintenance overhead and require additional configurations for tests. It
also
[
https://issues.apache.org/jira/browse/KAFKA-9564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108919#comment-17108919
]
Alexandre Dupriez edited comment on KAFKA-9564 at 5/16/20, 8:29 AM:
[
https://issues.apache.org/jira/browse/KAFKA-9564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108919#comment-17108919
]
Alexandre Dupriez commented on KAFKA-9564:
--
2020 May 16^th^ - integration tests for basic
[
https://issues.apache.org/jira/browse/KAFKA-8815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez resolved KAFKA-8815.
--
Resolution: Not A Problem
System failure. Not related to Kafka.
> Kafka broker
[
https://issues.apache.org/jira/browse/KAFKA-8815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108917#comment-17108917
]
Alexandre Dupriez edited comment on KAFKA-8815 at 5/16/20, 8:27 AM:
[
https://issues.apache.org/jira/browse/KAFKA-8815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108917#comment-17108917
]
Alexandre Dupriez commented on KAFKA-8815:
--
Hi [~william_reynolds]. In this case, the problem
Yuriy Badalyantc created KAFKA-10009:
Summary: Add method for getting last record offset in kafka
partition
Key: KAFKA-10009
URL: https://issues.apache.org/jira/browse/KAFKA-10009
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuriy Badalyantc updated KAFKA-10009:
-
Priority: Minor (was: Major)
> Add method for getting last record offset in kafka
showuon commented on pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#issuecomment-629607982
Thanks @abbccdda , I'll wait for @ableegoldman 's confirmation to see if I
have to revert this version back to `2.3`. Thank you very much.
showuon commented on a change in pull request #8675:
URL: https://github.com/apache/kafka/pull/8675#discussion_r426131494
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -424,7 +425,7 @@ object ConfigCommand extends Config {
case
74 matches
Mail list logo
