[jira] [Commented] (KAFKA-6989) Support Async Processing in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551559#comment-17551559 ] Antony Stubbs commented on KAFKA-6989: -- FYI you can utilise Confluent's Parallel Con

[jira] [Commented] (KAFKA-12540) Sub-key support to avoid unnecessary rekey operations with new key is a compound key of the original key + sub-field

[ https://issues.apache.org/jira/browse/KAFKA-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308320#comment-17308320 ] Antony Stubbs commented on KAFKA-12540: --- Yes Sophie, I think having the links is g

[jira] [Commented] (KAFKA-12540) Sub-key support to avoid unnecessary rekey operations with new key is a compound key of the original key + sub-field

[ https://issues.apache.org/jira/browse/KAFKA-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308091#comment-17308091 ] Antony Stubbs commented on KAFKA-12540: --- Ah yes! Totally - thanks! Now we have the

[jira] [Updated] (KAFKA-12540) Sub-key support to avoid unnecessary rekey operations with new key is a compound key of the original key + sub-field

[ https://issues.apache.org/jira/browse/KAFKA-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-12540: -- Description: If I am, for example, wanting to aggregate by an account, and by a metric, and t

[jira] [Updated] (KAFKA-12540) Sub-key support to avoid unnecessary rekey operations with new key is a compound key of the original key + sub-field

[ https://issues.apache.org/jira/browse/KAFKA-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-12540: -- Description: If I am, for example, wanting to aggregate by an account, and by a metric, and t

[jira] [Updated] (KAFKA-12540) Sub-key support to avoid unnecessary rekey operations with new key is a compound key of the original key + sub-field

[ https://issues.apache.org/jira/browse/KAFKA-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-12540: -- Description: If I am, for example, wanting to aggregate by an account, and by a metric, and t

[jira] [Created] (KAFKA-12540) Sub-key support to avoid unnecessary rekey operations with new key is a compound key of the original key + sub-field

Antony Stubbs created KAFKA-12540: - Summary: Sub-key support to avoid unnecessary rekey operations with new key is a compound key of the original key + sub-field Key: KAFKA-12540 URL: https://issues.apache.org/jir

[jira] [Updated] (KAFKA-10408) Calendar based windows

[ https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-10408: -- Description: A date based window, for example aggregate all payments made until each month da

[jira] [Created] (KAFKA-10408) Calendar based windows

Antony Stubbs created KAFKA-10408: - Summary: Calendar based windows Key: KAFKA-10408 URL: https://issues.apache.org/jira/browse/KAFKA-10408 Project: Kafka Issue Type: New Feature Co

[jira] [Created] (KAFKA-10382) MockProducer is not ThreadSafe, ideally it should be as the implementation it mocks is

Antony Stubbs created KAFKA-10382: - Summary: MockProducer is not ThreadSafe, ideally it should be as the implementation it mocks is Key: KAFKA-10382 URL: https://issues.apache.org/jira/browse/KAFKA-10382

[jira] [Commented] (KAFKA-6182) Automatic co-partitioning of topics via automatic intermediate topic with matching partitions

[ https://issues.apache.org/jira/browse/KAFKA-6182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110137#comment-17110137 ] Antony Stubbs commented on KAFKA-6182: -- Ah yes that makes sense. Assuming the except

[jira] [Comment Edited] (KAFKA-4748) Need a way to shutdown all workers in a Streams application at the same time

[ https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110133#comment-17110133 ] Antony Stubbs edited comment on KAFKA-4748 at 5/18/20, 10:47 AM: --

[jira] [Commented] (KAFKA-4748) Need a way to shutdown all workers in a Streams application at the same time

[ https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110133#comment-17110133 ] Antony Stubbs commented on KAFKA-4748: -- FYI [~mjsax], my intention for Kafka-6943 wa

[jira] [Updated] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-9259: - Description: The suppress() operator either inherits serdes from its upstream operator or falls

[jira] [Commented] (KAFKA-6621) Update Streams docs with details for UncaughtExceptionHandler

[ https://issues.apache.org/jira/browse/KAFKA-6621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005325#comment-17005325 ] Antony Stubbs commented on KAFKA-6621: -- related: https://issues.apache.org/jira/brow

[jira] [Commented] (KAFKA-9331) Add option to terminate application when StreamThread(s) die

[ https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005299#comment-17005299 ] Antony Stubbs commented on KAFKA-9331: -- FYI https://issues.apache.org/jira/browse/KA

[jira] [Updated] (KAFKA-8884) Improve streams errors on class cast exception in ProcessorsNodes

[ https://issues.apache.org/jira/browse/KAFKA-8884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8884: - Description: [https://github.com/apache/kafka/pull/7309]   If a processor causes a class cast e

[jira] [Updated] (KAFKA-8884) Improve streams errors on class cast exception in ProcessorsNodes

[ https://issues.apache.org/jira/browse/KAFKA-8884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8884: - Description: If a processor causes a class cast exception, atm you get a bit of a cryptic error

[jira] [Updated] (KAFKA-8884) Improve streams errors on class cast exception in ProcessorsNodes

[ https://issues.apache.org/jira/browse/KAFKA-8884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8884: - Description: If a processor causes a class cast exception, atm you get a bit of a cryptic error

[jira] [Updated] (KAFKA-8884) Improve streams errors on class cast exception in ProcessorsNodes

[ https://issues.apache.org/jira/browse/KAFKA-8884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8884: - Description: If a processor causes a class cast exception, atm you get a bit of a cryptic error

[jira] [Created] (KAFKA-8884) Improve streams errors on class cast exception in ProcessorsNodes

Antony Stubbs created KAFKA-8884: Summary: Improve streams errors on class cast exception in ProcessorsNodes Key: KAFKA-8884 URL: https://issues.apache.org/jira/browse/KAFKA-8884 Project: Kafka

[jira] [Commented] (KAFKA-5632) Message headers not supported by Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897938#comment-16897938 ] Antony Stubbs commented on KAFKA-5632: -- [~mjsax] [~guozhang] I think this should be

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897937#comment-16897937 ] Antony Stubbs commented on KAFKA-4125: -- Can we add 2.3 as an affected version? > Pr

[jira] [Updated] (KAFKA-8651) Add a #branch overload that takes a Map of predicate names to predicates

[ https://issues.apache.org/jira/browse/KAFKA-8651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8651: - Description: A map can be a more natural way to work with passing in predicates and extracting s

[jira] [Created] (KAFKA-8651) Add a #branch overload that takes a Map of predicate names to predicates

Antony Stubbs created KAFKA-8651: Summary: Add a #branch overload that takes a Map of predicate names to predicates Key: KAFKA-8651 URL: https://issues.apache.org/jira/browse/KAFKA-8651 Project: Kafka

[jira] [Updated] (KAFKA-8648) Console tools should fail fast if an unrecognised --property is passed in

[ https://issues.apache.org/jira/browse/KAFKA-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8648: - Description: Some people don't realise that the --property for the console producer and consumer

[jira] [Updated] (KAFKA-8647) Add consumer-props option to match producer-props for kafka-consumer-perf-test

[ https://issues.apache.org/jira/browse/KAFKA-8647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8647: - Description: kafka-consumer-perf-test is missing a consumer-props option like the producer perf

[jira] [Updated] (KAFKA-8648) Console tools should fail fast if an unrecognised --property is passed in

[ https://issues.apache.org/jira/browse/KAFKA-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8648: - Summary: Console tools should fail fast if an unrecognised --property is passed in (was: Console

[jira] [Updated] (KAFKA-8647) Add consumer-props option to match producer-props for kafka-consumer-perf-test

[ https://issues.apache.org/jira/browse/KAFKA-8647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8647: - Summary: Add consumer-props option to match producer-props for kafka-consumer-perf-test (was: Ad

[jira] [Created] (KAFKA-8648) Console tools should fail fast if an unrecognised option is passed in

Antony Stubbs created KAFKA-8648: Summary: Console tools should fail fast if an unrecognised option is passed in Key: KAFKA-8648 URL: https://issues.apache.org/jira/browse/KAFKA-8648 Project: Kafka

[jira] [Created] (KAFKA-8647) Add consumer-props option to match producer-props for console consumer

Antony Stubbs created KAFKA-8647: Summary: Add consumer-props option to match producer-props for console consumer Key: KAFKA-8647 URL: https://issues.apache.org/jira/browse/KAFKA-8647 Project: Kafka

[jira] [Created] (KAFKA-8572) Broker reports not leader partition as an error

Antony Stubbs created KAFKA-8572: Summary: Broker reports not leader partition as an error Key: KAFKA-8572 URL: https://issues.apache.org/jira/browse/KAFKA-8572 Project: Kafka Issue Type: Imp

[jira] [Commented] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16803600#comment-16803600 ] Antony Stubbs commented on KAFKA-6042: -- [~ijuma] this is marked as both affects and

[jira] [Commented] (KAFKA-4925) Add a configurable delay to the initial consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-4925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795212#comment-16795212 ] Antony Stubbs commented on KAFKA-4925: -- Relates to: KAFKA-7725 Add a delay for furth

[jira] [Commented] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-6686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787856#comment-16787856 ] Antony Stubbs commented on KAFKA-6686: -- Also relates to KAFKA-6646 because if you wa

[jira] [Commented] (KAFKA-7718) Allow customized header inheritance for stateful operators in DSL

[ https://issues.apache.org/jira/browse/KAFKA-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16774599#comment-16774599 ] Antony Stubbs commented on KAFKA-7718: -- The other question is - header access in DSL

[jira] [Created] (KAFKA-7731) JMX metrics for client connections: how many, what version, what language, source ip etc...

Antony Stubbs created KAFKA-7731: Summary: JMX metrics for client connections: how many, what version, what language, source ip etc... Key: KAFKA-7731 URL: https://issues.apache.org/jira/browse/KAFKA-7731

[jira] [Updated] (KAFKA-7731) JMX metrics from the broker for client connections: how many, what version, what language, source ip etc...

[ https://issues.apache.org/jira/browse/KAFKA-7731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-7731: - Summary: JMX metrics from the broker for client connections: how many, what version, what languag

[jira] [Created] (KAFKA-7725) Add a delay for further CG rebalances, beyond KIP-134 group.initial.rebalance.delay.ms

Antony Stubbs created KAFKA-7725: Summary: Add a delay for further CG rebalances, beyond KIP-134 group.initial.rebalance.delay.ms Key: KAFKA-7725 URL: https://issues.apache.org/jira/browse/KAFKA-7725

[jira] [Created] (KAFKA-7724) Docs for KIP-71 compact AND delete need correcting

Antony Stubbs created KAFKA-7724: Summary: Docs for KIP-71 compact AND delete need correcting Key: KAFKA-7724 URL: https://issues.apache.org/jira/browse/KAFKA-7724 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7458) Avoid enforced processing during bootstrap phase

[ https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16633951#comment-16633951 ] Antony Stubbs commented on KAFKA-7458: -- Related to KAFKA-4113 > Avoid enforced proc

[jira] [Commented] (KAFKA-6268) Tools should not swallow exceptions like resolving network names

[ https://issues.apache.org/jira/browse/KAFKA-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16627397#comment-16627397 ] Antony Stubbs commented on KAFKA-6268: -- If either a failed socket response happens o

[jira] [Commented] (KAFKA-7129) Dynamic default value for number of thread configuration

[ https://issues.apache.org/jira/browse/KAFKA-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531083#comment-16531083 ] Antony Stubbs commented on KAFKA-7129: -- One thing to be careful is of course detecti

[jira] [Commented] (KAFKA-6268) Tools should not swallow exceptions like resolving network names

[ https://issues.apache.org/jira/browse/KAFKA-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529801#comment-16529801 ] Antony Stubbs commented on KAFKA-6268: -- [~rsivaram] does this fix also cover securit

[jira] [Updated] (KAFKA-6268) Tools should not swallow exceptions like resolving network names

[ https://issues.apache.org/jira/browse/KAFKA-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6268: - Summary: Tools should not swallow exceptions like resolving network names (was: Tools should now

[jira] [Commented] (KAFKA-7035) Kafka Processor's init() method sometimes is not called

[ https://issues.apache.org/jira/browse/KAFKA-7035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511063#comment-16511063 ] Antony Stubbs commented on KAFKA-7035: -- Call your punctuate processor from the close

[jira] [Commented] (KAFKA-6743) ConsumerPerformance fails to consume all messages on topics with large number of partitions

[ https://issues.apache.org/jira/browse/KAFKA-6743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16493288#comment-16493288 ] Antony Stubbs commented on KAFKA-6743: -- Duplicate / relates to KAFKA-6225 > Consume

[jira] [Updated] (KAFKA-6943) Have option to shutdown KS cleanly if any threads crashes, or if all threads crash

[ https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6943: - Description: ATM users have to implement this themselves. Might be nice to have an option to conf

[jira] [Updated] (KAFKA-6943) Have option to shutdown KS cleanly if any threads crashes, or if all threads crash

[ https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6943: - Summary: Have option to shutdown KS cleanly if any threads crashes, or if all threads crash (was:

[jira] [Comment Edited] (KAFKA-6943) Have option to shutdown KS cleanly if any task crashes, or if all tasks crash

[ https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16490638#comment-16490638 ] Antony Stubbs edited comment on KAFKA-6943 at 5/25/18 12:23 PM:

[jira] [Commented] (KAFKA-6943) Have option to shutdown KS cleanly if any task crashes, or if all tasks crash

[ https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16490638#comment-16490638 ] Antony Stubbs commented on KAFKA-6943: -- Sorry, should have said thread, not task. For

[jira] [Created] (KAFKA-6943) Have option to shutdown KS cleanly if any task crashes, or if all tasks crash

Antony Stubbs created KAFKA-6943: Summary: Have option to shutdown KS cleanly if any task crashes, or if all tasks crash Key: KAFKA-6943 URL: https://issues.apache.org/jira/browse/KAFKA-6943 Project:

[jira] [Created] (KAFKA-6942) Connect connectors api doesn't show versions of connectors

Antony Stubbs created KAFKA-6942: Summary: Connect connectors api doesn't show versions of connectors Key: KAFKA-6942 URL: https://issues.apache.org/jira/browse/KAFKA-6942 Project: Kafka Issu

[jira] [Updated] (KAFKA-6910) Ability to specify a default state store type or factory

[ https://issues.apache.org/jira/browse/KAFKA-6910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6910: - Description: For large projects, it's a huge pain and not really practically at all to use a cust

[jira] [Created] (KAFKA-6910) Ability to specify a default state store type or factory

Antony Stubbs created KAFKA-6910: Summary: Ability to specify a default state store type or factory Key: KAFKA-6910 URL: https://issues.apache.org/jira/browse/KAFKA-6910 Project: Kafka Issue

[jira] [Commented] (KAFKA-5713) Improve kafka-acls options to understand strings with wildcards

[ https://issues.apache.org/jira/browse/KAFKA-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16454252#comment-16454252 ] Antony Stubbs commented on KAFKA-5713: -- [https://github.com/simplesteph/kafka-securit

[jira] [Commented] (KAFKA-6699) When one of two Kafka nodes are dead, streaming API cannot handle messaging

[ https://issues.apache.org/jira/browse/KAFKA-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409957#comment-16409957 ] Antony Stubbs commented on KAFKA-6699: -- Also, what is the replication factor for your

[jira] [Created] (KAFKA-6646) Add a GlobalKStream object type for stream event broadcast

Antony Stubbs created KAFKA-6646: Summary: Add a GlobalKStream object type for stream event broadcast Key: KAFKA-6646 URL: https://issues.apache.org/jira/browse/KAFKA-6646 Project: Kafka Issu

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362269#comment-16362269 ] Antony Stubbs commented on KAFKA-6555: -- This requires a KIP right? > Making state st

[jira] [Updated] (KAFKA-6542) Tables should trigger joins too, not just streams

[ https://issues.apache.org/jira/browse/KAFKA-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6542: - Description: At the moment it's quite possible to have a race condition when joining a stream wit

[jira] [Commented] (KAFKA-6543) Allow KTables to be bootstrapped at start up, like GKTables

[ https://issues.apache.org/jira/browse/KAFKA-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16356975#comment-16356975 ] Antony Stubbs commented on KAFKA-6543: -- Close - duplicate of KAFKA-4113 Allow KTable

[jira] [Updated] (KAFKA-6542) Tables should trigger joins too, not just streams

[ https://issues.apache.org/jira/browse/KAFKA-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6542: - Description: At the moment it's quite possible to have a race condition when joining a stream wit

[jira] [Updated] (KAFKA-6543) Allow KTables to be bootstrapped at start up, like GKTables

[ https://issues.apache.org/jira/browse/KAFKA-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6543: - Affects Version/s: 1.1.0 Description: In some uses cases, it's desirable to have KTables

[jira] [Created] (KAFKA-6543) Allow KTables to be bootstrapped at start up, like GKTables

Antony Stubbs created KAFKA-6543: Summary: Allow KTables to be bootstrapped at start up, like GKTables Key: KAFKA-6543 URL: https://issues.apache.org/jira/browse/KAFKA-6543 Project: Kafka Is

[jira] [Created] (KAFKA-6542) Tables should trigger joins too, not just streams

Antony Stubbs created KAFKA-6542: Summary: Tables should trigger joins too, not just streams Key: KAFKA-6542 URL: https://issues.apache.org/jira/browse/KAFKA-6542 Project: Kafka Issue Type: I

[jira] [Created] (KAFKA-6519) Change log level from ERROR to WARN for not leader for this partition exception

Antony Stubbs created KAFKA-6519: Summary: Change log level from ERROR to WARN for not leader for this partition exception Key: KAFKA-6519 URL: https://issues.apache.org/jira/browse/KAFKA-6519 Project

[jira] [Created] (KAFKA-6369) General wildcard support for ACL's in kafka

Antony Stubbs created KAFKA-6369: Summary: General wildcard support for ACL's in kafka Key: KAFKA-6369 URL: https://issues.apache.org/jira/browse/KAFKA-6369 Project: Kafka Issue Type: New Fea

[jira] [Updated] (KAFKA-6270) ProducerPerformance doesn't support setting sasl.jaas.config as a --producer-props

[ https://issues.apache.org/jira/browse/KAFKA-6270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6270: - Description: I seems the parser expects everything to strictly be key=value pairs, where as sasl.

[jira] [Updated] (KAFKA-6270) ProducerPerformance doesn't support setting sasl.jaas.config as a --producer-props

[ https://issues.apache.org/jira/browse/KAFKA-6270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6270: - Description: I seems the parser expects everything to strictly be key=value pairs, where as sasl.

[jira] [Updated] (KAFKA-6270) ProducerPerformance doesn't support setting sasl.jaas.config as a --producer-props

[ https://issues.apache.org/jira/browse/KAFKA-6270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6270: - Description: I seems the parser expects everything to strictly be key=value pairs, where as sasl.

[jira] [Created] (KAFKA-6270) ProducerPerformance doesn't support setting sasl.jaas.config as a --producer-props

Antony Stubbs created KAFKA-6270: Summary: ProducerPerformance doesn't support setting sasl.jaas.config as a --producer-props Key: KAFKA-6270 URL: https://issues.apache.org/jira/browse/KAFKA-6270 Proj

[jira] [Updated] (KAFKA-6235) Kafka should have a last resort retention setting for max disk used

[ https://issues.apache.org/jira/browse/KAFKA-6235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6235: - Summary: Kafka should have a last resort retention setting for max disk used (was: Kafka should h

[jira] [Updated] (KAFKA-6235) Kafka should have an emergency retention setting for max disk used

[ https://issues.apache.org/jira/browse/KAFKA-6235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6235: - Description: Kafka should have an emergency retention setting for max disk used to prevent the br

[jira] [Created] (KAFKA-6268) Tools should now swallow exceptions like resolving network names

Antony Stubbs created KAFKA-6268: Summary: Tools should now swallow exceptions like resolving network names Key: KAFKA-6268 URL: https://issues.apache.org/jira/browse/KAFKA-6268 Project: Kafka

[jira] [Created] (KAFKA-6265) GlobalKTable missing #queryableStoreName()

Antony Stubbs created KAFKA-6265: Summary: GlobalKTable missing #queryableStoreName() Key: KAFKA-6265 URL: https://issues.apache.org/jira/browse/KAFKA-6265 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6235) Kafka should have an emergency retention setting for max disk used

Antony Stubbs created KAFKA-6235: Summary: Kafka should have an emergency retention setting for max disk used Key: KAFKA-6235 URL: https://issues.apache.org/jira/browse/KAFKA-6235 Project: Kafka

[jira] [Created] (KAFKA-6226) Performance Consumer should print units in it's output, like the producer

Antony Stubbs created KAFKA-6226: Summary: Performance Consumer should print units in it's output, like the producer Key: KAFKA-6226 URL: https://issues.apache.org/jira/browse/KAFKA-6226 Project: Kafk

[jira] [Created] (KAFKA-6225) Add an option to performance consumer consume continuously

Antony Stubbs created KAFKA-6225: Summary: Add an option to performance consumer consume continuously Key: KAFKA-6225 URL: https://issues.apache.org/jira/browse/KAFKA-6225 Project: Kafka Issu

[jira] [Updated] (KAFKA-6182) Automatic co-partitioning of topics via automatic intermediate topic with matching partitions

[ https://issues.apache.org/jira/browse/KAFKA-6182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6182: - Affects Version/s: 1.0.0 > Automatic co-partitioning of topics via automatic intermediate topic wi

[jira] [Updated] (KAFKA-6182) Automatic co-partitioning of topics via automatic intermediate topic with matching partitions

[ https://issues.apache.org/jira/browse/KAFKA-6182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6182: - Description: Currently it is up to the user to ensure that two input topics for a join have the s

[jira] [Created] (KAFKA-6182) Automatic co-partitioning of topics via automatic intermediate topic with matching partitions

Antony Stubbs created KAFKA-6182: Summary: Automatic co-partitioning of topics via automatic intermediate topic with matching partitions Key: KAFKA-6182 URL: https://issues.apache.org/jira/browse/KAFKA-6182

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16234406#comment-16234406 ] Antony Stubbs commented on KAFKA-6144: -- Yes @mjsax I believe it is, sorry I had a loo

[jira] [Updated] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6145: - Description: Currently when expanding the KS cluster, the new node's partitions will be unavailab

[jira] [Updated] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6144: - Description: Currently when expanding the KS cluster, the new node's partitions will be unavailab

[jira] [Created] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

Antony Stubbs created KAFKA-6145: Summary: Warm up new KS instances before migrating tasks - potentially a two phase rebalance Key: KAFKA-6145 URL: https://issues.apache.org/jira/browse/KAFKA-6145 Pro

[jira] [Created] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

Antony Stubbs created KAFKA-6144: Summary: Allow state stores to serve stale reads during rebalance Key: KAFKA-6144 URL: https://issues.apache.org/jira/browse/KAFKA-6144 Project: Kafka Issue

[jira] [Created] (KAFKA-6079) Idempotent production for source connectors

Antony Stubbs created KAFKA-6079: Summary: Idempotent production for source connectors Key: KAFKA-6079 URL: https://issues.apache.org/jira/browse/KAFKA-6079 Project: Kafka Issue Type: New Fea

[jira] [Created] (KAFKA-6080) Transactional EoS for source connectors

Antony Stubbs created KAFKA-6080: Summary: Transactional EoS for source connectors Key: KAFKA-6080 URL: https://issues.apache.org/jira/browse/KAFKA-6080 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-6067) how to process when all isr crashed

[ https://issues.apache.org/jira/browse/KAFKA-6067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209482#comment-16209482 ] Antony Stubbs commented on KAFKA-6067: -- Are you including the leader? If all the foll

[jira] [Commented] (KAFKA-6062) Reduce topic partition count in kafka version 0.10.0.0

[ https://issues.apache.org/jira/browse/KAFKA-6062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209446#comment-16209446 ] Antony Stubbs commented on KAFKA-6062: -- Are you sure this is partition count, and not

[jira] [Commented] (KAFKA-3700) CRL support

[ https://issues.apache.org/jira/browse/KAFKA-3700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16171453#comment-16171453 ] Antony Stubbs commented on KAFKA-3700: -- Another option would be to implement OCSP ht