VinceMu commented on pull request #8666:
URL: https://github.com/apache/kafka/pull/8666#issuecomment-646962690
@dajac just following up on this PR, I've addressed your feedback. Ready for
a re-review.
This is an automated me
Hangleton closed pull request #7160:
URL: https://github.com/apache/kafka/pull/7160
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 to
vitojeng opened a new pull request #8907:
URL: https://github.com/apache/kafka/pull/8907
There are two kind of naming of VOut in Streams module: VOut / Vout.
This PR rename the naming of Vout to VOut.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
vitojeng opened a new pull request #8908:
URL: https://github.com/apache/kafka/pull/8908
Fix following task warning:
```
> Task :streams:javadoc
/Users/vitojeng/kafka/streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java:187:
warning - invalid usage of tag <
dongjinleekr commented on pull request #8130:
URL: https://github.com/apache/kafka/pull/8130#issuecomment-646991777
@mjsax Here is the fix. I investigated the problem and found the following.
The root of the problem is: the consturctors of `XXXStoreBuilder` classes
omit the MetricsSc
dongjinleekr edited a comment on pull request #8130:
URL: https://github.com/apache/kafka/pull/8130#issuecomment-646991777
@mjsax Here is the fix. I investigated the problem and found the following.
The root of the problem is: the consturctors of `XXXStoreBuilder` classes
omit the Me
chia7712 commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r443137719
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java
##
@@ -58,10 +59,12 @@
public final c
chia7712 commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r443137945
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java
##
@@ -299,16 +311,6 @@ private void r
chia7712 commented on pull request #8840:
URL: https://github.com/apache/kafka/pull/8840#issuecomment-647008308
@ijuma @hachikuji Could you take a look?
This is an automated message from the Apache Git Service.
To respond to
junrao commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-647020292
This is a second run of the system tests.
http://testing.confluent.io/confluent-kafka-branch-builder-system-test-results/?prefix=2020-06-19--001.1592614513--chia7712--fix_8334_avoid
abbccdda commented on pull request #8549:
URL: https://github.com/apache/kafka/pull/8549#issuecomment-647041336
@zhaohaidao Thanks for taking a look. I think the KIP description is wrong
about this scenario, as for a transaction coordinator RPC, it will:
1. return INVALID_PRODUCER_EPOCH
mmolimar commented on a change in pull request #7496:
URL: https://github.com/apache/kafka/pull/7496#discussion_r443157994
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -507,6 +508,18 @@ private SinkRecord convertAndTran
abbccdda commented on a change in pull request #8887:
URL: https://github.com/apache/kafka/pull/8887#discussion_r443159967
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -741,29 +741,23 @@ void shutdown(final boolean cle
abbccdda closed pull request #8498:
URL: https://github.com/apache/kafka/pull/8498
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 to t
[
https://issues.apache.org/jira/browse/KAFKA-10121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17141289#comment-17141289
]
Guozhang Wang commented on KAFKA-10121:
---
Thanks for filing this ticket John! Since
guozhangwang commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r443180740
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java
##
@@ -58,10 +59,12 @@
public fin
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10173:
--
Labels: suppress (was: )
> BufferUnderflowException during Kafka Streams Upgrade
> --
chia7712 commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r443184029
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java
##
@@ -58,10 +59,12 @@
public final c
18 matches
Mail list logo
