[
https://issues.apache.org/jira/browse/KAFKA-10902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462471#comment-17462471
]
Illia commented on KAFKA-10902:
---
We observe the same issue once in few weeks. It's not cle
Andrei Lakhmanets created KAFKA-13556:
-
Summary: Kafka cluster loses the controller
Key: KAFKA-13556
URL: https://issues.apache.org/jira/browse/KAFKA-13556
Project: Kafka
Issue Type: Bug
dajac merged pull request #11596:
URL: https://github.com/apache/kafka/pull/11596
--
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 comment.
To unsubscribe, e-mail: jira-unsubscr...
[
https://issues.apache.org/jira/browse/KAFKA-13556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrei Lakhmanets updated KAFKA-13556:
--
Description:
Hi team,
*Kafka version:* 2.8.1
*Configuration:* 3 kafka brokers in diff
[
https://issues.apache.org/jira/browse/KAFKA-13556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrei Lakhmanets updated KAFKA-13556:
--
Description:
Hi team,
*Kafka version:* 2.8.1
*Configuration:* 3 kafka brokers in diff
mimaison commented on pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#issuecomment-997796358
A point that was raised in the discussion on KIP-810 is whether we should
prevent setting `headers.delimiter`, `headers.separator` and
`headers.key.separator` to colliding valu
[
https://issues.apache.org/jira/browse/KAFKA-13556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrei Lakhmanets updated KAFKA-13556:
--
Description:
Hi team,
*Kafka version:* 2.8.1
*Configuration:* 3 kafka brokers in diff
[
https://issues.apache.org/jira/browse/KAFKA-13556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrei Lakhmanets updated KAFKA-13556:
--
Description:
Hi team,
*Kafka version:* 2.8.1
*Configuration:* 3 kafka brokers in diff
[
https://issues.apache.org/jira/browse/KAFKA-13556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrei Lakhmanets updated KAFKA-13556:
--
Description:
Hi team,
*Kafka version:* 2.8.1
*Configuration:* 3 kafka brokers in diff
C0urante commented on pull request #11588:
URL: https://github.com/apache/kafka/pull/11588#issuecomment-997964564
@blcksrx did you catch the [mailing list
thread](https://www.mail-archive.com/dev@kafka.apache.org/msg120391.html) about
this? I left this comment on there:
> I think th
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462669#comment-17462669
]
yazgoo commented on KAFKA-12495:
Hi, any news on this issue ?
I have been testing and it
blcksrx commented on pull request #11588:
URL: https://github.com/apache/kafka/pull/11588#issuecomment-998130538
Absolutely you are right, maybe its the best to consider retryMaxTimeout
beside of that. Also it makes sense to invoke stop in that case but
re-initialisation im not sure about
mimaison commented on a change in pull request #11564:
URL: https://github.com/apache/kafka/pull/11564#discussion_r772547748
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -146,62 +146,71 @@ object ConsoleProducer {
.describedAs("size")
mimaison merged pull request #11408:
URL: https://github.com/apache/kafka/pull/11408
--
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 comment.
To unsubscribe, e-mail: jira-unsubscr
mimaison commented on pull request #11408:
URL: https://github.com/apache/kafka/pull/11408#issuecomment-998135424
@showuon Can you also open a PR against
https://github.com/apache/kafka-site? Otherwise this will only be fixed when we
release 3.2.0. Thanks
--
This is an automated message
guozhangwang commented on pull request #11582:
URL: https://github.com/apache/kafka/pull/11582#issuecomment-998160736
LGTM, I believe @vvcephei will address the remaining comments right after
it's merged.
--
This is an automated message from the Apache Git Service.
To respond to the mes
vvcephei commented on pull request #11582:
URL: https://github.com/apache/kafka/pull/11582#issuecomment-998165138
Thanks, all! This is all really good feedback, and we clearly have some
opportunities to tighten up both the API and internals.
I will go through the follow-on tickets th
vvcephei merged pull request #11582:
URL: https://github.com/apache/kafka/pull/11582
--
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 comment.
To unsubscribe, e-mail: jira-unsubscr
vvcephei closed pull request #11614:
URL: https://github.com/apache/kafka/pull/11614
--
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 comment.
To unsubscribe, e-mail: jira-unsubscr
vvcephei closed pull request #11583:
URL: https://github.com/apache/kafka/pull/11583
--
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 comment.
To unsubscribe, e-mail: jira-unsubscr
[
https://issues.apache.org/jira/browse/KAFKA-13557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-13557:
Assignee: John Roesler
> IQv2: Remove swapResult from the public API
> --
John Roesler created KAFKA-13557:
Summary: IQv2: Remove swapResult from the public API
Key: KAFKA-13557
URL: https://issues.apache.org/jira/browse/KAFKA-13557
Project: Kafka
Issue Type: Sub-t
Kirk True created KAFKA-13558:
-
Summary: NioEchoServer fails to close resources
Key: KAFKA-13558
URL: https://issues.apache.org/jira/browse/KAFKA-13558
Project: Kafka
Issue Type: Bug
Affects
vvcephei opened a new pull request #11617:
URL: https://github.com/apache/kafka/pull/11617
Follow-on from https://github.com/apache/kafka/pull/11582 .
Removes a public API method in favor of an internal utility method.
### Committer Checklist (excluded from commit message)
- [ ]
kirktrue opened a new pull request #11618:
URL: https://github.com/apache/kafka/pull/11618
Due to resource leaks in the `NioEchoServer`, at times it won't start
properly to accept clients and will throw an exception in the
`ServerSocketChannel.accept()` call. Previous to this change, the e
mjsax commented on a change in pull request #11617:
URL: https://github.com/apache/kafka/pull/11617#discussion_r772606055
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/InternalQueryResultUtil.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software
mjsax commented on a change in pull request #11617:
URL: https://github.com/apache/kafka/pull/11617#discussion_r772607893
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/InternalQueryResultUtil.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software
mjsax commented on a change in pull request #11617:
URL: https://github.com/apache/kafka/pull/11617#discussion_r772608820
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/InternalQueryResultUtil.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software
guozhangwang commented on a change in pull request #11611:
URL: https://github.com/apache/kafka/pull/11611#discussion_r772623797
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -951,6 +951,8 @@
public static final String IQ_CONSIST
vvcephei commented on a change in pull request #11617:
URL: https://github.com/apache/kafka/pull/11617#discussion_r772639230
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/InternalQueryResultUtil.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/KAFKA-13525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13525.
--
Resolution: Fixed
> IQv2: Implement KeyQuery from the KIP
> --
vvcephei commented on a change in pull request #11617:
URL: https://github.com/apache/kafka/pull/11617#discussion_r772642542
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/InternalQueryResultUtil.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Softw
mjsax commented on a change in pull request #11617:
URL: https://github.com/apache/kafka/pull/11617#discussion_r772654218
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/InternalQueryResultUtil.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software
mjsax commented on a change in pull request #11617:
URL: https://github.com/apache/kafka/pull/11617#discussion_r772654543
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/InternalQueryResultUtil.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software
mjsax commented on a change in pull request #11617:
URL: https://github.com/apache/kafka/pull/11617#discussion_r772656401
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/internals/SucceededQueryResult.java
##
@@ -0,0 +1,147 @@
+/*
+ * Licensed to the Apache
vvcephei commented on a change in pull request #11617:
URL: https://github.com/apache/kafka/pull/11617#discussion_r772679426
##
File path:
streams/src/main/java/org/apache/kafka/streams/query/internals/SucceededQueryResult.java
##
@@ -0,0 +1,147 @@
+/*
+ * Licensed to the Apac
vvcephei commented on pull request #11617:
URL: https://github.com/apache/kafka/pull/11617#issuecomment-998384051
Unrelated test failures:
```
Build / JDK 17 and Scala 2.13 /
org.apache.kafka.common.security.oauthbearer.secured.RefreshingHttpsJwksTest.testBasicScheduleRe
vvcephei merged pull request #11617:
URL: https://github.com/apache/kafka/pull/11617
--
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 comment.
To unsubscribe, e-mail: jira-unsubscr
jeffkbkim commented on a change in pull request #11571:
URL: https://github.com/apache/kafka/pull/11571#discussion_r772792590
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java
##
@@ -1837,7 +1837,12 @@ private DescribeGroupsResponse
jeffkbkim commented on a change in pull request #11566:
URL: https://github.com/apache/kafka/pull/11566#discussion_r772795815
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java
##
@@ -486,6 +487,43 @@ public void testRe
jeffkbkim commented on a change in pull request #11566:
URL: https://github.com/apache/kafka/pull/11566#discussion_r772797072
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -181,6 +182,7 @@ class GroupCoordinator(val brokerId: Int,
jeffkbkim commented on a change in pull request #11566:
URL: https://github.com/apache/kafka/pull/11566#discussion_r772798218
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -467,6 +468,7 @@ boolean joinGroupIfNeed
mjsax commented on a change in pull request #11535:
URL: https://github.com/apache/kafka/pull/11535#discussion_r772838710
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -1097,15 +1097,20 @@ long decodeTimestamp(final Stri
frankshi created KAFKA-13559:
Summary: The broker's ProduceResponse may be delayed for 300ms
Key: KAFKA-13559
URL: https://issues.apache.org/jira/browse/KAFKA-13559
Project: Kafka
Issue Type: Ta
[
https://issues.apache.org/jira/browse/KAFKA-13559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
frankshi updated KAFKA-13559:
-
Description:
Hi team:
We have found the value in the source code
[here|https://github.com/apache/kafka
[
https://issues.apache.org/jira/browse/KAFKA-13559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
frankshi updated KAFKA-13559:
-
Description:
Hi team:
We have found the value in the source code
[here|https://github.com/apache/kafka
[
https://issues.apache.org/jira/browse/KAFKA-13559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
frankshi updated KAFKA-13559:
-
Attachment: image-2021-12-21-14-44-56-689.png
> The broker's ProduceResponse may be delayed for 300ms
>
[
https://issues.apache.org/jira/browse/KAFKA-13559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
frankshi updated KAFKA-13559:
-
Attachment: image-2021-12-21-14-45-22-716.png
> The broker's ProduceResponse may be delayed for 300ms
>
[
https://issues.apache.org/jira/browse/KAFKA-13559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
frankshi updated KAFKA-13559:
-
Description:
Hi team:
We have found the value in the source code
[here|https://github.com/apache/kafka
[
https://issues.apache.org/jira/browse/KAFKA-13544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463021#comment-17463021
]
Andrei Lakhmanets commented on KAFKA-13544:
---
Hello [~joecqupt] , [~junrao]
T
[
https://issues.apache.org/jira/browse/KAFKA-13559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
frankshi updated KAFKA-13559:
-
Description:
Hi team:
We have found the value in the source code
[here|https://github.com/apache/kafka
[
https://issues.apache.org/jira/browse/KAFKA-13559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
frankshi updated KAFKA-13559:
-
Description:
Hi team:
We have found the value in the source code
[here|https://github.com/apache/kafka
52 matches
Mail list logo
