[
https://issues.apache.org/jira/browse/KAFKA-4488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4488 started by Damian Guy.
-
> UnsupportedOperationException during initialization of StandbyT
Damian Guy created KAFKA-4490:
-
Summary: Add Global Table support to Kafka Streams
Key: KAFKA-4490
URL: https://issues.apache.org/jira/browse/KAFKA-4490
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4490:
--
Environment: (was: As per KIP-99
https://cwiki.apache.org/confluence/display/KAFKA/KIP-99%3A+Add
Damian Guy created KAFKA-4492:
-
Summary: java.lang.IllegalStateException: Attempting to put a
clean entry for key... into NamedCache
Key: KAFKA-4492
URL: https://issues.apache.org/jira/browse/KAFKA-4492
[
https://issues.apache.org/jira/browse/KAFKA-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4490:
--
Description:
As per KIP-99
https://cwiki.apache.org/confluence/display/KAFKA/KIP-99%3A+Add+Global
[
https://issues.apache.org/jira/browse/KAFKA-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4492:
--
Description:
This follows on from https://issues.apache.org/jira/browse/KAFKA-4311
The exception seems
Damian Guy created KAFKA-4495:
-
Summary: ThreadCache.maybeEvict can become an infinite loop
Key: KAFKA-4495
URL: https://issues.apache.org/jira/browse/KAFKA-4495
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-4495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4495.
---
Resolution: Invalid
> ThreadCache.maybeEvict can become an infinite l
[
https://issues.apache.org/jira/browse/KAFKA-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4492:
--
Description:
This follows on from https://issues.apache.org/jira/browse/KAFKA-4311
The exception seems
Damian Guy created KAFKA-4516:
-
Summary: When a CachingStateStore is closed it should clear its
associated NamedCache. Subsequent queries should throw
InvalidStateStoreException
Key: KAFKA-4516
URL: https
[
https://issues.apache.org/jira/browse/KAFKA-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4492.
---
Resolution: Fixed
> java.lang.IllegalStateException: Attempting to put a clean entry for
[
https://issues.apache.org/jira/browse/KAFKA-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4516:
--
Status: Patch Available (was: Open)
> When a CachingStateStore is closed it should clear
[
https://issues.apache.org/jira/browse/KAFKA-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4490:
--
Status: Patch Available (was: Open)
> Add Global Table support to Kafka Stre
[
https://issues.apache.org/jira/browse/KAFKA-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-4473:
-
Assignee: Damian Guy
> RecordCollector should handle retriable exceptions more stric
[
https://issues.apache.org/jira/browse/KAFKA-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4473 started by Damian Guy.
-
> RecordCollector should handle retriable exceptions more stric
Damian Guy created KAFKA-4532:
-
Summary: StateStores can be connected to the wrong source topic
Key: KAFKA-4532
URL: https://issues.apache.org/jira/browse/KAFKA-4532
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4532 started by Damian Guy.
-
> StateStores can be connected to the wrong source to
[
https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4532:
--
Summary: StateStores can be connected to the wrong source topic resulting
in incorrect metadata
[
https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4532:
--
Description:
When building a topology with tables and StateStores, the StateStores are
mapped to the
[
https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4532:
--
Description:
When building a topology with tables and StateStores, the StateStores are
mapped to the
Damian Guy created KAFKA-4534:
-
Summary: StreamPartitionAssignor only ever updates the
partitionsByHostState and metadataWithInternalTopics once.
Key: KAFKA-4534
URL: https://issues.apache.org/jira/browse/KAFKA-4534
[
https://issues.apache.org/jira/browse/KAFKA-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4473:
--
Status: Patch Available (was: In Progress)
> RecordCollector should handle retriable exceptions m
[
https://issues.apache.org/jira/browse/KAFKA-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4534:
--
Status: Patch Available (was: Open)
> StreamPartitionAssignor only ever updates
Damian Guy created KAFKA-4537:
-
Summary: StreamPartitionAssignor incorrectly adds standby
partitions to the partitionsByHostState map
Key: KAFKA-4537
URL: https://issues.apache.org/jira/browse/KAFKA-4537
Damian Guy created KAFKA-4539:
-
Summary: NPE in StreamThread when creating StandbyTasks
Key: KAFKA-4539
URL: https://issues.apache.org/jira/browse/KAFKA-4539
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4539 started by Damian Guy.
-
> NPE in StreamThread when creating StandbyTa
[
https://issues.apache.org/jira/browse/KAFKA-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4539:
--
Status: Patch Available (was: In Progress)
> NPE in StreamThread when creating StandbyTa
[
https://issues.apache.org/jira/browse/KAFKA-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4539:
--
Summary: StreamThread is not correctly creating StandbyTasks (was: NPE in
StreamThread when creating
[
https://issues.apache.org/jira/browse/KAFKA-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4539:
--
Description:
Fails because {{createStandbyTask(..)}} can return null fi the topology for the
{{TaskId
Damian Guy created KAFKA-4540:
-
Summary: Suspended tasks that are not assigned to the StreamThread
need to be closed before new active and standby tasks are created
Key: KAFKA-4540
URL: https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/KAFKA-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749549#comment-15749549
]
Damian Guy commented on KAFKA-4540:
---
This issue isn't resolved. The proble
[
https://issues.apache.org/jira/browse/KAFKA-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4540:
--
Status: Patch Available (was: Open)
> Suspended tasks that are not assigned to the StreamThread n
Damian Guy created KAFKA-4561:
-
Summary: Ordering of operations in
StreamThread.shutdownTasksAndState may void at-least-once guarantees
Key: KAFKA-4561
URL: https://issues.apache.org/jira/browse/KAFKA-4561
[
https://issues.apache.org/jira/browse/KAFKA-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4561 started by Damian Guy.
-
> Ordering of operations in StreamThread.shutdownTasksAndState may void
> at
[
https://issues.apache.org/jira/browse/KAFKA-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4561:
--
Status: Patch Available (was: In Progress)
> Ordering of operations
Damian Guy created KAFKA-4588:
-
Summary:
QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable
is occasionally failing on jenkins
Key: KAFKA-4588
URL: https://issues.apache.org/jira/browse
[
https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4588:
--
Description:
org.apache.kafka.streams.integration.QueryableStateIntegrationTest
[
https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15881280#comment-15881280
]
Damian Guy commented on KAFKA-4791:
---
[~mjsax] this is a bug. Bart is cal
Damian Guy created KAFKA-4851:
-
Summary: SessionStore.fetch(key) is a performance bottleneck
Key: KAFKA-4851
URL: https://issues.apache.org/jira/browse/KAFKA-4851
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4657:
--
Description:
No tests that cover what happens when {{windowStore.fetch(...)}} throw an
[
https://issues.apache.org/jira/browse/KAFKA-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-4863:
-
Assignee: Damian Guy (was: Eno Thereska)
> Querying window store may return unwanted k
[
https://issues.apache.org/jira/browse/KAFKA-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4863 started by Damian Guy.
-
> Querying window store may return unwanted k
[
https://issues.apache.org/jira/browse/KAFKA-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4863:
--
Status: Patch Available (was: In Progress)
> Querying window store may return unwanted k
[
https://issues.apache.org/jira/browse/KAFKA-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4876.
---
Resolution: Duplicate
Fix Version/s: 0.10.2.1
> WindowStore.fetch(key, 0, Long.MaxValue)
Damian Guy created KAFKA-4880:
-
Summary: Add KTable/GlobalKTable Join to Streams
Key: KAFKA-4880
URL: https://issues.apache.org/jira/browse/KAFKA-4880
Project: Kafka
Issue Type: New Feature
Damian Guy created KAFKA-4881:
-
Summary: Add internal leave.group.on.close config to consumer
Key: KAFKA-4881
URL: https://issues.apache.org/jira/browse/KAFKA-4881
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-4880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4880.
---
Resolution: Duplicate
> Add KTable/GlobalKTable Join to Stre
Damian Guy created KAFKA-4890:
-
Summary: State directory being deleted when another thread holds
the lock
Key: KAFKA-4890
URL: https://issues.apache.org/jira/browse/KAFKA-4890
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4890:
--
Description:
Looks like a state directory is being cleaned up when another thread already
has the lock
[
https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924238#comment-15924238
]
Damian Guy commented on KAFKA-4609:
---
[~miguno] It is because the caches are flu
[
https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924238#comment-15924238
]
Damian Guy edited comment on KAFKA-4609 at 3/14/17 2:0
[
https://issues.apache.org/jira/browse/KAFKA-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925825#comment-15925825
]
Damian Guy commented on KAFKA-4885:
---
[~guozhang]
1. We give users a chance to shut
[
https://issues.apache.org/jira/browse/KAFKA-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4643.
---
Resolution: Won't Fix
Method that wasn't covered has subsequently been removed
>
[
https://issues.apache.org/jira/browse/KAFKA-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925830#comment-15925830
]
Damian Guy commented on KAFKA-4643:
---
[~adyachkov] it looks like the method has
[
https://issues.apache.org/jira/browse/KAFKA-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reopened KAFKA-4643:
---
> Improve test coverage of StreamsKafkaCli
[
https://issues.apache.org/jira/browse/KAFKA-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926216#comment-15926216
]
Damian Guy commented on KAFKA-4643:
---
[~adyachkov] true. I missed that! Though the
Damian Guy created KAFKA-4909:
-
Summary: run integration tests separate from unit tests
Key: KAFKA-4909
URL: https://issues.apache.org/jira/browse/KAFKA-4909
Project: Kafka
Issue Type: New
[
https://issues.apache.org/jira/browse/KAFKA-4594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927957#comment-15927957
]
Damian Guy commented on KAFKA-4594:
---
[~manasvigupta]
Sorry, i've already begu
[
https://issues.apache.org/jira/browse/KAFKA-4594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-4594:
-
Assignee: Damian Guy (was: Manasvi Gupta)
> Annotate integration tests and provide gradle bu
[
https://issues.apache.org/jira/browse/KAFKA-4909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4909.
---
Resolution: Duplicate
> run integration tests separate from unit te
[
https://issues.apache.org/jira/browse/KAFKA-4594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4594 started by Damian Guy.
-
> Annotate integration tests and provide gradle build targets to run subsets
[
https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936328#comment-15936328
]
Damian Guy commented on KAFKA-4919:
---
Hi [~elevy] Yes that would be the issue. Bec
[
https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4919 started by Damian Guy.
-
> Document that stores must not be closed when Processors are clo
[
https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-4919:
-
Assignee: Damian Guy
> Document that stores must not be closed when Processors are clo
Damian Guy created KAFKA-4965:
-
Summary: set leave.group.on.close to false in KafkaStreams
Key: KAFKA-4965
URL: https://issues.apache.org/jira/browse/KAFKA-4965
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-4965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4965 started by Damian Guy.
-
> set leave.group.on.close to false in KafkaStre
[
https://issues.apache.org/jira/browse/KAFKA-4965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4965:
--
Summary: set internal.leave.group.on.close to false in KafkaStreams (was:
set leave.group.on.close to
[
https://issues.apache.org/jira/browse/KAFKA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946730#comment-15946730
]
Damian Guy commented on KAFKA-4963:
---
[~mjsax] what you have said is correct.
[
https://issues.apache.org/jira/browse/KAFKA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4963.
---
Resolution: Not A Problem
as [~mjsax] stated in his comment this is by design.
If you want to do any
[
https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947575#comment-15947575
]
Damian Guy commented on KAFKA-4969:
---
This also needs to take into account
[
https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-4913:
-
Assignee: Damian Guy
> creating a window store with one segment throws division by zero er
[
https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4913:
--
Status: Patch Available (was: Open)
> creating a window store with one segment throws division by z
[
https://issues.apache.org/jira/browse/KAFKA-4965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4965:
--
Status: Patch Available (was: In Progress)
> set internal.leave.group.on.close to false
[
https://issues.apache.org/jira/browse/KAFKA-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-4937:
-
Assignee: Damian Guy
> Batch resetting offsets in Streams' StoreChangel
[
https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4913:
--
Fix Version/s: (was: 0.10.2.1)
0.11.0.0
> creating a window store with
[
https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4913:
--
Priority: Major (was: Blocker)
> creating a window store with one segment throws division by z
[
https://issues.apache.org/jira/browse/KAFKA-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-5047:
-
Assignee: Damian Guy
> NullPointerException while using GlobalKTable in KafkaStre
[
https://issues.apache.org/jira/browse/KAFKA-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5047:
--
Status: Patch Available (was: Open)
> NullPointerException while using GlobalKTable in KafkaStre
Damian Guy created KAFKA-5054:
-
Summary: ChangeLoggingKeyValueByteStore delete and putIfAbsent
should be synchronized
Key: KAFKA-5054
URL: https://issues.apache.org/jira/browse/KAFKA-5054
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-5054:
-
Assignee: Damian Guy
> ChangeLoggingKeyValueByteStore delete and putIfAbsent should
Damian Guy created KAFKA-5058:
-
Summary: Add a sensor to KafkaStreams to track records that have
been dropped due to having a null key
Key: KAFKA-5058
URL: https://issues.apache.org/jira/browse/KAFKA-5058
Damian Guy created KAFKA-5059:
-
Summary: Implement Transactional Coordinator
Key: KAFKA-5059
URL: https://issues.apache.org/jira/browse/KAFKA-5059
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5059:
--
Description: This covers the implementation of the transaction coordinator
to support transactions, as
Damian Guy created KAFKA-5095:
-
Summary: ThreadCacheTest.cacheOverheadsSmallValues fails
intermittently
Key: KAFKA-5095
URL: https://issues.apache.org/jira/browse/KAFKA-5095
Project: Kafka
Damian Guy created KAFKA-5113:
-
Summary: Tidy up usage of Errors.INVALID_FETCH_SIZE and
InvalidFetchSizeException
Key: KAFKA-5113
URL: https://issues.apache.org/jira/browse/KAFKA-5113
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-4588:
-
Assignee: Damian Guy
Damian Guy created KAFKA-4609:
-
Summary: KTable/KTable join followed by groupBy and
aggregate/count can result in incorrect results
Key: KAFKA-4609
URL: https://issues.apache.org/jira/browse/KAFKA-4609
Damian Guy created KAFKA-4628:
-
Summary: Support KTable/GlobalKTable Joins
Key: KAFKA-4628
URL: https://issues.apache.org/jira/browse/KAFKA-4628
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4588:
--
Status: Patch Available (was: In Progress
[
https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4588 started by Damian Guy.
-
> QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvaila
Damian Guy created KAFKA-4640:
-
Summary: Improve Streams unit test coverage
Key: KAFKA-4640
URL: https://issues.apache.org/jira/browse/KAFKA-4640
Project: Kafka
Issue Type: Bug
Damian Guy created KAFKA-4641:
-
Summary: Improve test coverage of StreamsThread
Key: KAFKA-4641
URL: https://issues.apache.org/jira/browse/KAFKA-4641
Project: Kafka
Issue Type: Sub-task
Damian Guy created KAFKA-4642:
-
Summary: Improve test coverage of ProcessorStateManager
Key: KAFKA-4642
URL: https://issues.apache.org/jira/browse/KAFKA-4642
Project: Kafka
Issue Type: Sub-task
Damian Guy created KAFKA-4643:
-
Summary: Improve test coverage of StreamsKafkaClient
Key: KAFKA-4643
URL: https://issues.apache.org/jira/browse/KAFKA-4643
Project: Kafka
Issue Type: Sub-task
Damian Guy created KAFKA-4644:
-
Summary: Improve test coverage of StreamsPartitionAssignor
Key: KAFKA-4644
URL: https://issues.apache.org/jira/browse/KAFKA-4644
Project: Kafka
Issue Type: Sub
Damian Guy created KAFKA-4645:
-
Summary: Improve test coverage of ProcessorTopology
Key: KAFKA-4645
URL: https://issues.apache.org/jira/browse/KAFKA-4645
Project: Kafka
Issue Type: Sub-task
Damian Guy created KAFKA-4646:
-
Summary: Improve Streams unit test coverage
Key: KAFKA-4646
URL: https://issues.apache.org/jira/browse/KAFKA-4646
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4646.
---
Resolution: Duplicate
> Improve Streams unit test cover
[
https://issues.apache.org/jira/browse/KAFKA-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4646:
--
Summary: Improve test coverage AbstractProcessorContext (was: Improve
Streams unit test coverage
[
https://issues.apache.org/jira/browse/KAFKA-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reopened KAFKA-4646:
---
Exception paths in {{register}}, {{topic}}, {{partition}}, {{offset}},
{{timestamp}}
> Improve t
501 - 600 of 765 matches
Mail list logo
