[
https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424321#comment-17424321
]
Ralph Matthias Debusmann commented on KAFKA-13164:
--
Hi Hao Li,
thanks!
[
https://issues.apache.org/jira/browse/KAFKA-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13339:
Component/s: (was: consumer)
streams
> Kstream not fetch all the mess
[
https://issues.apache.org/jira/browse/KAFKA-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13339.
-
Resolution: Invalid
> Kstream not fetch all the messages
> -
[
https://issues.apache.org/jira/browse/KAFKA-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424304#comment-17424304
]
Matthias J. Sax commented on KAFKA-13339:
-
The logs you shared don't contain any
[
https://issues.apache.org/jira/browse/KAFKA-13326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424298#comment-17424298
]
Matthias J. Sax commented on KAFKA-13326:
-
Neither mirror-maker2 not replicator
[
https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424296#comment-17424296
]
Hao Li commented on KAFKA-13164:
Hi Ralph,
I was able to test it out with following
mjsax opened a new pull request #11380:
URL: https://github.com/apache/kafka/pull/11380
Call for review @guozhangwang @cadonna
--
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 the specific comme
[
https://issues.apache.org/jira/browse/KAFKA-13345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-13345:
---
Assignee: Matthias J. Sax
> WindowStore should use "delete" policy when duplicates
Matthias J. Sax created KAFKA-13345:
---
Summary: WindowStore should use "delete" policy when duplicates
are enabled
Key: KAFKA-13345
URL: https://issues.apache.org/jira/browse/KAFKA-13345
Project: Kaf
Pakkiyarasu P created KAFKA-13344:
-
Summary: In a Kafka Cluster (3 brokers), I am trying to consume
message from single broker. When the broker is down, I am continuing to traffic
messages from consumer because other 2 brokers are running.
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424158#comment-17424158
]
Tomas Forsman commented on KAFKA-13261:
---
[~vcrfxia] thank you so much for solving
jolshan commented on pull request #11331:
URL: https://github.com/apache/kafka/pull/11331#issuecomment-933821031
@ijuma
> Thanks for the PR. A high-level question, what are we trying to optimize
for here?
>Requests that don't include topic ids
Requests that include topic ids
Bo
akatona84 commented on pull request #11373:
URL: https://github.com/apache/kafka/pull/11373#issuecomment-933672624
@granthenke , could you take a look as well? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
[
https://issues.apache.org/jira/browse/KAFKA-12762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-12762:
---
Fix Version/s: 3.0.1
> Use connection timeout when polling the network for new connections
>
[
https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-9747:
--
Fix Version/s: 3.0.1
> No tasks created for a connector
>
>
>
mimaison commented on pull request #11174:
URL: https://github.com/apache/kafka/pull/11174#issuecomment-933641417
Applied to 3.0:
https://github.com/apache/kafka/commit/9218b8cc5f10a1fb79c74e9a49ab36fd51e68916
--
This is an automated message from the Apache Git Service.
To respond to the
ccding commented on pull request #11345:
URL: https://github.com/apache/kafka/pull/11345#issuecomment-933622186
While I am working on the test, I have a question:
The `log.flush()` function is also called at
https://github.com/apache/kafka/blob/db42afd6e24ef4291390b4d1c1f10758beedefe
mimaison commented on pull request #8984:
URL: https://github.com/apache/kafka/pull/8984#issuecomment-933614436
@huxihx can you rebase your PR? Thanks
--
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 g
mimaison commented on pull request #11276:
URL: https://github.com/apache/kafka/pull/11276#issuecomment-933613268
@viktorsomogyi Thanks for the PR. I think we should do a small KIP for this
change. There may be users relying on HTTP TRACE today.
--
This is an automated message from the A
[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424004#comment-17424004
]
Andrew patterson commented on KAFKA-12994:
--
Next and final PR is here [https://
mimaison commented on a change in pull request #11220:
URL: https://github.com/apache/kafka/pull/11220#discussion_r721467669
##
File path:
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java
##
@@ -52,9 +52,39 @@ default String originalTo
officialpatterson opened a new pull request #11379:
URL: https://github.com/apache/kafka/pull/11379
As raised in KAFKA-12994, All tests that use the old API should be either
eliminated or migrated to the new API in order to remove the
@SuppressWarnings("deprecation") annotations.
Th
[
https://issues.apache.org/jira/browse/KAFKA-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423982#comment-17423982
]
Joel Wiegman edited comment on KAFKA-13343 at 10/4/21, 2:51 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423982#comment-17423982
]
Joel Wiegman commented on KAFKA-13343:
--
Agreed. The partitions argument says "If n
chia7712 opened a new pull request #11378:
URL: https://github.com/apache/kafka/pull/11378
Including the pool status can help us to understand what happens in the
moment. The new message is shown below.
`
Failed to allocate 200 bytes within the configured max blocking time 10 ms.
Tot
mimaison commented on pull request #11220:
URL: https://github.com/apache/kafka/pull/11220#issuecomment-933433123
@OmniaGM Sorry for the delay, I was away for a few weeks. I'm back now and
I'll take a look
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/KAFKA-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liyunhua updated KAFKA-13343:
-
Description:
[链接标题|https://kafka.apache.org/quickstart]
i'm a new comer to kafka, so i learn by QUI
[
https://issues.apache.org/jira/browse/KAFKA-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liyunhua updated KAFKA-13343:
-
Description:
https://kafka.apache.org/quickstart
i'm a new comer to kafka, so i learn by QUICKSTART,
liyunhua created KAFKA-13343:
Summary: kafka-topics.sh throws error with the step3 command of
quickstart's steps
Key: KAFKA-13343
URL: https://issues.apache.org/jira/browse/KAFKA-13343
Project: Kafka
wenzelcheng commented on pull request #11377:
URL: https://github.com/apache/kafka/pull/11377#issuecomment-933342185
@ijuma @tombentley request for review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
wenzelcheng opened a new pull request #11377:
URL: https://github.com/apache/kafka/pull/11377
It may cause the file handle not to be released.
--
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 the
showuon commented on a change in pull request #11234:
URL: https://github.com/apache/kafka/pull/11234#discussion_r721155436
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java
##
@@ -212,18 +216,15 @@ public void remove(final W
showuon commented on a change in pull request #11234:
URL: https://github.com/apache/kafka/pull/11234#discussion_r721153713
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java
##
@@ -351,10 +345,8 @@ public V fetchSession(final
patrickstuedi commented on a change in pull request #11234:
URL: https://github.com/apache/kafka/pull/11234#discussion_r720243284
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java
##
@@ -212,18 +216,15 @@ public void remove(f
34 matches
Mail list logo
