showuon commented on pull request #9261:
URL: https://github.com/apache/kafka/pull/9261#issuecomment-688650169
@vvcephei , could you help review? Thanks.
This is an automated message from the Apache Git Service.
To respond to
showuon opened a new pull request #9261:
URL: https://github.com/apache/kafka/pull/9261
Currently, the source reference are all pointing to the 1.0 version codes,
which is obviously wrong. Update to the current `dotVersion`. (ref:
https://github.com/apache/kafka/blob/trunk/docs/streams/dev
showuon commented on pull request #9260:
URL: https://github.com/apache/kafka/pull/9260#issuecomment-688646476
@ijuma , please help review. Thanks.
This is an automated message from the Apache Git Service.
To respond to the m
showuon opened a new pull request #9260:
URL: https://github.com/apache/kafka/pull/9260
Now, default should be 2.13.x, not 2.12.x. Update it.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build st
junrao commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r484638938
##
File path: core/src/main/scala/kafka/server/DelayedOperation.scala
##
@@ -221,36 +205,34 @@ final class DelayedOperationPurgatory[T <:
DelayedOperation](
[
https://issues.apache.org/jira/browse/KAFKA-10375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satyawati Tripathi reassigned KAFKA-10375:
--
Assignee: Satyawati Tripathi
> Restore consumer fails with SSL handshake fail
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r484622290
##
File path:
core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala
##
@@ -202,9 +201,8 @@ object AbstractCoordinatorConcurr
junrao commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r484606811
##
File path: core/src/main/scala/kafka/server/DelayedOperation.scala
##
@@ -228,29 +212,33 @@ final class DelayedOperationPurgatory[T <:
DelayedOperation](
gwenshap commented on a change in pull request #9249:
URL: https://github.com/apache/kafka/pull/9249#discussion_r484602439
##
File path: clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
##
@@ -324,11 +332,35 @@ public synchronized boolean add(final MetricName
chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-688481474
@junrao Thanks for all reviews again 👍
> Do you plan to remove some of the unused methods in DelayedOperations in
Partition?
my bad. I forgot this request :(
Swayam Raina created KAFKA-10467:
Summary: kafka-topic --describe fails for topic created by
"produce"
Key: KAFKA-10467
URL: https://issues.apache.org/jira/browse/KAFKA-10467
Project: Kafka
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r484543835
##
File path: core/src/main/scala/kafka/server/DelayedOperation.scala
##
@@ -231,26 +214,27 @@ final class DelayedOperationPurgatory[T <:
DelayedOperation
junrao commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r484521628
##
File path: core/src/main/scala/kafka/server/DelayedOperation.scala
##
@@ -228,29 +211,37 @@ final class DelayedOperationPurgatory[T <:
DelayedOperation](
[
https://issues.apache.org/jira/browse/KAFKA-10466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191782#comment-17191782
]
Daeho Kim commented on KAFKA-10466:
---
How can I assign to me?
> Add Regex option for r
[
https://issues.apache.org/jira/browse/KAFKA-10465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
M. Manna updated KAFKA-10465:
-
Attachment: ConsumerTestApp.java
> Potential Bug/Doc update in Transactional Producer and Isolation Leve
[
https://issues.apache.org/jira/browse/KAFKA-10465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
M. Manna updated KAFKA-10465:
-
Attachment: (was: ConsumerTestApp.java)
> Potential Bug/Doc update in Transactional Producer and Iso
daehokimm opened a new pull request #9259:
URL: https://github.com/apache/kafka/pull/9259
*Requires KIP - do not merge*
### Goal
Allow regex for MaskField SMT to replacement
### Details
The existing `org.apache.kafka.connect.transforms.MaskField` SMT allow to
mas
Daeho Kim created KAFKA-10466:
-
Summary: Add Regex option for replacement on MaskField SMT
Key: KAFKA-10466
URL: https://issues.apache.org/jira/browse/KAFKA-10466
Project: Kafka
Issue Type: Impr
cadonna commented on pull request #9258:
URL: https://github.com/apache/kafka/pull/9258#issuecomment-688397112
Call for review: @vvcephei @guozhangwang @mjsax @ableegoldman @wcarlson5
@abbccdda
This is an automated message
cadonna opened a new pull request #9258:
URL: https://github.com/apache/kafka/pull/9258
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade not
[
https://issues.apache.org/jira/browse/KAFKA-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-9924:
-
Fix Version/s: 2.7.0
> Add RocksDB Memory Consumption to RocksDB Metrics
> -
[
https://issues.apache.org/jira/browse/KAFKA-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-9924.
--
Resolution: Fixed
> Add RocksDB Memory Consumption to RocksDB Metrics
> --
[
https://issues.apache.org/jira/browse/KAFKA-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10355:
--
Fix Version/s: 2.7.0
> Handle accidental deletion of source-topics as exceptional failure
> --
[
https://issues.apache.org/jira/browse/KAFKA-10465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
M. Manna updated KAFKA-10465:
-
Priority: Critical (was: Major)
> Potential Bug/Doc update in Transactional Producer and Isolation Leve
[
https://issues.apache.org/jira/browse/KAFKA-10465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191682#comment-17191682
]
M. Manna commented on KAFKA-10465:
--
I have sent an email to users DL - it would be appr
M. Manna created KAFKA-10465:
Summary: Potential Bug/Doc update in Transactional Producer and
Isolation Level
Key: KAFKA-10465
URL: https://issues.apache.org/jira/browse/KAFKA-10465
Project: Kafka
Ismail Mekni created KAFKA-10464:
Summary: Kafka client throws IndexOutOfBoundsException when
polling messages
Key: KAFKA-10464
URL: https://issues.apache.org/jira/browse/KAFKA-10464
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass reassigned KAFKA-9413:
--
Assignee: Viktor Somogyi-Vass
> Add audit of Kafka cluster
> -
chia7712 opened a new pull request #9257:
URL: https://github.com/apache/kafka/pull/9257
issue: https://issues.apache.org/jira/browse/KAFKA-10463
the default image of Dockerfile is ```openjdk:8``` and it pre-installed git
so it is fine that necessary utilities does not include git. H
Chia-Ping Tsai created KAFKA-10463:
--
Summary: the necessary utilities in Dockerfile should include git
Key: KAFKA-10463
URL: https://issues.apache.org/jira/browse/KAFKA-10463
Project: Kafka
chia7712 commented on pull request #9182:
URL: https://github.com/apache/kafka/pull/9182#issuecomment-688132941
```
Build / JDK 8 /
org.apache.kafka.connect.mirror.MirrorConnectorsIntegrationTest.testReplication
```
unrelated error
40 matches
Mail list logo
