[jira] [Assigned] (KAFKA-13985) MirrorSourceTask commitRecord throws NPE if SMT is filtering out source record

[ https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rens Groothuijsen reassigned KAFKA-13985: - Assignee: Rens Groothuijsen > MirrorSourceTask commitRecord throws NPE if SMT

[jira] [Commented] (KAFKA-14081) Cannot get my MetricsReporter implementation to receive meaningful metrics

[ https://issues.apache.org/jira/browse/KAFKA-14081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577677#comment-17577677 ] Rens Groothuijsen commented on KAFKA-14081: --- I had a look at the source code, and it does

[jira] [Commented] (KAFKA-13796) MM2 - Topics Exclude/Blacklist not working

[ https://issues.apache.org/jira/browse/KAFKA-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17570518#comment-17570518 ] Rens Groothuijsen commented on KAFKA-13796: --- >From what I can see, adding quote marks around

[jira] [Commented] (KAFKA-5666) Need feedback to user if consumption fails due to offsets.topic.replication.factor=3

[ https://issues.apache.org/jira/browse/KAFKA-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404267#comment-17404267 ] Rens Groothuijsen commented on KAFKA-5666: -- [~ll1124278064] No, I'm no longer working on this

[jira] [Commented] (KAFKA-10417) suppress() with cogroup() throws ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211318#comment-17211318 ] Rens Groothuijsen commented on KAFKA-10417: --- [~ableegoldman] I would, but I'm not familiar

[jira] [Commented] (KAFKA-10417) suppress() with cogroup() throws ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187322#comment-17187322 ] Rens Groothuijsen commented on KAFKA-10417: --- A cogrouped stream creates a KTable with

[jira] [Commented] (KAFKA-10363) Broker try to connect to a new cluster when there are changes in zookeeper.connect properties

[ https://issues.apache.org/jira/browse/KAFKA-10363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178634#comment-17178634 ] Rens Groothuijsen commented on KAFKA-10363: --- One possible workaround is to update the broker's

[jira] [Assigned] (KAFKA-10224) The license term about jersey is not correct

[ https://issues.apache.org/jira/browse/KAFKA-10224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rens Groothuijsen reassigned KAFKA-10224: - Assignee: Rens Groothuijsen > The license term about jersey is not correct >

[jira] [Commented] (KAFKA-10159) MirrorSourceConnector don`t work on connect-distributed.sh

[ https://issues.apache.org/jira/browse/KAFKA-10159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165362#comment-17165362 ] Rens Groothuijsen commented on KAFKA-10159: --- [~ryannedolan] From what I can see,

[jira] [Assigned] (KAFKA-9716) Values of compression-rate and compression-rate-avg are misleading

[ https://issues.apache.org/jira/browse/KAFKA-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rens Groothuijsen reassigned KAFKA-9716: Assignee: Rens Groothuijsen > Values of compression-rate and compression-rate-avg

[jira] [Commented] (KAFKA-9968) Newly subscribed topic not present in metadata request

[ https://issues.apache.org/jira/browse/KAFKA-9968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105860#comment-17105860 ] Rens Groothuijsen commented on KAFKA-9968: -- [~cmanhin] I personally wouldn't consider this

[jira] [Commented] (KAFKA-9968) Newly subscribed topic not present in metadata request

[ https://issues.apache.org/jira/browse/KAFKA-9968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105792#comment-17105792 ] Rens Groothuijsen commented on KAFKA-9968: -- [~cmanhin] Thanks for the test case! From what I can

[jira] [Commented] (KAFKA-9603) Number of open files keeps increasing in Streams application

[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097996#comment-17097996 ] Rens Groothuijsen commented on KAFKA-9603: -- [~biljazovic] It does indeed appear to affect

[jira] [Comment Edited] (KAFKA-9745) Attribute is missed in kafka mirror maker metrics

[ https://issues.apache.org/jira/browse/KAFKA-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095694#comment-17095694 ] Rens Groothuijsen edited comment on KAFKA-9745 at 4/29/20, 4:57 PM:

[jira] [Commented] (KAFKA-9745) Attribute is missed in kafka mirror maker metrics

[ https://issues.apache.org/jira/browse/KAFKA-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095694#comment-17095694 ] Rens Groothuijsen commented on KAFKA-9745: -- [~krasnovnikita] From what I can see in the code, in

[jira] [Assigned] (KAFKA-9745) Attribute is missed in kafka mirror maker metrics

[ https://issues.apache.org/jira/browse/KAFKA-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rens Groothuijsen reassigned KAFKA-9745: Assignee: (was: Rens Groothuijsen) > Attribute is missed in kafka mirror

[jira] [Assigned] (KAFKA-9745) Attribute is missed in kafka mirror maker metrics

[ https://issues.apache.org/jira/browse/KAFKA-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rens Groothuijsen reassigned KAFKA-9745: Assignee: Rens Groothuijsen > Attribute is missed in kafka mirror maker metrics >

[jira] [Commented] (KAFKA-9438) Issue with mm2 active/active replication

[ https://issues.apache.org/jira/browse/KAFKA-9438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076672#comment-17076672 ] Rens Groothuijsen commented on KAFKA-9438: -- [~romanius11] Tried to replicate this issue, though

[jira] [Commented] (KAFKA-8809) Infinite retry if secure cluster tried to be reached from non-secure consumer

[ https://issues.apache.org/jira/browse/KAFKA-8809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17075890#comment-17075890 ] Rens Groothuijsen commented on KAFKA-8809: -- [~gsomogyi] I assume you're using the Java API? In

[jira] [Commented] (KAFKA-9482) mirror maker 2.0 doesn't replicates (create topic) created automatically by producing messages

[ https://issues.apache.org/jira/browse/KAFKA-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074132#comment-17074132 ] Rens Groothuijsen commented on KAFKA-9482: -- [~grinfeld] It works for me. The default source

[jira] [Commented] (KAFKA-9547) Kafka transaction - skip one offset when the application stops and be started again

[ https://issues.apache.org/jira/browse/KAFKA-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072917#comment-17072917 ] Rens Groothuijsen commented on KAFKA-9547: -- [~cheatmenot] As far as I know this is the expected

[jira] [Commented] (KAFKA-8293) Messages undelivered when small quotas applied

[ https://issues.apache.org/jira/browse/KAFKA-8293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852160#comment-16852160 ] Rens Groothuijsen commented on KAFKA-8293: -- I haven't been able to replicate this issue with a

[jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rens Groothuijsen reassigned KAFKA-2939: Assignee: (was: Rens Groothuijsen) > Make AbstractConfig.logUnused() tunable

[jira] [Comment Edited] (KAFKA-8297) Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics

[ https://issues.apache.org/jira/browse/KAFKA-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848480#comment-16848480 ] Rens Groothuijsen edited comment on KAFKA-8297 at 5/26/19 4:42 PM: ---

[jira] [Comment Edited] (KAFKA-8297) Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics

[ https://issues.apache.org/jira/browse/KAFKA-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848480#comment-16848480 ] Rens Groothuijsen edited comment on KAFKA-8297 at 5/26/19 4:42 PM: ---

[jira] [Commented] (KAFKA-8297) Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics

[ https://issues.apache.org/jira/browse/KAFKA-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848480#comment-16848480 ] Rens Groothuijsen commented on KAFKA-8297: -- Would it break the existing interface to only expose

[jira] [Commented] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848414#comment-16848414 ] Rens Groothuijsen commented on KAFKA-2939: -- Took a shot at implementing the boolean idea, though

[jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rens Groothuijsen reassigned KAFKA-2939: Assignee: Rens Groothuijsen > Make AbstractConfig.logUnused() tunable for clients

[jira] [Commented] (KAFKA-5666) Need feedback to user if consumption fails due to offsets.topic.replication.factor=3

[ https://issues.apache.org/jira/browse/KAFKA-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833459#comment-16833459 ] Rens Groothuijsen commented on KAFKA-5666: -- [~apurva] [~yevabyzek] Checking in the console

[jira] [Commented] (KAFKA-5666) Need feedback to user if consumption fails due to offsets.topic.replication.factor=3

[ https://issues.apache.org/jira/browse/KAFKA-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16828030#comment-16828030 ] Rens Groothuijsen commented on KAFKA-5666: -- Hi, I'm fairly new to Kafka. Can I pick up this