[jira] [Resolved] (KAFKA-11151) Load Bug greeqrsThe 10

[ https://issues.apache.org/jira/browse/KAFKA-11151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11151. - Resolution: Invalid > Load Bug greeqrsThe 10 > --- > >

[jira] [Resolved] (KAFKA-11155) Load Bug ted789peop 3

[ https://issues.apache.org/jira/browse/KAFKA-11155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11155. - Resolution: Invalid > Load Bug ted789peop 3 > -- > >

[jira] [Resolved] (KAFKA-11157) Load Bug llwxybezan 19

[ https://issues.apache.org/jira/browse/KAFKA-11157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11157. - Resolution: Invalid > Load Bug llwxybezan 19 > --- > >

[jira] [Resolved] (KAFKA-11216) Load Bug arted789pe 20

[ https://issues.apache.org/jira/browse/KAFKA-11216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11216. - Resolution: Invalid > Load Bug arted789pe 20 > --- > >

[jira] [Resolved] (KAFKA-11183) Load Bug lwxybezana 5

[ https://issues.apache.org/jira/browse/KAFKA-11183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11183. - Resolution: Invalid > Load Bug lwxybezana 5 > -- > >

[jira] [Resolved] (KAFKA-11160) Load Bug brokenhear 18

[ https://issues.apache.org/jira/browse/KAFKA-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11160. - Resolution: Invalid > Load Bug brokenhear 18 > --- > >

[jira] [Resolved] (KAFKA-11181) Load Bug 789peoplea 14

[ https://issues.apache.org/jira/browse/KAFKA-11181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11181. - Resolution: Invalid > Load Bug 789peoplea 14 > --- > >

[jira] [Resolved] (KAFKA-11163) Load Bug hearted789 10

[ https://issues.apache.org/jira/browse/KAFKA-11163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11163. - Resolution: Invalid > Load Bug hearted789 10 > --- > >

[jira] [Resolved] (KAFKA-11161) Load Bug peopleabcl 12

[ https://issues.apache.org/jira/browse/KAFKA-11161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11161. - Resolution: Invalid > Load Bug peopleabcl 12 > --- > >

[jira] [Resolved] (KAFKA-11162) Load Bug lmworldnop 13

[ https://issues.apache.org/jira/browse/KAFKA-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11162. - Resolution: Invalid > Load Bug lmworldnop 13 > --- > >

[jira] [Resolved] (KAFKA-11164) Load Bug 456brokenh 11

[ https://issues.apache.org/jira/browse/KAFKA-11164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11164. - Resolution: Invalid > Load Bug 456brokenh 11 > --- > >

[jira] [Resolved] (KAFKA-11210) Load Bug greeqrsThe 12

[ https://issues.apache.org/jira/browse/KAFKA-11210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11210. - Resolution: Invalid > Load Bug greeqrsThe 12 > --- > >

[jira] [Resolved] (KAFKA-11167) Load Bug lwxybezana 7

[ https://issues.apache.org/jira/browse/KAFKA-11167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11167. - Resolution: Invalid > Load Bug lwxybezana 7 > -- > >

[jira] [Resolved] (KAFKA-11174) Load Bug nanswerlet 20

[ https://issues.apache.org/jira/browse/KAFKA-11174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11174. - Resolution: Invalid > Load Bug nanswerlet 20 > --- > >

[jira] [Resolved] (KAFKA-11168) Load Bug vwillwxybe 3

[ https://issues.apache.org/jira/browse/KAFKA-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11168. - Resolution: Invalid > Load Bug vwillwxybe 3 > -- > >

[jira] [Resolved] (KAFKA-11173) Load Bug mworldnopa 19

[ https://issues.apache.org/jira/browse/KAFKA-11173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11173. - Resolution: Invalid > Load Bug mworldnopa 19 > --- > >

[jira] [Resolved] (KAFKA-11178) Load Bug eretuvwill 17

[ https://issues.apache.org/jira/browse/KAFKA-11178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11178. - Resolution: Invalid > Load Bug eretuvwill 17 > --- > >

[jira] [Resolved] (KAFKA-11175) Load Bug werletitbe 9

[ https://issues.apache.org/jira/browse/KAFKA-11175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11175. - Resolution: Invalid > Load Bug werletitbe 9 > -- > >

[jira] [Resolved] (KAFKA-11179) Load Bug kenhearted 7

[ https://issues.apache.org/jira/browse/KAFKA-11179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11179. - Resolution: Invalid > Load Bug kenhearted 7 > -- > >

[jira] [Resolved] (KAFKA-11185) Load Bug peopleabcl 4

[ https://issues.apache.org/jira/browse/KAFKA-11185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11185. - Resolution: Invalid > Load Bug peopleabcl 4 > -- > >

[jira] [Resolved] (KAFKA-11182) Load Bug erletitbe 15

[ https://issues.apache.org/jira/browse/KAFKA-11182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11182. - Resolution: Invalid > Load Bug erletitbe 15 > -- > >

[jira] [Resolved] (KAFKA-11186) Load Bug sTheretuvw 17

[ https://issues.apache.org/jira/browse/KAFKA-11186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11186. - Resolution: Invalid > Load Bug sTheretuvw 17 > --- > >

[jira] [Resolved] (KAFKA-11188) Load Bug orldnopagr 16

[ https://issues.apache.org/jira/browse/KAFKA-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11188. - Resolution: Invalid > Load Bug orldnopagr 16 > --- > >

[jira] [Resolved] (KAFKA-11187) Load Bug nanswerlet 19

[ https://issues.apache.org/jira/browse/KAFKA-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11187. - Resolution: Invalid > Load Bug nanswerlet 19 > --- > >

[jira] [Resolved] (KAFKA-11190) Load Bug fginhijthe 15

[ https://issues.apache.org/jira/browse/KAFKA-11190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11190. - Resolution: Invalid > Load Bug fginhijthe 15 > --- > >

[jira] [Resolved] (KAFKA-11195) Load Bug 123the456b 20

[ https://issues.apache.org/jira/browse/KAFKA-11195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11195. - Resolution: Invalid > Load Bug 123the456b 20 > --- > >

[jira] [Resolved] (KAFKA-11192) Load Bug agreeqrsTh 13

[ https://issues.apache.org/jira/browse/KAFKA-11192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11192. - Resolution: Invalid > Load Bug agreeqrsTh 13 > --- > >

[jira] [Resolved] (KAFKA-11194) Load Bug ed789peopl 12

[ https://issues.apache.org/jira/browse/KAFKA-11194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11194. - Resolution: Invalid > Load Bug ed789peopl 12 > --- > >

[jira] [Resolved] (KAFKA-11196) Load Bug hen123the4 1

[ https://issues.apache.org/jira/browse/KAFKA-11196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11196. - Resolution: Invalid > Load Bug hen123the4 1 > -- > >

[jira] [Resolved] (KAFKA-11197) Load Bug titbe 4

[ https://issues.apache.org/jira/browse/KAFKA-11197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11197. - Resolution: Invalid > Load Bug titbe 4 > - > > Key: KAF

[jira] [Resolved] (KAFKA-11199) Load Bug abclivinge 2

[ https://issues.apache.org/jira/browse/KAFKA-11199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11199. - Resolution: Invalid > Load Bug abclivinge 2 > -- > >

[jira] [Resolved] (KAFKA-11202) Load Bug earted789p 7

[ https://issues.apache.org/jira/browse/KAFKA-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11202. - Resolution: Invalid > Load Bug earted789p 7 > -- > >

[jira] [Resolved] (KAFKA-11203) Load Bug leabclivin 9

[ https://issues.apache.org/jira/browse/KAFKA-11203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11203. - Resolution: Invalid > Load Bug leabclivin 9 > -- > >

[jira] [Resolved] (KAFKA-11201) Load Bug ngefginhij 6

[ https://issues.apache.org/jira/browse/KAFKA-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11201. - Resolution: Invalid > Load Bug ngefginhij 6 > -- > >

[jira] [Resolved] (KAFKA-11200) Load Bug greeqrsThe 3

[ https://issues.apache.org/jira/browse/KAFKA-11200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11200. - Resolution: Invalid > Load Bug greeqrsThe 3 > -- > >

[jira] [Resolved] (KAFKA-11205) Load Bug greeqrsThe 10

[ https://issues.apache.org/jira/browse/KAFKA-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11205. - Resolution: Invalid > Load Bug greeqrsThe 10 > --- > >

[jira] [Resolved] (KAFKA-11213) Load Bug itbe 15

[ https://issues.apache.org/jira/browse/KAFKA-11213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11213. - Resolution: Invalid > Load Bug itbe 15 > - > > Key: KAF

[jira] [Resolved] (KAFKA-11215) Load Bug eqrsTheret 1

[ https://issues.apache.org/jira/browse/KAFKA-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11215. - Resolution: Invalid > Load Bug eqrsTheret 1 > -- > >

[jira] [Resolved] (KAFKA-11214) Load Bug zananswerl 11

[ https://issues.apache.org/jira/browse/KAFKA-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11214. - Resolution: Invalid > Load Bug zananswerl 11 > --- > >

[jira] [Resolved] (KAFKA-11212) Load Bug ivingefgin 19

[ https://issues.apache.org/jira/browse/KAFKA-11212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11212. - Resolution: Invalid > Load Bug ivingefgin 19 > --- > >

[jira] [Resolved] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10722. - Fix Version/s: 2.8.0 Resolution: Fixed Added you to the list of contributors and

[jira] [Resolved] (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 ] Matthias J. Sax resolved KAFKA-8651. Resolution: Duplicate Closing this ticket in favor of KAFKA-5488 that is backed by KIP-418

[jira] [Created] (KAFKA-10848) Allow fine grained control over cross-partition processing order

Matthias J. Sax created KAFKA-10848: --- Summary: Allow fine grained control over cross-partition processing order Key: KAFKA-10848 URL: https://issues.apache.org/jira/browse/KAFKA-10848 Project: Kafka

[jira] [Created] (KAFKA-10847) Avoid spurious left/outer join results in stream-stream join

Matthias J. Sax created KAFKA-10847: --- Summary: Avoid spurious left/outer join results in stream-stream join Key: KAFKA-10847 URL: https://issues.apache.org/jira/browse/KAFKA-10847 Project: Kafka

[jira] [Resolved] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9552. Fix Version/s: 2.6.0 Resolution: Fixed > Stream should handle OutOfSequence exceptio

[jira] [Reopened] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9552: > Stream should handle OutOfSequence exception thrown from Producer > -

[jira] [Resolved] (KAFKA-10752) One topic partition multiple consumer

[ https://issues.apache.org/jira/browse/KAFKA-10752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10752. - Resolution: Invalid [~dnamicro] – we use the Jira board for bug reports, not to answer q

[jira] [Resolved] (KAFKA-10745) Please let me know how I check the time which Source connector receive the data from source table.

[ https://issues.apache.org/jira/browse/KAFKA-10745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10745. - Resolution: Invalid [~nayusik] – we use the Jira board for bug reports, not to answer qu

[jira] [Created] (KAFKA-10755) Should consider commit latency when computing next commit timestamp

Matthias J. Sax created KAFKA-10755: --- Summary: Should consider commit latency when computing next commit timestamp Key: KAFKA-10755 URL: https://issues.apache.org/jira/browse/KAFKA-10755 Project: Ka

[jira] [Resolved] (KAFKA-10500) Add API to Start and Stop Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10500. - Fix Version/s: 2.8.0 Resolution: Fixed > Add API to Start and Stop Stream Threads

[jira] [Resolved] (KAFKA-10036) Improve error message if user violates `Supplier` pattern

[ https://issues.apache.org/jira/browse/KAFKA-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10036. - Fix Version/s: 2.8.0 Resolution: Fixed > Improve error message if user violates `

[jira] [Resolved] (KAFKA-10569) Running aggregate queries on KSQL client side is getting to ERROR Shutdown broker because all log dirs in ...

[ https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10569. - Resolution: Invalid > Running aggregate queries on KSQL client side is getting to ERROR

[jira] [Resolved] (KAFKA-6585) Consolidate duplicated logic on reset tools

[ https://issues.apache.org/jira/browse/KAFKA-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6585. Fix Version/s: 2.7.0 Resolution: Fixed > Consolidate duplicated logic on reset tools

[jira] [Created] (KAFKA-10555) Improve client state machine

Matthias J. Sax created KAFKA-10555: --- Summary: Improve client state machine Key: KAFKA-10555 URL: https://issues.apache.org/jira/browse/KAFKA-10555 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-10297) Don't use deprecated producer config `retries`

[ https://issues.apache.org/jira/browse/KAFKA-10297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10297. - Resolution: Invalid We change the KIP to not deprecate `retries`. Hence, this ticket is

[jira] [Resolved] (KAFKA-10480) Kafka streams application is being stuck

[ https://issues.apache.org/jira/browse/KAFKA-10480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10480. - Resolution: Invalid > Kafka streams application is being stuck > ---

[jira] [Reopened] (KAFKA-10480) Kafka streams application is being stuck

[ https://issues.apache.org/jira/browse/KAFKA-10480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-10480: - > Kafka streams application is being stuck > > >

[jira] [Created] (KAFKA-10351) Add missing tests for IOExceptions for GlobalStateManagerImpl

Matthias J. Sax created KAFKA-10351: --- Summary: Add missing tests for IOExceptions for GlobalStateManagerImpl Key: KAFKA-10351 URL: https://issues.apache.org/jira/browse/KAFKA-10351 Project: Kafka

[jira] [Resolved] (KAFKA-10321) shouldDieOnInvalidOffsetExceptionDuringStartup would block forever on JDK11

[ https://issues.apache.org/jira/browse/KAFKA-10321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10321. - Fix Version/s: 2.7.0 Resolution: Fixed > shouldDieOnInvalidOffsetExceptionDuringS

[jira] [Created] (KAFKA-10317) Global thread should honor shutdown signal during bootstrapping

Matthias J. Sax created KAFKA-10317: --- Summary: Global thread should honor shutdown signal during bootstrapping Key: KAFKA-10317 URL: https://issues.apache.org/jira/browse/KAFKA-10317 Project: Kafka

[jira] [Created] (KAFKA-10316) Consider renaming getter method for Interactive Queries

Matthias J. Sax created KAFKA-10316: --- Summary: Consider renaming getter method for Interactive Queries Key: KAFKA-10316 URL: https://issues.apache.org/jira/browse/KAFKA-10316 Project: Kafka

[jira] [Created] (KAFKA-10315) Consider to throw exception for failed fetch requests

Matthias J. Sax created KAFKA-10315: --- Summary: Consider to throw exception for failed fetch requests Key: KAFKA-10315 URL: https://issues.apache.org/jira/browse/KAFKA-10315 Project: Kafka I

[jira] [Created] (KAFKA-10306) GlobalThread might loop forever

Matthias J. Sax created KAFKA-10306: --- Summary: GlobalThread might loop forever Key: KAFKA-10306 URL: https://issues.apache.org/jira/browse/KAFKA-10306 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-10297) Don't use deprecated producer config `retries`

Matthias J. Sax created KAFKA-10297: --- Summary: Don't use deprecated producer config `retries` Key: KAFKA-10297 URL: https://issues.apache.org/jira/browse/KAFKA-10297 Project: Kafka Issue Ty

[jira] [Resolved] (KAFKA-8296) Kafka Streams branch method raises type warnings

[ https://issues.apache.org/jira/browse/KAFKA-8296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8296. Resolution: Duplicate Closing this ticket as duplicate. > Kafka Streams branch method rais

[jira] [Created] (KAFKA-10277) Relax non-null key requirement for stream-globalTable joins

Matthias J. Sax created KAFKA-10277: --- Summary: Relax non-null key requirement for stream-globalTable joins Key: KAFKA-10277 URL: https://issues.apache.org/jira/browse/KAFKA-10277 Project: Kafka

[jira] [Resolved] (KAFKA-10247) Streams may attempt to process after closing a task

[ https://issues.apache.org/jira/browse/KAFKA-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10247. - Fix Version/s: 2.6.0 Resolution: Fixed > Streams may attempt to process after clo

[jira] [Resolved] (KAFKA-10262) StateDirectory is not thread-safe

[ https://issues.apache.org/jira/browse/KAFKA-10262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10262. - Fix Version/s: 2.6.0 Resolution: Fixed > StateDirectory is not thread-safe >

[jira] [Resolved] (KAFKA-10222) Incorrect methods show up in 0.10 Kafka Streams docs

[ https://issues.apache.org/jira/browse/KAFKA-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10222. - Resolution: Fixed > Incorrect methods show up in 0.10 Kafka Streams docs > -

[jira] [Reopened] (KAFKA-6453) Reconsider timestamp propagation semantics

[ https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-6453: IMHO, the PR only covers part of this ticket. We should also document how timestamps are compu

[jira] [Resolved] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9891. Resolution: Fixed > Invalid state store content after task migration with exactly_once and

[jira] [Resolved] (KAFKA-10155) Flaky Test ReassignPartitionsUnitTest.testModifyBrokerThrottles

[ https://issues.apache.org/jira/browse/KAFKA-10155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10155. - Resolution: Fixed > Flaky Test ReassignPartitionsUnitTest.testModifyBrokerThrottles > --

[jira] [Created] (KAFKA-10168) Rename public StreamsConfig variable

Matthias J. Sax created KAFKA-10168: --- Summary: Rename public StreamsConfig variable Key: KAFKA-10168 URL: https://issues.apache.org/jira/browse/KAFKA-10168 Project: Kafka Issue Type: Improv

[jira] [Resolved] (KAFKA-7833) StreamsBuilder should throw an exception if addGlobalStore and addStateStore is called for the same store builder

[ https://issues.apache.org/jira/browse/KAFKA-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7833. Fix Version/s: 2.6.0 Resolution: Fixed > StreamsBuilder should throw an exception if

[jira] [Resolved] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7608. Resolution: Fixed KIP-221 is merged. Closing this ticket. > A Kafka Streams DSL transform

[jira] [Resolved] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8011. Assignee: Matthias J. Sax (was: Sophie Blee-Goldman) Resolution: Fixed The currently

[jira] [Resolved] (KAFKA-10030) Throw exception while fetching a key from a single partition

[ https://issues.apache.org/jira/browse/KAFKA-10030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10030. - Resolution: Fixed > Throw exception while fetching a key from a single partition > -

[jira] [Resolved] (KAFKA-10064) Add documentation for KIP-571

[ https://issues.apache.org/jira/browse/KAFKA-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10064. - Resolution: Fixed > Add documentation for KIP-571 > - > >

[jira] [Created] (KAFKA-10055) Add shared internal utility class

Matthias J. Sax created KAFKA-10055: --- Summary: Add shared internal utility class Key: KAFKA-10055 URL: https://issues.apache.org/jira/browse/KAFKA-10055 Project: Kafka Issue Type: Improveme

[jira] [Reopened] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8011: Failed again:  [https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/2533/testReport/junit/org

[jira] [Resolved] (KAFKA-658) Implement "Exact Mirroring" functionality in mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-658. --- Resolution: Fixed Closing this ticket as fixed, as MM2 is available now. > Implement "Exact M

[jira] [Resolved] (KAFKA-617) Refactor KafkaApis.handleListOffsetRequest

[ https://issues.apache.org/jira/browse/KAFKA-617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-617. --- Resolution: Abandoned Closing this old ticket as abandoned. > Refactor KafkaApis.handleListOf

[jira] [Resolved] (KAFKA-205) Audit swallowing of exceptions/throwables

[ https://issues.apache.org/jira/browse/KAFKA-205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-205. --- Resolution: Abandoned Closing this old ticket as abandoned. > Audit swallowing of exceptions/

[jira] [Resolved] (KAFKA-72) Redo config objects with default arguments

[ https://issues.apache.org/jira/browse/KAFKA-72?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-72. -- Closing this old ticket as abandoned. > Redo config objects with default arguments > ---

[jira] [Resolved] (KAFKA-40) Time based log rolling

[ https://issues.apache.org/jira/browse/KAFKA-40?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-40. -- Resolution: Implemented (was: Abandoned) It seem the time-index as introduced via KIP-33 ([http

[jira] [Resolved] (KAFKA-39) javaapi does not declare IOException to be thrown

[ https://issues.apache.org/jira/browse/KAFKA-39?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-39. -- > javaapi does not declare IOException to be thrown > ---

[jira] [Created] (KAFKA-10036) Improve error message is user violates `Supplier` pattern

Matthias J. Sax created KAFKA-10036: --- Summary: Improve error message is user violates `Supplier` pattern Key: KAFKA-10036 URL: https://issues.apache.org/jira/browse/KAFKA-10036 Project: Kafka

[jira] [Resolved] (KAFKA-10003) Deprecate KStream#through in favor of KStream#repartition

[ https://issues.apache.org/jira/browse/KAFKA-10003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10003. - Fix Version/s: 2.6.0 Resolution: Fixed > Deprecate KStream#through in favor of KS

[jira] [Resolved] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks

[ https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7041. Resolution: Won't Fix > Using RocksDB bulk loading for StandbyTasks > -

[jira] [Resolved] (KAFKA-8311) Better consumer timeout exception handling

[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8311. Resolution: Duplicate Closing this ticket – KIP-572 / KAFKA-9274 does subsume it. > Better

[jira] [Resolved] (KAFKA-7985) Cleanup AssignedTasks / AbstractTask logic

[ https://issues.apache.org/jira/browse/KAFKA-7985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7985. Resolution: Abandoned Given that this ticket is old and the code was refactored multiple ti

[jira] [Resolved] (KAFKA-7708) [kafka-streams-scala] Invalid signature for KTable join in 2.12

[ https://issues.apache.org/jira/browse/KAFKA-7708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7708. Resolution: Abandoned > [kafka-streams-scala] Invalid signature for KTable join in 2.12 > -

[jira] [Resolved] (KAFKA-7445) Branch one Stream in multiple Streams

[ https://issues.apache.org/jira/browse/KAFKA-7445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7445. Resolution: Not A Problem > Branch one Stream in multiple Streams > ---

[jira] [Resolved] (KAFKA-7209) Kafka stream does not rebalance when one node gets down

[ https://issues.apache.org/jira/browse/KAFKA-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7209. Resolution: Abandoned > Kafka stream does not rebalance when one node gets down > -

[jira] [Resolved] (KAFKA-7203) Improve Streams StickyTaskAssingor

[ https://issues.apache.org/jira/browse/KAFKA-7203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7203. Resolution: Fixed > Improve Streams StickyTaskAssingor > --

[jira] [Resolved] (KAFKA-7133) DisconnectException every 5 minutes in single restore consumer thread

[ https://issues.apache.org/jira/browse/KAFKA-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7133. Resolution: Abandoned > DisconnectException every 5 minutes in single restore consumer thre

[jira] [Resolved] (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:all-tabpanel ] Matthias J. Sax resolved KAFKA-7035. Resolution: Abandoned > Kafka Processor's init() method sometimes is not called > -

[jira] [Resolved] (KAFKA-7015) Enhance RecordCollectorImpl exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7015. Resolution: Not A Problem We should actually not log sensitive information like key and val

[jira] [Resolved] (KAFKA-7004) Support configurable restore consumer poll timeout

[ https://issues.apache.org/jira/browse/KAFKA-7004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7004. Resolution: Fixed > Support configurable restore consumer poll timeout > --

[jira] [Resolved] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data

[ https://issues.apache.org/jira/browse/KAFKA-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6977. Resolution: Abandoned > Kafka Streams - java.lang.IllegalStateException: Unexpected error

<    1   2   3   4   5   6   7   8   9   10   >