guozhangwang commented on pull request #10232:
URL: https://github.com/apache/kafka/pull/10232#issuecomment-791891198
We may reset generationa and request rejoin in two different places: 1) in
join/sync-group handler, and 2) in joinGroupIfNeeded, when the future is
received. The principle
guozhangwang commented on a change in pull request #10232:
URL: https://github.com/apache/kafka/pull/10232#discussion_r588847540
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -802,8 +801,10 @@ public void handle(
[
https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-12381:
Fix Version/s: 2.8.0
> Incompatible change in verifiable_producer.log in 2.8
> ---
[
https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-12381.
-
Resolution: Fixed
> Incompatible change in verifiable_producer.log in 2.8
>
guozhangwang commented on a change in pull request #10232:
URL: https://github.com/apache/kafka/pull/10232#discussion_r588842618
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -775,8 +776,6 @@ public void handle(S
ijuma opened a new pull request #10273:
URL: https://github.com/apache/kafka/pull/10273
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
abbccdda commented on pull request #10240:
URL: https://github.com/apache/kafka/pull/10240#issuecomment-791799082
Cherry-picked to 2.8
This is an automated message from the Apache Git Service.
To respond to the message, pleas
abbccdda merged pull request #10240:
URL: https://github.com/apache/kafka/pull/10240
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
abbccdda commented on pull request #10240:
URL: https://github.com/apache/kafka/pull/10240#issuecomment-791798044
System test pass:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4419/ and
only flaky tests are failing, merging
--
[
https://issues.apache.org/jira/browse/KAFKA-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12347.
--
> Improve Kafka Streams ability to track progress
> --
[
https://issues.apache.org/jira/browse/KAFKA-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-9349:
--
Assignee: (was: Jason Gustafson)
> Investigate new member timeout for dynamic v4 J
[
https://issues.apache.org/jira/browse/KAFKA-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296367#comment-17296367
]
Ismael Juma commented on KAFKA-12435:
-
cc [~mjsax] [~vvcephei]
> Several streams-te
[
https://issues.apache.org/jira/browse/KAFKA-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296366#comment-17296366
]
Ismael Juma commented on KAFKA-12435:
-
If you run `aggregatedJavadoc` with Java 8, y
Ismael Juma created KAFKA-12435:
---
Summary: Several streams-test-utils classes missing from javadoc
Key: KAFKA-12435
URL: https://issues.apache.org/jira/browse/KAFKA-12435
Project: Kafka
Issue T
[
https://issues.apache.org/jira/browse/KAFKA-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-12435:
Description:
!image-2021-03-05-14-22-45-891.png!
Only 3 of them show up currently ^. Source:
htt
ijuma opened a new pull request #10272:
URL: https://github.com/apache/kafka/pull/10272
- Use consistent options for `javadoc` and `aggregatedJavadoc`
- `aggregatedJavadoc` depends on `compileJava`
- `connect-api` inherits `options.links`
- `streams` and `streams-test-utils` javadoc
Jason Gustafson created KAFKA-12434:
---
Summary: Admin API for DescribeProducers
Key: KAFKA-12434
URL: https://issues.apache.org/jira/browse/KAFKA-12434
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-12432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-12432:
-
Summary: Fix AdminClient timeout handling in the presence of badly behaved
brokers (was: AdminC
abbccdda merged pull request #10211:
URL: https://github.com/apache/kafka/pull/10211
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
hachikuji commented on a change in pull request #10220:
URL: https://github.com/apache/kafka/pull/10220#discussion_r588522951
##
File path: core/src/test/java/kafka/test/junit/ClusterTestExtensions.java
##
@@ -199,12 +209,25 @@ private void processClusterTest(ClusterTest annot,
Jason Gustafson created KAFKA-12433:
---
Summary: Controller should create topic config records after topic
record
Key: KAFKA-12433
URL: https://issues.apache.org/jira/browse/KAFKA-12433
Project: Kafka
hachikuji commented on a change in pull request #10252:
URL: https://github.com/apache/kafka/pull/10252#discussion_r588524835
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala
##
@@ -142,28 +145,19 @@ class BrokerMetadataListener(brokerId: In
hachikuji commented on a change in pull request #10240:
URL: https://github.com/apache/kafka/pull/10240#discussion_r588513624
##
File path:
core/src/test/scala/unit/kafka/server/AutoTopicCreationManagerTest.scala
##
@@ -146,29 +146,118 @@ class AutoTopicCreationManagerTest {
Colin McCabe created KAFKA-12432:
Summary: AdminClient will not honor connection setup or request
timeouts in some cases
Key: KAFKA-12432
URL: https://issues.apache.org/jira/browse/KAFKA-12432
Project
satishd edited a comment on pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#issuecomment-791545987
@junrao: This is built on top of https://github.com/apache/kafka/pull/10218.
This is an automated messag
satishd commented on pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#issuecomment-791545987
@junrao
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
satishd opened a new pull request #10271:
URL: https://github.com/apache/kafka/pull/10271
KAFKA-12429: Added serdes for the default implementation of RLMM based on
an internal topic as storage. This topic will receive events of
RemoteLogSegmentMetadata, RemoteLogSegmentUpdate, and
Remote
ijuma commented on pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#issuecomment-791487213
Thanks for the PR. Can you check the perf impact of these changes?
This is an automated message from the Apache Gi
[
https://issues.apache.org/jira/browse/KAFKA-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reopened KAFKA-12347:
> Improve Kafka Streams ability to track progress
> --
mimaison commented on a change in pull request #9549:
URL: https://github.com/apache/kafka/pull/9549#discussion_r588262888
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/tools/TransformationDoc.java
##
@@ -18,11 +18,15 @@
import org.apache.kafka.common
rajinisivaram commented on a change in pull request #10267:
URL: https://github.com/apache/kafka/pull/10267#discussion_r588308473
##
File path: clients/src/main/java/org/apache/kafka/common/network/Selector.java
##
@@ -517,7 +517,7 @@ void pollSelectionKeys(Set selectionKeys,
rajinisivaram commented on pull request #10267:
URL: https://github.com/apache/kafka/pull/10267#issuecomment-791420001
@splett2 Thanks for the PR. I think it would be better to store channels in
`keysWithBufferedReads` only when the channel is not explicitly muted since we
care about this
[
https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Yurchenko reassigned KAFKA-12430:
--
Assignee: Ivan Yurchenko
> emit.heartbeats.enabled = false should disable heartbeats
omkreddy merged pull request #10270:
URL: https://github.com/apache/kafka/pull/10270
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
mimaison commented on a change in pull request #10192:
URL: https://github.com/apache/kafka/pull/10192#discussion_r588238922
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceTaskTest.java
##
@@ -86,4 +96,66 @@ public void testZeroOffsetSyn
pzygielo commented on pull request #8211:
URL: https://github.com/apache/kafka/pull/8211#issuecomment-791330792
Now it has [separate issue
(KAFKA-10775)](https://issues.apache.org/jira/browse/KAFKA-10775). What process
shall be followed to have it corrected?
-
[
https://issues.apache.org/jira/browse/KAFKA-12431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Sinoros-Szabo updated KAFKA-12431:
Attachment: fetch-on-2.6.1.png
fetch-on-2.4.1.png
> Fetch Request/
Peter Sinoros-Szabo created KAFKA-12431:
---
Summary: Fetch Request/Response without Topic information
Key: KAFKA-12431
URL: https://issues.apache.org/jira/browse/KAFKA-12431
Project: Kafka
dpoldrugo edited a comment on pull request #10059:
URL: https://github.com/apache/kafka/pull/10059#issuecomment-791291261
@omkreddy well for as at Infobip it caused an incident which basically
blocked all kafka traffic, just because of some clients didn't have PTR records
and thus reverse
dpoldrugo commented on pull request #10059:
URL: https://github.com/apache/kafka/pull/10059#issuecomment-791291261
@omkreddy well for as at Infobip it caused an incident which basically
blocked all kafka traffic, just because of some clients didn't have PTR records
and thus reverse dns blo
omkreddy opened a new pull request #10270:
URL: https://github.com/apache/kafka/pull/10270
We are logging CONNECTIONS_MAX_REAUTH_MS at debug level for each mechanism.
This is spammy when we enable debug logs for SaslServerAuthenticator. Updating
the log level to trace level.
### Com
Ivan Yurchenko created KAFKA-12430:
--
Summary: emit.heartbeats.enabled = false should disable heartbeats
topic creation
Key: KAFKA-12430
URL: https://issues.apache.org/jira/browse/KAFKA-12430
Project:
chia7712 commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588138822
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,
.s
[
https://issues.apache.org/jira/browse/KAFKA-10526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295880#comment-17295880
]
Sagar Rao commented on KAFKA-10526:
---
hey [~hachikuji] sorry for bugging again on this
Iskuskov commented on pull request #9541:
URL: https://github.com/apache/kafka/pull/9541#issuecomment-791263135
@kkonstantine, could you take a look at this please?
This is an automated message from the Apache Git Service.
To
45 matches
Mail list logo