[
https://issues.apache.org/jira/browse/KAFKA-14366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630855#comment-17630855
]
Chetan commented on KAFKA-14366:
Hi [~pnee] I will detail the steps to recreate the scen
dajac commented on code in PR #12783:
URL: https://github.com/apache/kafka/pull/12783#discussion_r1017672302
##
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala:
##
@@ -135,6 +151,13 @@ class ReplicaFetcherThread(name: String,
logAppendInfo
}
+ private def
cadonna commented on code in PR #12835:
URL: https://github.com/apache/kafka/pull/12835#discussion_r1017658640
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java:
##
@@ -175,14 +175,14 @@ void commitOffsetsOrTransaction(final Map corruptedTas
cadonna commented on code in PR #12795:
URL: https://github.com/apache/kafka/pull/12795#discussion_r1017702122
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -115,6 +117,7 @@ public void run() {
private void runOn
dajac commented on code in PR #12748:
URL: https://github.com/apache/kafka/pull/12748#discussion_r1017718371
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java:
##
@@ -1229,4 +1247,23 @@ private boolean in(Set pairs) {
r
dajac commented on code in PR #12748:
URL: https://github.com/apache/kafka/pull/12748#discussion_r1017743686
##
clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java:
##
@@ -78,6 +80,26 @@ public void testDecodeGeneration() {
assertF
[
https://issues.apache.org/jira/browse/KAFKA-14298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ramakrishna resolved KAFKA-14298.
-
Resolution: Not A Problem
> Getting null pointer exception
> --
>
>
clolov commented on PR #12809:
URL: https://github.com/apache/kafka/pull/12809#issuecomment-1308588950
Hopefully the newest two commits address your comments @ableegoldman, if not
just let me know :)
--
This is an automated message from the Apache Git Service.
To respond to the message, p
lucasbru commented on code in PR #12795:
URL: https://github.com/apache/kafka/pull/12795#discussion_r1017943192
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -277,6 +294,9 @@ private void addTask(final Task task) {
cadonna commented on code in PR #12809:
URL: https://github.com/apache/kafka/pull/12809#discussion_r1017938045
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java:
##
@@ -610,15 +617,21 @@ public Acces
clolov commented on code in PR #12836:
URL: https://github.com/apache/kafka/pull/12836#discussion_r1018025744
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java:
##
@@ -219,26 +219,20 @@ public void send(final String topic,
clolov commented on code in PR #12836:
URL: https://github.com/apache/kafka/pull/12836#discussion_r1018037337
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java:
##
@@ -219,26 +219,20 @@ public void send(final String topic,
shekhar-rajak commented on code in PR #12735:
URL: https://github.com/apache/kafka/pull/12735#discussion_r1018066045
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java:
##
@@ -374,30 +350,40 @@ public void testErrorHandlingInSourceTasks(
shekhar-rajak commented on PR #12739:
URL: https://github.com/apache/kafka/pull/12739#issuecomment-1308922420
Hi @divijvaidya Please review once.
--
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
nicktelford commented on code in PR #12393:
URL: https://github.com/apache/kafka/pull/12393#discussion_r1018125919
##
streams/src/main/java/org/apache/kafka/streams/state/internals/TransactionalKeyValueStore.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Software Found
Ron Dagostino created KAFKA-14371:
-
Summary: quorum-state file contains empty/unused clusterId field
Key: KAFKA-14371
URL: https://issues.apache.org/jira/browse/KAFKA-14371
Project: Kafka
Iss
cmccabe commented on code in PR #12833:
URL: https://github.com/apache/kafka/pull/12833#discussion_r1018269186
##
core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala:
##
@@ -398,8 +398,11 @@ class BrokerMetadataListener(
build()
try {
jeffkbkim commented on code in PR #12783:
URL: https://github.com/apache/kafka/pull/12783#discussion_r1018280351
##
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala:
##
@@ -135,6 +151,13 @@ class ReplicaFetcherThread(name: String,
logAppendInfo
}
+ private
cmccabe commented on PR #12833:
URL: https://github.com/apache/kafka/pull/12833#issuecomment-1309197714
It's a bit confusing to have two variations of close(), so let's just have
freeze() and then close().
--
This is an automated message from the Apache Git Service.
To respond to the mess
pprovenzano opened a new pull request, #12838:
URL: https://github.com/apache/kafka/pull/12838
Changes needed to get SaslPlainSslEndToEndAuthorizationTest to pass in
KRAFT
Removed direct calls in EndToEndAuthorizationTest to zookeeper and
instead
use the superuser prin
cmccabe commented on code in PR #12838:
URL: https://github.com/apache/kafka/pull/12838#discussion_r1018304863
##
core/src/test/scala/integration/kafka/api/SaslPlainSslEndToEndAuthorizationTest.scala:
##
@@ -147,10 +157,11 @@ class SaslPlainSslEndToEndAuthorizationTest extends
cmccabe commented on PR #12838:
URL: https://github.com/apache/kafka/pull/12838#issuecomment-1309232726
Hi @pprovenzano . Thanks for the PR.
Before I can review this I'd like to understand the strategy here. Do you
want to leave the `CONTROLLER` endpoint as `PLAINTEXT`? Or will it als
pprovenzano commented on code in PR #12838:
URL: https://github.com/apache/kafka/pull/12838#discussion_r1018372760
##
core/src/test/scala/integration/kafka/api/SaslPlainSslEndToEndAuthorizationTest.scala:
##
@@ -147,10 +157,11 @@ class SaslPlainSslEndToEndAuthorizationTest exten
[
https://issues.apache.org/jira/browse/KAFKA-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631265#comment-17631265
]
Mikael commented on KAFKA-14362:
I would have thought that an orderly rebalance wouldn't
pprovenzano commented on PR #12838:
URL: https://github.com/apache/kafka/pull/12838#issuecomment-1309335998
The main focus of these tests is on brokers doing authorization and
validating that the client gets (or does not get) access to the topic for
various ACLs. So I think that we should n
[
https://issues.apache.org/jira/browse/KAFKA-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikael updated KAFKA-14362:
---
Description:
Trigger scenario:
Two Kafka client application instances on separate EC2 instances with one
c
Jeff Kim created KAFKA-14372:
Summary: RackAwareReplicaSelector should choose a replica from the
isr
Key: KAFKA-14372
URL: https://issues.apache.org/jira/browse/KAFKA-14372
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-14372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-14372:
-
Description: The default replica selector chooses a replica solely on
whether the broker.rack matches th
Daniel Scanteianu created KAFKA-14373:
-
Summary: provide builders for producer/consumer
Key: KAFKA-14373
URL: https://issues.apache.org/jira/browse/KAFKA-14373
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-14373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Scanteianu updated KAFKA-14373:
--
Description:
creating a producer/consumer involves looking up the consts for kafka
co
[
https://issues.apache.org/jira/browse/KAFKA-14373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631334#comment-17631334
]
Daniel Scanteianu commented on KAFKA-14373:
---
i am happy to code this
> provid
[
https://issues.apache.org/jira/browse/KAFKA-14373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Scanteianu updated KAFKA-14373:
--
Description:
creating a producer/consumer involves looking up the consts for kafka
co
gharris1727 opened a new pull request, #12839:
URL: https://github.com/apache/kafka/pull/12839
Signed-off-by: Greg Harris
The static lookupKafkaClusterId method is mocked out in several tests, when
it is now an implementation detail of the WorkerConfig. This change both
migrates sta
cmccabe commented on PR #12838:
URL: https://github.com/apache/kafka/pull/12838#issuecomment-1309560732
Rather than putting the `@Timeout(60)` on each test case, I'd suggest
putting it on the test class itself, so that it applies to each test.
Actually, can you split out a separate PR
[
https://issues.apache.org/jira/browse/KAFKA-13964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13964.
-
Resolution: Duplicate
Thanks for reporting the issue. This will be resolved by
https://
[
https://issues.apache.org/jira/browse/KAFKA-14360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-14360:
--
Assignee: Shay Lin (was: A. Sophie Blee-Goldman)
> Documentation: St
pratimsc opened a new pull request, #12840:
URL: https://github.com/apache/kafka/pull/12840
Updated the Jackson libraries for mitigating CVEs fixed under release
`2.13.4` , ref: https://github.com/FasterXML/jackson/wiki/Jackson-Release-2.13.4
--
This is an automated message from the A
ableegoldman commented on code in PR #12835:
URL: https://github.com/apache/kafka/pull/12835#discussion_r1018583064
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java:
##
@@ -175,14 +175,14 @@ void commitOffsetsOrTransaction(final Map corrupt
[
https://issues.apache.org/jira/browse/KAFKA-13891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631387#comment-17631387
]
Luke Chen commented on KAFKA-13891:
---
I'm also very busy these days. [~aiquestion] , if
ableegoldman commented on code in PR #12835:
URL: https://github.com/apache/kafka/pull/12835#discussion_r1018584439
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java:
##
@@ -191,43 +191,49 @@ void commitOffsetsOrTransaction(final Map allOffs
showuon commented on PR #12840:
URL: https://github.com/apache/kafka/pull/12840#issuecomment-1309672615
Should we also bump the `jackson-databind` to 2.13.4.2 for CVE-2022-42003?
ref: https://github.com/spring-projects/spring-boot/issues/32583
--
This is an automated message from t
[
https://issues.apache.org/jira/browse/KAFKA-14373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631396#comment-17631396
]
Luke Chen commented on KAFKA-14373:
---
[~scanteianu] , please remember to propose a
[KI
[
https://issues.apache.org/jira/browse/KAFKA-14373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631498#comment-17631498
]
Daniel Scanteianu commented on KAFKA-14373:
---
Thanks, following the process in
43 matches
Mail list logo
