jira@kafka.apache.org, 2018-06

You are viewing a plain text version of this content. The canonical link for it is here.

- [jira] [Commented] (KAFKA-6936) Scala API Wrapper for Streams uses default serializer for table aggregate - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 00:20:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6979) Add max.block.ms to consumer for default behavior - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/01 01:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6979) Add max.block.ms to consumer for default timeout behavior - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/01 01:02:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-6979) Add max.block.ms to consumer for default timeout behavior - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/01 01:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6870) Concurrency conflicts in SampledStat - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/01 01:29:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5810) Improve authentication logging on the broker-side - posted by "Gérald Quintana (JIRA)" <ji...@apache.org> on 2018/06/01 08:07:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5810) Improve authentication logging on the broker-side - posted by "Gérald Quintana (JIRA)" <ji...@apache.org> on 2018/06/01 08:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3743) kafka-server-start.sh: Unhelpful error message - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 10:35:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 10:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6959) Any impact we foresee if we upgrade Linux version or move to VM instead of physical Linux server - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 10:52:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6980) Recommended MaxDirectMemorySize for consumers - posted by "John Lu (JIRA)" <ji...@apache.org> on 2018/06/01 13:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6972) Kafka ACL does not work expected with wildcard - posted by "Sönke Liebau (JIRA)" <ji...@apache.org> on 2018/06/01 13:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6309) add support for getting topic defaults from AdminClient - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 14:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6973) setting invalid timestamp causes Kafka broker restart to fail - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 14:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6936) Scala API Wrapper for Streams uses default serializer for table aggregate - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/01 14:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6973) setting invalid timestamp causes Kafka broker restart to fail - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/01 14:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6973) setting invalid timestamp causes Kafka broker restart to fail - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/01 14:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6581) ConsumerGroupCommand hangs if even one of the partition is unavailable - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 14:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 14:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3503) Throw exception on missing/non-existent partition - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 14:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 14:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 14:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3011) Consumer.poll(0) blocks if Kafka not accessible - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 15:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3457) KafkaConsumer.committed(...) hangs forever if port number is wrong - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 15:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 15:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4571) Consumer fails to retrieve messages if started before producer - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 15:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4751) kafka-clients-0.9.0.2.4.2.11-1 issue not throwing exception. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 16:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/01 16:35:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 16:35:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-5304) Kafka Producer throwing infinite NullPointerExceptions - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 16:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6207) Include start of record when RecordIsTooLarge - posted by "Tadhg Pearson (JIRA)" <ji...@apache.org> on 2018/06/01 17:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5424) KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 18:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6979) Add max.block.ms to consumer for default timeout behavior - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 21:58:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6965) log4j:WARN log messages printed when running kafka-console-producer OOB - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/01 23:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6965) log4j:WARN log messages printed when running kafka-console-producer OOB - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/01 23:14:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6760) responses not logged properly in controller - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 23:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6098) Delete and Re-create topic operation could result in race condition - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/01 23:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters - posted by "Arjun Satish (JIRA)" <ji...@apache.org> on 2018/06/01 23:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6760) responses not logged properly in controller - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/01 23:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/01 23:50:00 UTC, 9 replies.
- [jira] [Commented] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/01 23:51:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters - posted by "Arjun Satish (JIRA)" <ji...@apache.org> on 2018/06/01 23:53:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6860) NPE when reinitializeStateStores with eos enabled - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/02 00:00:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/02 00:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/02 00:10:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-6965) log4j:WARN log messages printed when running kafka-console-producer OOB - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/02 00:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6982) java.lang.ArithmeticException: / by zero - posted by "wade wu (JIRA)" <ji...@apache.org> on 2018/06/02 00:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6982) java.lang.ArithmeticException: / by zero - posted by "wade wu (JIRA)" <ji...@apache.org> on 2018/06/02 00:56:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6983) Error while deleting segments - The process cannot access the file because it is being used by another process - posted by "wade wu (JIRA)" <ji...@apache.org> on 2018/06/02 01:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6982) java.lang.ArithmeticException: / by zero - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/06/02 02:29:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/02 03:08:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6984) Question - posted by "Remil (JIRA)" <ji...@apache.org> on 2018/06/02 07:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6984) Question - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/02 08:10:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6985) Error connection between cluster node - posted by "Ranjeet Ranjan (JIRA)" <ji...@apache.org> on 2018/06/02 09:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5919) Adding checks on "version" field for tools using it - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/02 13:26:10 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed - posted by "Di Campo (JIRA)" <ji...@apache.org> on 2018/06/02 18:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6986) Export Admin Client metrics through Stream Threads - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/06/02 19:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6955) Use Java AdminClient in DeleteRecordsCommand - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/02 19:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6743) ConsumerPerformance fails to consume all messages on topics with large number of partitions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/02 23:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6743) ConsumerPerformance fails to consume all messages on topics with large number of partitions - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/02 23:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6912) Add authorization tests for custom principal types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/03 01:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6972) Kafka ACL does not work expected with wildcard - posted by "Soyee Deng (JIRA)" <ji...@apache.org> on 2018/06/03 08:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/03 08:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6972) Kafka ACL does not work expected with wildcard - posted by "Soyee Deng (JIRA)" <ji...@apache.org> on 2018/06/03 08:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6976) Kafka Streams instances going in to DEAD state - posted by "Deepak Goyal (JIRA)" <ji...@apache.org> on 2018/06/03 09:17:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-6976) Kafka Streams instances going in to DEAD state - posted by "Deepak Goyal (JIRA)" <ji...@apache.org> on 2018/06/03 09:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/03 18:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6900) Add thenCompose to KafkaFuture - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/03 21:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6841) Add support for Prefixed ACLs - posted by "Piyush Vijay (JIRA)" <ji...@apache.org> on 2018/06/04 00:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6709) broker failed to handle request due to OOM - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/04 01:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently - posted by "Valencia Edna Serrao (JIRA)" <ji...@apache.org> on 2018/06/04 04:30:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4960) Invalid state store exception - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 05:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 05:21:00 UTC, 9 replies.
- [jira] [Resolved] (KAFKA-5974) Removed unused parameter ProcessorContext - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 05:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5924) Add the compose method to the Kafka Stream API - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 05:33:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 05:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 05:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5393) in-memory state store memory issue - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 05:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5058) Add a sensor to KafkaStreams to track records that have been dropped due to having a null key - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 05:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5739) Rewrite KStreamPeekTest at processor level avoiding driver usage - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 05:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6355) transient failure in org.apache.kafka.streams.integration.EosIntegrationTest.shouldBeAbleToRunWithTwoSubtopologies - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 05:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6092) Time passed in punctuate call is currentTime, not punctuate schedule time. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 05:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6987) Reimplement KafkaFuture with CopletableFuture - posted by "Andras Beni (JIRA)" <ji...@apache.org> on 2018/06/04 07:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/06/04 09:59:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/04 11:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6923) Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2018/06/04 14:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6988) Kafka windows classpath too long - posted by "lkgen (JIRA)" <ji...@apache.org> on 2018/06/04 14:46:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5761) Serializer API should support ByteBuffer - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/04 15:06:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException - posted by "Anil (JIRA)" <ji...@apache.org> on 2018/06/04 17:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException - posted by "Anil (JIRA)" <ji...@apache.org> on 2018/06/04 17:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6989) Support Async Processing in Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 17:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/04 17:14:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4690) IllegalStateException using DeleteTopicsRequest when delete.topic.enable=false - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 17:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6989) Support Async Processing in Streams - posted by "Virgil Palanciuc (JIRA)" <ji...@apache.org> on 2018/06/04 17:42:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6989) Support Async Processing in Streams - posted by "Virgil Palanciuc (JIRA)" <ji...@apache.org> on 2018/06/04 17:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6987) Reimplement KafkaFuture with CopletableFuture - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 18:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2018/06/04 19:35:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 20:14:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread - posted by "Eugen Feller (JIRA)" <ji...@apache.org> on 2018/06/04 21:34:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread - posted by "Eugen Feller (JIRA)" <ji...@apache.org> on 2018/06/04 21:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data - posted by "Eugen Feller (JIRA)" <ji...@apache.org> on 2018/06/04 21:39:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6813) Remove deprecated APIs from KIP-120 and KIP-182 in Streams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 22:34:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 22:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5632) Message headers not supported by Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 22:47:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5632) Message headers not supported by Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/04 22:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6986) Export Admin Client metrics through Stream Threads - posted by "Shun Guan (JIRA)" <ji...@apache.org> on 2018/06/04 22:50:00 UTC, 9 replies.
- [jira] [Commented] (KAFKA-6722) SensorAccess.getOrCreate should be more efficient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 00:54:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread - posted by "Eugen Feller (JIRA)" <ji...@apache.org> on 2018/06/05 01:01:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-6963) KIP-308: Add a Kafka Source Connector to Kafka Connect - posted by "Rhys Anthony McCaig (JIRA)" <ji...@apache.org> on 2018/06/05 01:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6841) Add support for Prefixed ACLs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 01:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6986) Export Admin Client metrics through Stream Threads - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/05 02:00:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-6989) Support Async Processing in Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/05 02:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6991) Connect Rest Extension Plugin issue with Class Loader - posted by "Magesh kumar Nandakumar (JIRA)" <ji...@apache.org> on 2018/06/05 05:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6991) Connect Rest Extension Plugin issue with Class Loader - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 05:26:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6992) Configuring the batch.size to zero won't disable the batching entirely - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/05 06:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/05 07:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6993) Defective documentations for KStream/KTable methods - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2018/06/05 07:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6993) Fix defective documentations for KStream/KTable methods - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2018/06/05 07:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6993) Fix defective documentations for KStream/KTable methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 07:45:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2018/06/05 09:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2018/06/05 09:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/05 09:57:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-5940) kafka-delete-records.sh doesn't give any feedback when the JSON offset configuration file is invalid - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/05 10:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6972) Kafka ACL does not work expected with wildcard - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/05 10:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/05 10:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6982) java.lang.ArithmeticException: / by zero - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/05 10:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3665) Default ssl.endpoint.identification.algorithm should be https - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 11:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6750) Add listener name to AuthenticationContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 12:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6995) Make config "internal.leave.group.on.close" public - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/06/05 15:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6996) ConsumerGroupCommand.scala uses deprecated components - posted by "Zeynep Arikoglu (JIRA)" <ji...@apache.org> on 2018/06/05 15:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6996) ConsumerGroupCommand.scala uses deprecated components - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/05 15:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6995) Make config "internal.leave.group.on.close" public - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/06/05 17:03:00 UTC, 9 replies.
- [jira] [Updated] (KAFKA-6995) Make config "internal.leave.group.on.close" public - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/05 18:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6986) Export Admin Client metrics through Stream Threads - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/05 18:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6704) Checking hasNext from SegementIterator could throw InvalidStateStoreException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 18:50:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6995) Make config "internal.leave.group.on.close" public - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/05 18:57:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6991) Connect Rest Extension Plugin issue with Class Loader - posted by "Magesh kumar Nandakumar (JIRA)" <ji...@apache.org> on 2018/06/05 19:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6997) Kafka run class doesn't exclude test-sources jar - posted by "Magesh kumar Nandakumar (JIRA)" <ji...@apache.org> on 2018/06/05 19:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6997) Kafka run class doesn't exclude test-sources jar - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 19:59:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6730) Simplify state store recovery - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 20:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6730) Simplify state store recovery - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/05 20:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6983) Error while deleting segments - The process cannot access the file because it is being used by another process - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 20:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/05 21:00:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-6972) Kafka ACL does not work expected with wildcard - posted by "Soyee Deng (JIRA)" <ji...@apache.org> on 2018/06/05 21:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4453) add request prioritization - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/06/05 21:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/05 22:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6999) Document read-write lock usage of caching enabled stores - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/05 22:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/05 22:54:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/05 22:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/05 22:54:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/05 23:09:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7000) KafkaConsumer.position should wait for assignment metadata - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/05 23:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6997) Kafka run class doesn't exclude test-sources jar - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/05 23:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6919) Trogdor documentation points to wrong location for trogdor.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 23:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7000) KafkaConsumer.position should wait for assignment metadata - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 23:38:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7000) KafkaConsumer.position should wait for assignment metadata - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/05 23:39:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6786) Remove additional configs in StreamsBrokerDownResilienceTest - posted by "Abhishek Sharma (JIRA)" <ji...@apache.org> on 2018/06/06 01:37:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5588) Remove deprecated new-consumer option for tools - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 03:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7001) Rename `errors.allowed.max` in Connect to `errors.tolerance` - posted by "Arjun Satish (JIRA)" <ji...@apache.org> on 2018/06/06 04:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7001) Rename errors.allowed.max property in Connect to errors.tolerance - posted by "Arjun Satish (JIRA)" <ji...@apache.org> on 2018/06/06 04:15:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7001) Rename `errors.allowed.max` in Connect to `errors.tolerance` - posted by "Arjun Satish (JIRA)" <ji...@apache.org> on 2018/06/06 04:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7002) Allow replication factor to be set via a configuration property for the Connect DLQ topic - posted by "Arjun Satish (JIRA)" <ji...@apache.org> on 2018/06/06 04:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7003) Add headers with error context in messages written to the Connect DeadLetterQueue topic - posted by "Arjun Satish (JIRA)" <ji...@apache.org> on 2018/06/06 04:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1935) Consumer should use a separate socket for Coordinator connection - posted by "Soumya Kanti Acharya (JIRA)" <ji...@apache.org> on 2018/06/06 04:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7002) Allow replication factor to be set via a configuration property for the Connect DLQ topic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 04:58:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7001) Rename errors.allowed.max property in Connect to errors.tolerance - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 04:59:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7004) Support configurable restore consumer poll timeout - posted by "Shawn Nguyen (JIRA)" <ji...@apache.org> on 2018/06/06 05:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7004) Support configurable restore consumer poll timeout - posted by "Shawn Nguyen (JIRA)" <ji...@apache.org> on 2018/06/06 05:10:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-1935) Consumer should use a separate socket for Coordinator connection - posted by "Soumya Kanti Acharya (JIRA)" <ji...@apache.org> on 2018/06/06 05:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5434) Console consumer hangs if not existing partition is specified - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 06:34:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception - posted by "Grégory R. (JIRA)" <ji...@apache.org> on 2018/06/06 08:18:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-6919) Trogdor documentation points to wrong location for trogdor.sh - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/06 10:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6726) KIP-277 - Fine Grained ACL for CreateTopics API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 10:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6726) KIP-277 - Fine Grained ACL for CreateTopics API - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/06 11:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6445) Remove deprecated metrics in 2.0 - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5638) Inconsistency in consumer group related ACLs - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5214) Re-add KafkaAdminClient#apiVersions - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4693) Consumer subscription change during rebalance causes exception - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4640) Improve Streams unit test coverage - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:54:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:57:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-6841) Add support for Prefixed ACLs - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/06 11:57:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:58:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 11:58:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5876) IQ should throw different exceptions for different errors - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5637) Document compatibility and release policies - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5276) Support derived and prefixed configs in DescribeConfigs (KIP-133) - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5029) cleanup javadocs and logging - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5272) Improve validation for Alter Configs (KIP-133) - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3096) Leader is not set to -1 when it is shutdown if followers are down - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3866) KerberosLogin refresh time bug and other improvements - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6912) Add authorization tests for custom principal types - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6835) Enable topic unclean leader election to be enabled without controller change - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6863) Kafka clients should try to use multiple DNS resolved IP addresses if the first one fails - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:12:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6874) Add Configuration Allowing for Optional Topology Optimization - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion() - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3143) inconsistent state in ZK when all replicas are dead - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6761) Reduce Kafka Streams Footprint - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6877) Remove completedFetch upon a failed parse if it contains no records. - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5255) Auto generate request/response classes - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6836) Upgrade metrics library - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:18:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5023) Remove cyclic dependency between record and protocol packages - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5022) Improve CRC tests so that we verify which fields are included in the CRC - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:19:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5270) TransactionManager should send and `AddOffsetsToTxn` request only once per group per transaction - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6415) KafkaLog4jAppender deadlocks when logging from producer network thread - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5661) Develop and understanding of how to tune transactions for optimal performance - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5795) Make the idempotent producer the default producer setting - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2 - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5383) Additional Test Cases for ReplicaManager - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6509) Add additional tests for validating store restoration completes before Topology is intitalized - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5682) Consumer should include partition in exceptions raised during record parsing/validation - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5480) Partition Leader may not be elected although there is one live replica in ISR - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5284) Add tools and metrics to diagnose problems with the idempotent producer and transactions - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6508) Look into optimizing StreamPartitionAssignor StandbyTask Assignment - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:24:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4487) Tests should be run in Jenkins with INFO or DEBUG level - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6463) Review logging level for user errors in AdminManager - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5780) Long shutdown time when updated to 0.11.0 - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5606) Review consumer's RequestFuture usage pattern - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5482) A CONCURRENT_TRANASCTIONS error for the first AddPartitionsToTxn request slows down transactions significantly - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5356) Producer with transactionalId should be able to send outside of a transaction - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6809) connections-created metric does not behave as expected - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:26:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6276) AdminClient may leave some futures hanging after shutdown - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6045) All access to log should fail if log is closed - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5945) Improve handling of authentication failures when credentials are removed - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5729) Consumer should verify offset commits are from assigned partitions - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5451) Kafka Connect should scan classpath asynchronously - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6124) Revisit default config for internal client with regard to resilience - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5026) DebuggingConsumerId and DebuggingMessageFormatter and message format v2 - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5857) Excessive heap usage on controller node during reassignment - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3135) Unexpected delay before fetch response transmission - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5041) Kafka TestKit library - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5025) FetchRequestTest should use batches with more than one message - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5030) Suggested clean-ups from message format V2 review - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5286) Producer should await transaction completion in close - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5204) Connect needs to validate Connector type during instantiation - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6304) The controller should allow updating the partition reassignment for the partitions being reassigned - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens. - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6438) NSEE while concurrently creating and deleting a topic - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5116) Controller updates to ISR holds the controller lock for a very long time - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5955) Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5478) TransactionsTest.testFencingOnAddPartitions Timeout - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5950) AdminClient should retry based on returned error codes - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5601) Refactor ReassignPartitionsCommand to use AdminClient - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5883) Run tests on Java 9 with –illegal-access=deny - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4928) Add integration test for DumpLogSegments - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 12:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7005) Remove duplicate Java Resource class. - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/06 13:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7006) Remove duplicate Scala ResourceNameType class. - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/06 13:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7006) Remove duplicate Scala ResourceNameType class - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/06 13:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7007) All ACL changes should use single /kafka-acl-changes path - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/06 13:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7008) Consider replacing the Resource field in AclBinding with a ResourceFilter or ResourceMatcher. - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/06 13:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7008) Consider replacing the Resource field in AclBinding with a ResourceFilter or ResourceMatcher - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/06 13:24:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:45:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-6546) Add ENDPOINT_NOT_FOUND_ON_LEADER error code for missing listener - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1120) Controller could miss a broker state change - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6784) FindCoordinatorResponse cannot be cast to FetchResponse - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5736) Improve error message in Connect when all kafka brokers are down - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5543) We don't remove the LastStableOffsetLag metric when a partition is moved away from a broker - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5347) OutOfSequence error should be fatal - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5527) Idempotent/transactional Producer part 2 (KIP-98) - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5235) GetOffsetShell: retrieve offsets for all given topics and partitions with single request to the broker - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5964) Add more unit tests for SslTransportLayer - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5834) AbstractConfig.logUnused() may log confusing warning information. - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5782) Avoid unnecessary PID reset when expire batches. - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5234) GetOffsetShell: retrieve offsets for multiple topics with single request - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:53:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6648) Fetcher.getTopicMetadata() only returns "healthy" partitions, not all - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:56:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5887) Enable findBugs (or equivalent) when building with Java 9 - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4934) Add streams test with RocksDb failures - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 13:58:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 14:00:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-6950) Add mechanism to delay response to failed client authentication - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/06 14:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7009) Mute logger for reflections.org at the warn level in system tests - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/06/06 14:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7009) Mute logger for reflections.org at the warn level in system tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 14:25:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7006) Remove duplicate Scala ResourceNameType class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 15:29:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7010) Rename ResourceNameType.ANY to MATCH - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/06 15:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient - posted by "Attila Sasvari (JIRA)" <ji...@apache.org> on 2018/06/06 16:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7011) Investigate if its possible to drop the ResourceNameType field from Java Resource class. - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/06 16:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7011) Investigate if its possible to drop the ResourceNameType field from Java Resource class. - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/06 16:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7011) Investigate if its possible to drop the ResourceNameType field from Java Resource class. - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/06 16:08:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6739) Down-conversion fails for records with headers - posted by "Christian Becker (JIRA)" <ji...@apache.org> on 2018/06/06 16:13:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1 - posted by "rajadayalan perumalsamy (JIRA)" <ji...@apache.org> on 2018/06/06 18:15:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6739) Down-conversion fails for records with headers - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/06 18:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1 - posted by "praveen (JIRA)" <ji...@apache.org> on 2018/06/06 18:44:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1 - posted by "corey Kasten (JIRA)" <ji...@apache.org> on 2018/06/06 19:37:00 UTC, 32 replies.
- [jira] [Resolved] (KAFKA-6993) Fix defective documentations for KStream/KTable methods - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/06 19:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5510) Streams should commit all offsets regularly - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/06 20:32:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7004) Support configurable restore consumer poll timeout - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/06 21:05:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6967) TopologyTestDriver does not allow pre-populating state stores that have change logging - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 22:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7013) Do Infer analysis and investigate results - posted by "Koen De Groote (JIRA)" <ji...@apache.org> on 2018/06/06 22:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6935) KIP-295 Add Streams Config for Optional Optimization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 01:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7014) Guarantee the byte buffer returned by Serializer is reusable - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/07 02:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1 - posted by "rajadayalan perumalsamy (JIRA)" <ji...@apache.org> on 2018/06/07 03:33:00 UTC, 8 replies.
- [jira] [Commented] (KAFKA-6538) Enhance ByteStore exceptions with more context information - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 03:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6538) Enhance ByteStore exceptions with more context information - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/07 03:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7015) Enhance RecordCollectorImpl exceptions with more context information - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/07 03:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6538) Enhance ByteStore exceptions with more context information - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/07 03:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close() - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/07 04:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7016) Reconsider the "avoid the expensive and useless stack trace for api exceptions" practice - posted by "Martin Vysny (JIRA)" <ji...@apache.org> on 2018/06/07 06:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7016) Reconsider the "avoid the expensive and useless stack trace for api exceptions" practice - posted by "Martin Vysny (JIRA)" <ji...@apache.org> on 2018/06/07 06:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7003) Add headers with error context in messages written to the Connect DeadLetterQueue topic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 07:24:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7017) GroupCoordinator response error: Broker: Group coordinator not available - posted by "Sampath Kumar (JIRA)" <ji...@apache.org> on 2018/06/07 07:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5924) Add the compose method to the Kafka Stream API - posted by "Laurent T (JIRA)" <ji...@apache.org> on 2018/06/07 07:59:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5924) Add the compose method to the Kafka Stream API - posted by "Laurent T (JIRA)" <ji...@apache.org> on 2018/06/07 08:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position() - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/07 08:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6631) Kafka Streams - Rebalancing exception in Kafka 1.0.0 - posted by "Deepak Goyal (JIRA)" <ji...@apache.org> on 2018/06/07 11:03:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7011) Investigate if its possible to drop the ResourceNameType field from Java Resource class. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 14:32:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6984) Question - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/07 17:18:01 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1 - posted by "rajadayalan perumalsamy (JIRA)" <ji...@apache.org> on 2018/06/07 17:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6547) group offset reset and begin_offset ignored/no effect - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/07 17:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1 - posted by "rajadayalan perumalsamy (JIRA)" <ji...@apache.org> on 2018/06/07 18:30:00 UTC, 8 replies.
- [jira] [Created] (KAFKA-7018) persist memberId for consumer restart - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/06/07 18:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/07 19:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7019) Reduction the contention between metadata update and metadata read operation - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/07 19:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7019) Reduction the contention between metadata update and metadata read operation - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/07 19:44:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7007) All ACL changes should use single /kafka-acl-changes path - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 20:45:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7008) Consider replacing the Resource field in AclBinding with a ResourceFilter or ResourceMatcher - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/07 20:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7008) Consider replacing the Resource field in AclBinding with a ResourceFilter or ResourceMatcher - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/07 20:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7020) Error while renaming dir for topic_XXX in log dir YYY - posted by "wade wu (JIRA)" <ji...@apache.org> on 2018/06/07 22:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7020) Error while renaming dir for topic_XXX in log dir YYY - posted by "wade wu (JIRA)" <ji...@apache.org> on 2018/06/07 22:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7020) Error when deleting topic with access denied exception - posted by "wade wu (JIRA)" <ji...@apache.org> on 2018/06/07 23:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7020) Error when deleting topic with access denied exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 23:19:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-7021) Source KTable checkpoint is not correct - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/07 23:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7011) Investigate if its possible to drop the ResourceNameType field from Java Resource class. - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/06/07 23:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7018) persist memberId for consumer restart - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/08 00:18:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-7022) Setting a very small segment.bytes can cause ReplicaFetcher threads to crash and in turn an unhealthy cluster due to under-replicated partitions - posted by "Koelli Mungee (JIRA)" <ji...@apache.org> on 2018/06/08 02:03:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7022) Setting segment.bytes for a topic too small can cause ReplicaFetcher thread crash and in turn an unhealthy cluster due to under-replicated partitions - posted by "Koelli Mungee (JIRA)" <ji...@apache.org> on 2018/06/08 02:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7023) Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2018/06/08 02:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7023) Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2018/06/08 02:17:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-7023) Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2018/06/08 02:29:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6953) [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure) - posted by "Flavio Stutz (JIRA)" <ji...@apache.org> on 2018/06/08 03:18:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-2445) Failed test: kafka.producer.ProducerTest > testSendWithDeadBroker FAILED - posted by "Jimin Hsieh (JIRA)" <ji...@apache.org> on 2018/06/08 05:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2445) Failed test: kafka.producer.ProducerTest > testSendWithDeadBroker FAILED - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/08 05:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6934) Csv reporter doesn't work for ConsoleConsumer - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2018/06/08 08:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7022) Setting a very small segment.bytes can cause ReplicaFetcher threads to crash and in turn an unhealthy cluster due to under-replicated partitions - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/08 09:00:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2260) Allow specifying expected offset on produce - posted by "Sven Linstaedt (JIRA)" <ji...@apache.org> on 2018/06/08 09:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce - posted by "Sven Linstaedt (JIRA)" <ji...@apache.org> on 2018/06/08 10:11:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6291) Cannot close EmbeddedZookeeper on Windows - posted by "Kamil Bar (JIRA)" <ji...@apache.org> on 2018/06/08 12:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6946) Keep the session id for incremental fetch when fetch responses are throttled - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/08 12:37:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7024) Rocksdb state directory should be created before opening the DB - posted by "Abhishek Agarwal (JIRA)" <ji...@apache.org> on 2018/06/08 12:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7025) Android client support - posted by "Martin Vysny (JIRA)" <ji...@apache.org> on 2018/06/08 13:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time - posted by "Michael Hartle (JIRA)" <ji...@apache.org> on 2018/06/08 14:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7015) Enhance RecordCollectorImpl exceptions with more context information - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/06/08 14:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7006) Remove duplicate Scala ResourceNameType class - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/06/08 15:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/08 15:41:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7022) Setting a very small segment.bytes can cause ReplicaFetcherThread to crash and in turn an unhealthy cluster due to under-replicated partitions - posted by "Koelli Mungee (JIRA)" <ji...@apache.org> on 2018/06/08 16:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7022) Setting a very small segment.bytes can cause ReplicaFetcherThread to crash and in turn high number of under-replicated partitions - posted by "Koelli Mungee (JIRA)" <ji...@apache.org> on 2018/06/08 16:39:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7023) Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/08 17:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/08 17:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/08 17:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7022) Setting a very small segment.bytes can cause ReplicaFetcherThread to crash and in turn high number of under-replicated partitions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/08 20:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7010) Rename ResourceNameType.ANY to MATCH - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/08 20:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/06/08 21:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7027) Overloaded StreamsBuilder Build Method to Accept java.util.Properties - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/06/08 22:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7027) Overloaded StreamsBuilder Build Method to Accept java.util.Properties - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/06/08 22:11:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4381) Add per partition lag metric to KafkaConsumer. - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/08 23:51:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-4381) Add per partition lag metric to KafkaConsumer. - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/08 23:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6840) support windowing in ktable API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/09 00:12:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/06/09 00:12:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/09 00:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7028) super.users doesn't work with custom principals - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/09 03:55:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6502) Kafka streams deserialization handler not committing offsets on error records - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/06/09 06:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6574) Support Headers in console-consumer and console-producer - posted by "Alexander Abramov (JIRA)" <ji...@apache.org> on 2018/06/09 10:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7028) super.users doesn't work with custom principals - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/09 13:26:00 UTC, 9 replies.
- [jira] [Commented] (KAFKA-7029) ReplicaVerificationTool should not use the deprecated SimpleConsumer - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/09 17:23:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7029) ReplicaVerificationTool should not use the deprecated SimpleConsumer - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/09 17:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7030) Add configuration to disable message down-conversion - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/09 17:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7029) ReplicaVerificationTool should not use the deprecated SimpleConsumer - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/09 17:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6971) Passing in help flag to kafka-console-producer should print arg options - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/09 19:08:00 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-7028) super.users doesn't work with custom principals - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/09 22:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7031) Kafka Connect API module depends on Jersey - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/06/10 15:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7031) Kafka Connect API module depends on Jersey - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/06/10 15:41:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6889) Fix Streams system test to only specify used log files - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/10 15:50:00 UTC, 8 replies.
- [jira] [Comment Edited] (KAFKA-7031) Kafka Connect API module depends on Jersey - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/06/10 16:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6964) Add ability to print all internal topic names - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/06/11 06:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7032) The TimeUnit is neglected by KakfaConsumer#close(long, TimeUnit) - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/11 06:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7032) The TimeUnit is neglected by KakfaConsumer#close(long, TimeUnit) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 06:50:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7032) The TimeUnit is neglected by KakfaConsumer#close(long, TimeUnit) - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/11 06:58:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6948) Avoid overflow in timestamp comparison - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 08:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7033) Modify AbstractOptions's timeoutMs as Long type - posted by "darion yaphet (JIRA)" <ji...@apache.org> on 2018/06/11 09:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7033) Modify AbstractOptions's timeoutMs as Long type - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/11 09:33:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6949) alterReplicaLogDirs() should grab partition lock when accessing log of the future replica - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/11 09:43:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-7034) Remove the duplicated listTopics from Consumer - posted by "darion yaphet (JIRA)" <ji...@apache.org> on 2018/06/11 09:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6697) JBOD configured broker should not die if log directory is invalid - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/11 09:44:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6780) log cleaner shouldn't clean messages beyond high watermark - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/11 09:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5905) Remove PrincipalBuilder and DefaultPrincipalBuilder - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/11 09:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91) - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/11 09:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3438) Rack Aware Replica Reassignment should warn of overloaded brokers - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/11 09:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5914) Return MessageFormatVersion and MessageMaxBytes in MetadataResponse - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/11 09:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6800) Update documentation for SASL/PLAIN and SCRAM to use callbacks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 10:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7035) Kafka Processor's init() method sometimes is not called - posted by "Oleksandr Konopko (JIRA)" <ji...@apache.org> on 2018/06/11 10:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7035) Kafka Processor's init() method sometimes is not called - posted by "Oleksandr Konopko (JIRA)" <ji...@apache.org> on 2018/06/11 10:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7036) Complete the docs of KafkaConsumer#poll - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/11 10:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created - posted by "Sampath Kumar (JIRA)" <ji...@apache.org> on 2018/06/11 11:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6964) Add ability to print all internal topic names - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/06/11 11:51:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-7037) Kafka doesn't allow to delete topic with '+' in the name - posted by "Sandeep Nemuri (JIRA)" <ji...@apache.org> on 2018/06/11 11:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7037) Kafka doesn't allow to delete topic with '+' in the name - posted by "Sandeep Nemuri (JIRA)" <ji...@apache.org> on 2018/06/11 11:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7037) Kafka doesn't allow to delete topic with '+' in the name - posted by "Sandeep Nemuri (JIRA)" <ji...@apache.org> on 2018/06/11 12:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7005) Remove duplicate Java Resource class. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 12:19:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion - posted by "Sandeep Nemuri (JIRA)" <ji...@apache.org> on 2018/06/11 12:22:00 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion - posted by "Sandeep Nemuri (JIRA)" <ji...@apache.org> on 2018/06/11 12:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3575) Use console consumer access topic that does not exist, can not use "Control + C" to exit process - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3733) Avoid long command lines by setting CLASSPATH in environment - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4126) No relevant log when the topic is non-existent - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4931) stop script fails due 4096 ps output limit - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5359) Exceptions from RequestFuture lack parts of the stack trace - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5517) Support linking to particular configuration parameters - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6448) Mx4jLoader#props.getBoolean("kafka_mx4jenable", false) conflict with the annotation - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3999) Consumer bytes-fetched metric uses decompressed message size - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4893) async topic deletion conflicts with max topic length - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool. - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4203) Java producer default max message size does not align with broker default - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4249) Document how to customize GC logging options for broker - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4307) Inconsistent parameters between console producer and consumer - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4862) Kafka client connect to a shutdown node will block for a long time - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5403) Transactions system test should dedup consumed messages by offset - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 13:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5952) Refactor Consumer Fetcher metrics - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 14:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer) - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 14:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4850) RocksDb cannot use Bloom Filters - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 14:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4808) send of null key to a compacted topic should throw error back to user - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 14:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4701) Allow kafka brokers to dynamically reload truststore without restarting. - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 14:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3190) KafkaProducer should not invoke callback in send() - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 14:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 14:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active (KIP-211) - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 14:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/11 14:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6788) Grouping consumer requests per consumer coordinator in admin client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 15:28:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-7038) Support AdminClient Example - posted by "darion yaphet (JIRA)" <ji...@apache.org> on 2018/06/11 16:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6889) Fix Streams system test to only specify used log files - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/11 16:17:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-6860) NPE when reinitializeStateStores with eos enabled - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/11 16:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6860) NPE when reinitializeStateStores with eos enabled - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/11 16:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7035) Kafka Processor's init() method sometimes is not called - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/11 17:18:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-6946) Keep the session id for incremental fetch when fetch responses are throttled - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/11 17:53:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/06/11 17:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6546) Add ENDPOINT_NOT_FOUND_ON_LEADER error code for missing listener - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 18:17:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7039) DelegatingClassLoader creates plugin instance even if its not Versioned - posted by "Magesh kumar Nandakumar (JIRA)" <ji...@apache.org> on 2018/06/11 18:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7039) DelegatingClassLoader creates plugin instance even if its not Versioned - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 19:05:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread - posted by "Eugen Feller (JIRA)" <ji...@apache.org> on 2018/06/11 19:09:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data - posted by "Eugen Feller (JIRA)" <ji...@apache.org> on 2018/06/11 20:14:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/06/11 20:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7030) Add configuration to disable message down-conversion - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 20:28:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7005) Remove duplicate Java Resource class. - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/06/11 20:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 21:02:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/11 21:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7024) Rocksdb state directory should be created before opening the DB - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/11 21:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7042) Fall back to the old behavior when the broker is too old to recognize LIST_OFFSET versions - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/11 21:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7042) Fall back to the old behavior when the broker is too old to recognize LIST_OFFSET versions - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/11 21:13:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/11 21:15:00 UTC, 8 replies.
- [jira] [Comment Edited] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/11 21:15:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7043) Connect isolation whitelist does not include new primitive converters (KIP-305) - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/06/11 21:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 21:41:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5570) Join request's timeout should be slightly higher than the rebalance timeout - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 22:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7003) Add headers with error context in messages written to the Connect DeadLetterQueue topic - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/11 22:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7021) Source KTable checkpoint is not correct - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 23:09:00 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/11 23:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors - posted by "Jeff Field (JIRA)" <ji...@apache.org> on 2018/06/12 01:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/06/12 01:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6966) Extend `TopologyDescription.Sink` to return `TopicNameExtractor` - posted by "Nishanth Pradeep (JIRA)" <ji...@apache.org> on 2018/06/12 01:51:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/12 01:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/12 01:54:00 UTC, 8 replies.
- [jira] [Commented] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/12 01:58:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6966) Extend `TopologyDescription.Sink` to return `TopicNameExtractor` - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/12 01:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7043) Connect isolation whitelist does not include new primitive converters (KIP-305) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 02:14:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6881) Kafka 1.1 Broker version crashes when deleting log - posted by "xiaojing zhou (JIRA)" <ji...@apache.org> on 2018/06/12 05:03:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6806) Unable to validate sink connectors without "topics" component which is not required - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/12 06:41:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-6631) Kafka Streams - Rebalancing exception in Kafka 1.0.0 - posted by "Ashish Surana (JIRA)" <ji...@apache.org> on 2018/06/12 07:48:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6976) Kafka Streams instances going in to DEAD state - posted by "Ashish Surana (JIRA)" <ji...@apache.org> on 2018/06/12 07:48:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-7029) ReplicaVerificationTool should not use the deprecated SimpleConsumer - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/12 07:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7029) ReplicaVerificationTool should not use the deprecated SimpleConsumer - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/12 07:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6562) KIP-255: OAuth Authentication via SASL/OAUTHBEARER - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 09:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader - posted by "Frank Lyaruu (JIRA)" <ji...@apache.org> on 2018/06/12 09:07:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6351) libs directory has duplicate javassist jars - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 09:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6351) libs directory has duplicate javassist jars - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/12 09:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4690) IllegalStateException using DeleteTopicsRequest when delete.topic.enable=false - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/12 11:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6801) Restrict Consumer to fetch data from secure port only, and deny from non-secure port. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/12 11:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2572) zk connection instability - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/12 14:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7046) Support new Admin API for single topic - posted by "darion yaphet (JIRA)" <ji...@apache.org> on 2018/06/12 14:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3379) Update tools relying on old producer to use new producer. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/12 15:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7038) Support AdminClient Example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 15:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6761) Reduce Kafka Streams Footprint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 15:24:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-1181) Consolidate brokerList and topicPartitionInfo in BrokerPartitionInfo - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/12 16:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2550) [Kafka][0.8.2.1][Performance]When there are a lot of partition under a Topic, there are serious performance degradation. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/12 16:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7047) Connect isolation whitelist does not include SimpleHeaderConverter - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/06/12 16:27:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/12 16:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7048) NPE when creating >1 connectors - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/12 16:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7048) NPE when creating connector - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/12 16:42:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7048) NPE when creating connector - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/12 16:53:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/12 17:26:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-6747) kafka-streams Invalid transition attempted from state READY to state ABORTING_TRANSACTION - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/12 17:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6976) Kafka Streams instances going in to DEAD state - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/12 18:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7049) InternalTopicIntegrationTest sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/12 18:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7050) Decrease consumer request timeout to 30s - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/12 18:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7050) Decrease consumer request timeout to 30s - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 18:44:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6782) GlobalKTable GlobalStateStore never finishes restoring when consuming aborted messages - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 18:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7050) Decrease consumer request timeout to 30s - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/12 19:02:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6782) GlobalKTable GlobalStateStore never finishes restoring when consuming aborted messages - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/12 19:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException - posted by "Eugen Feller (JIRA)" <ji...@apache.org> on 2018/06/12 19:10:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException - posted by "Eugen Feller (JIRA)" <ji...@apache.org> on 2018/06/12 19:11:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/06/12 20:27:00 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-6782) GlobalKTable GlobalStateStore never finishes restoring when consuming aborted messages - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/12 20:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7047) Connect isolation whitelist does not include SimpleHeaderConverter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 20:59:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7007) Use JSON for /kafka-acl-extended-changes path - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/06/12 22:10:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7007) Use JSON for /kafka-acl-extended-changes path - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/06/12 22:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7010) Rename ResourceNameType.ANY to MATCH - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/12 22:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7010) Rename ResourceNameType.ANY to MATCH - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 22:42:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7051) Improve the efficiency of the ReplicaManager when there are many partitions - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/06/12 22:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7051) Improve the efficiency of the ReplicaManager when there are many partitions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 23:00:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7051) Improve the efficiency of the ReplicaManager when there are many partitions - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/12 23:38:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7049) InternalTopicIntegrationTest sometimes fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/13 00:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/13 00:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6634) Delay initiating the txn on producers until initializeTopology with EOS turned on - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/13 00:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/13 02:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7043) Connect isolation whitelist does not include new primitive converters (KIP-305) - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/13 04:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/13 04:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7031) Kafka Connect API module depends on Jersey - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/13 05:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7009) Mute logger for reflections.org at the warn level in system tests - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/13 05:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7052) ExtractField SMT throws NPE - needs clearer error message - posted by "Robin Moffatt (JIRA)" <ji...@apache.org> on 2018/06/13 08:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7053) Spring Kafka SSL producers throwing TimeoutExceptions - posted by "Guido Josquin (JIRA)" <ji...@apache.org> on 2018/06/13 09:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7053) Spring Kafka SSL producers throwing TimeoutExceptions - posted by "Guido Josquin (JIRA)" <ji...@apache.org> on 2018/06/13 09:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7052) ExtractField SMT throws NPE - needs clearer error message - posted by "Robin Moffatt (JIRA)" <ji...@apache.org> on 2018/06/13 09:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception. - posted by "Manohar Vanam (JIRA)" <ji...@apache.org> on 2018/06/13 09:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception. - posted by "Manohar Vanam (JIRA)" <ji...@apache.org> on 2018/06/13 09:35:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception. - posted by "Manohar Vanam (JIRA)" <ji...@apache.org> on 2018/06/13 09:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime - posted by "Meghana Gupta (JIRA)" <ji...@apache.org> on 2018/06/13 09:57:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4113) Allow KTable bootstrap - posted by "Ben Stopford (JIRA)" <ji...@apache.org> on 2018/06/13 10:12:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent - posted by "Nikki Thean (JIRA)" <ji...@apache.org> on 2018/06/13 14:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent - posted by "Nikki Thean (JIRA)" <ji...@apache.org> on 2018/06/13 14:14:00 UTC, 9 replies.
- [jira] [Updated] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent - posted by "Nikki Thean (JIRA)" <ji...@apache.org> on 2018/06/13 14:16:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-7007) Use JSON for /kafka-acl-extended-changes path - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/13 15:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/13 16:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7056) Connect's new numeric converters should be in a different package - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/06/13 16:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7056) Connect's new numeric converters should be in a different package - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/06/13 16:43:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4113) Allow KTable bootstrap - posted by "Ben Stopford (JIRA)" <ji...@apache.org> on 2018/06/13 16:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 17:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/13 17:57:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/06/13 19:59:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6749) TopologyTestDriver fails when topoloy under test uses EXACTLY_ONCE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 21:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6978) Make Streams Window retention time strict - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 23:05:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7050) Decrease consumer request timeout to 30s - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/13 23:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5235) GetOffsetShell: retrieve offsets for all given topics and partitions with single request to the broker - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/14 00:40:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7019) Reduction the contention between metadata update and metadata read operation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 02:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7056) Connect's new numeric converters should be in a different package - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 03:38:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/14 04:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5234) GetOffsetShell: retrieve offsets for multiple topics with single request - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/14 04:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 07:18:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5479) Docs for authorization omit authorizer.class.name - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 07:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6780) log cleaner shouldn't clean messages beyond high watermark - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 07:20:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5445) Document exceptions thrown by AdminClient methods - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 07:22:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 07:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6648) Fetcher.getTopicMetadata() only returns "healthy" partitions, not all - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 07:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6897) Mirrormaker waits to shut down forever on produce failure with abort.on.send.failure=true - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 07:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6342) Move workaround for JSON parsing of non-escaped strings - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 07:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6684) Support casting values with bytes schema to string - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 07:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6805) Allow dynamic broker configs to be configured in ZooKeeper before starting broker - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 08:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7028) super.users doesn't work with custom principals - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 08:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7039) DelegatingClassLoader creates plugin instance even if its not Versioned - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 08:10:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-6806) Unable to validate sink connectors without "topics" component which is not required - posted by "Ivan Majnarić (JIRA)" <ji...@apache.org> on 2018/06/14 08:23:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4812) We are facing the same issue as SAMZA-590 for kafka - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/14 08:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7057) Consumer stop polling - posted by "Moshe Lavi (JIRA)" <ji...@apache.org> on 2018/06/14 08:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7057) Consumer stop polling - posted by "Moshe Lavi (JIRA)" <ji...@apache.org> on 2018/06/14 08:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values - posted by "Gunnar Morling (JIRA)" <ji...@apache.org> on 2018/06/14 10:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values - posted by "Gunnar Morling (JIRA)" <ji...@apache.org> on 2018/06/14 10:14:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values - posted by "Gunnar Morling (JIRA)" <ji...@apache.org> on 2018/06/14 10:14:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-7015) Enhance RecordCollectorImpl exceptions with more context information - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 10:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/14 11:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7059) Offer new constructor on ProducerRecord - posted by "Matthias Weßendorf (JIRA)" <ji...@apache.org> on 2018/06/14 14:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7059) Offer new constructor on ProducerRecord - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 14:53:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6806) Unable to validate sink connectors without "topics" component which is not required - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/06/14 15:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6583) Metadata should include number of state stores for task - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/06/14 15:32:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6583) Metadata should include number of state stores for task - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/06/14 15:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/14 15:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4696) Streams standby task assignment should be state-store aware - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/06/14 16:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4237) Avoid long request timeout for the consumer - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/14 17:43:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6982) java.lang.ArithmeticException: / by zero - posted by "Martin M (JIRA)" <ji...@apache.org> on 2018/06/14 17:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4237) Avoid long request timeout for the consumer - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/14 17:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2837) FAILING TEST: kafka.api.ProducerBounceTest > testBrokerFailure - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/14 17:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7010) Rename ResourceNameType.ANY to MATCH - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/06/14 20:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/14 22:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char - posted by "Ahmed Al-Mehdi (JIRA)" <ji...@apache.org> on 2018/06/14 23:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7060) Command-line overrides for ConnectDistributed worker properties - posted by "Kevin Lafferty (JIRA)" <ji...@apache.org> on 2018/06/14 23:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7060) Command-line overrides for ConnectDistributed worker properties - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/15 00:01:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/15 03:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/15 05:18:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5950) AdminClient should retry based on returned error codes - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/15 05:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6445) Remove deprecated metrics in 2.0 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/15 05:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/15 06:19:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/15 06:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4686) Null Message payload is shutting down broker - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/15 06:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6083) The Fetcher should add the InvalidRecordException as a cause to the KafkaException when invalid record is found. - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/15 06:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5975) No response when deleting topics and delete.topic.enable=false - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/15 06:25:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/15 06:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7061) Enhanced log compaction - posted by "Luis Cabral (JIRA)" <ji...@apache.org> on 2018/06/15 08:32:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7048) NPE when creating connector - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/15 14:13:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/15 14:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/15 14:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7063) Update documentation to remove references to old producers and consumers - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/15 14:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support - posted by "Andras Beni (JIRA)" <ji...@apache.org> on 2018/06/15 14:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7060) Command-line overrides for ConnectDistributed worker properties - posted by "Kevin Lafferty (JIRA)" <ji...@apache.org> on 2018/06/15 14:55:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7021) Source KTable checkpoint is not correct - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/15 15:34:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1013) Modify existing tools as per the changes in KAFKA-1000 - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 15:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2546) CPU utilization very high when no kafka node alive - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 15:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-966) Allow high level consumer to 'nak' a message and force Kafka to close the KafkaStream without losing that message - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 15:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4967) java.io.EOFException Error while committing offsets - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 15:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3798) Kafka Consumer 0.10.0.0 killed after rebalancing exception - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 15:49:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7063) Update documentation to remove references to old producers and consumers - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 17:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-796) Kafka Scala classes should declare thrown checked exceptions to be Java friendly - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 17:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-857) kafka.admin.ListTopicCommand, 'by broker' display/filter - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 17:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1942) ConsumerGroupCommand does not show offset information in ZK for deleted topic - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 17:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2537) Mirrormaker defaults to localhost with no sanity checks - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 18:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2584) SecurityProtocol enum validation should be removed or relaxed for non-config usages - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 18:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3057) "Checking consumer position" docs are referencing (only) deprecated ConsumerOffsetChecker - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 18:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3150) kafka.tools.UpdateOffsetsInZK not work (sasl enabled) - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 18:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4196) Transient test failure: DeleteConsumerGroupTest.testConsumptionOnRecreatedTopicAfterTopicWideDeleteInZK - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 18:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 18:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4723) offsets.storage=kafka - groups stuck in rebalancing with committed offsets - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 18:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5408) Using the ConsumerRecord instead of BaseConsumerRecord in the ConsoleConsumer - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 19:02:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5691) ZKUtils.CreateRecursive should handle NOAUTH - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 19:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5590) Delete Kafka Topic Complete Failed After Enable Ranger Kafka Plugin - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 19:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7064) "Unexpected resource type GROUP" when describing broker configs using latest admin client - posted by "Rohan Desai (JIRA)" <ji...@apache.org> on 2018/06/15 21:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7064) "Unexpected resource type GROUP" when describing broker configs using latest admin client - posted by "Rohan Desai (JIRA)" <ji...@apache.org> on 2018/06/15 21:34:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-7064) "Unexpected resource type GROUP" when describing broker configs using latest admin client - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/15 21:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7064) "Unexpected resource type GROUP" when describing broker configs using latest admin client - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/15 21:35:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-7056) Connect's new numeric converters should be in a different package - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/15 21:54:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/06/15 22:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5857) Excessive heap usage on controller node during reassignment - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/16 05:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6933) Broker reports Corrupted index warnings apparently infinitely - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/16 05:17:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7065) Quickstart tutorial fails because of missing brokers - posted by "Holger Brandl (JIRA)" <ji...@apache.org> on 2018/06/16 08:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7066) Make Streams Runtime Error User Friendly in Case of Serialisation exception - posted by "Stephane Maarek (JIRA)" <ji...@apache.org> on 2018/06/16 08:56:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7066) Make Streams Runtime Error User Friendly in Case of Serialisation exception - posted by "Stephane Maarek (JIRA)" <ji...@apache.org> on 2018/06/16 08:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7066) Make Streams Runtime Error User Friendly in Case of Serialisation exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/16 09:03:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-7065) Quickstart tutorial fails because of missing brokers - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/16 09:13:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6708) Review Exception messages with regards to Serde Useage - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/16 16:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6708) Review Exception messages with regards to Serde Useage - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/16 16:04:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6933) Broker reports Corrupted index warnings apparently infinitely - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/16 17:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7063) Update documentation to remove references to old producers and consumers - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/16 18:18:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7063) Update documentation to remove references to old producers and consumers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/16 18:18:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7018) persist memberId for consumer restart - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/06/17 00:07:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7039) DelegatingClassLoader creates plugin instance even if its not Versioned - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/17 05:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7047) Connect isolation whitelist does not include SimpleHeaderConverter - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/17 05:37:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/17 06:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7067) ConnectRestApiTest fails assertion - posted by "Magesh kumar Nandakumar (JIRA)" <ji...@apache.org> on 2018/06/17 06:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7068) ConfigTransformer doesn't handle null values - posted by "Magesh kumar Nandakumar (JIRA)" <ji...@apache.org> on 2018/06/17 07:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7067) ConnectRestApiTest fails assertion - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/17 07:19:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7068) ConfigTransformer doesn't handle null values - posted by "Robert Yokota (JIRA)" <ji...@apache.org> on 2018/06/17 07:20:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-7068) ConfigTransformer doesn't handle null values - posted by "Robert Yokota (JIRA)" <ji...@apache.org> on 2018/06/17 07:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7068) ConfigTransformer doesn't handle null values - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/17 19:14:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7066) Make Streams Runtime Error User Friendly in Case of Serialisation exception - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/18 00:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6203) Kafka crash when deleting a topic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/18 07:10:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7065) Quickstart tutorial fails because of missing brokers - posted by "Holger Brandl (JIRA)" <ji...@apache.org> on 2018/06/18 07:32:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-7065) Quickstart tutorial fails because of missing brokers - posted by "Holger Brandl (JIRA)" <ji...@apache.org> on 2018/06/18 07:32:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6708) Review Exception messages with regards to Serde Useage - posted by "Khaireddine Rezgui (JIRA)" <ji...@apache.org> on 2018/06/18 08:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7069) AclCommand does not allow 'create' operation on 'topic' - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/18 09:02:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7069) AclCommand does not allow 'create' operation on 'topic' - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/18 09:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7069) AclCommand does not allow 'create' operation on 'topic' - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/06/18 09:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7070) KafkaConsumer#committed might unexpectedly shift consumer offset - posted by "Jan Lukavský (JIRA)" <ji...@apache.org> on 2018/06/18 16:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4061) Apache Kafka failover is not working - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/18 16:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3791) Broken tools -- need better way to get offsets and other info - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/18 16:26:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7035) Kafka Processor's init() method sometimes is not called - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/06/18 16:36:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4433) Kafka Controller Does not send a LeaderAndIsr to old leader of a topicPartition during reassignment, if the old leader is not a part of the new assigned replicas - posted by "Mayuresh Gharat (JIRA)" <ji...@apache.org> on 2018/06/18 17:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6805) Allow dynamic broker configs to be configured in ZooKeeper before starting broker - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/18 17:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7071) specify number of partitions when using repartition logic - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/06/18 17:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7071) specify number of partitions when using repartition logic - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/06/18 17:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7071) specify number of partitions when using repartition logic - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/18 18:19:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4870) A question about broker down , the server is doing partition master election,the client producer may send msg fail . How the producer deal with the situation ?? - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/18 18:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7070) KafkaConsumer#committed might unexpectedly shift consumer offset - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/06/18 19:04:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5237) SimpleConsumerShell logs terminating message to stdout instead of stderr - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/18 19:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7071) specify number of partitions when using repartition logic - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/06/18 20:53:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6037) Make Sub-topology Parallelism Tunable - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/06/18 20:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6037) Make Sub-topology Parallelism Tunable - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/06/18 20:54:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps - posted by "Collin Scangarella (JIRA)" <ji...@apache.org> on 2018/06/18 20:58:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-6942) Connect connectors api doesn't show versions of connectors - posted by "Jordan Moore (JIRA)" <ji...@apache.org> on 2018/06/18 21:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6932) Avroconverter does not propagate subjectname stratergy - posted by "Jordan Moore (JIRA)" <ji...@apache.org> on 2018/06/18 21:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7072) Kafka Streams may drop rocksb window segments before they expire - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/18 21:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7072) Kafka Streams may drop rocksb window segments before they expire - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/18 21:48:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-7067) ConnectRestApiTest fails assertion - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/18 22:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7023) Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/18 23:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6304) The controller should allow updating the partition reassignment for the partitions being reassigned - posted by "Adem Efe Gencer (JIRA)" <ji...@apache.org> on 2018/06/19 00:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6395) KIP: Add Record Header support to Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/19 01:06:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5632) Message headers not supported by Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/19 01:06:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors - posted by "Brett Rann (JIRA)" <ji...@apache.org> on 2018/06/19 03:43:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-7073) Allow retries to try different partitions where the use case allows it - posted by "moshe blumberg (JIRA)" <ji...@apache.org> on 2018/06/19 10:29:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5348) kafka-consumer-groups.sh refuses to remove groups without ids - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/19 11:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6934) Csv reporter doesn't work for ConsoleConsumer - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/19 11:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7074) Race condition between Kafka log deletion and compaction - posted by "Phil Mikhailov (JIRA)" <ji...@apache.org> on 2018/06/19 11:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7074) Race condition between Kafka log deletion and compaction - posted by "Phil Mikhailov (JIRA)" <ji...@apache.org> on 2018/06/19 11:34:00 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-6737) Is Kafka imapcted by critical vulnerqbilty CVE-2018-7489 - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/19 13:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6564) Fix broken links in Dockerfile - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/19 14:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6864) null is not passed to keyDeserialzer and valueDeserializer in Fetcher - posted by "Mathias Kub (JIRA)" <ji...@apache.org> on 2018/06/19 15:42:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7034) Remove the duplicated listTopics from Consumer - posted by "Bhagya Lakshmi Gummalla (JIRA)" <ji...@apache.org> on 2018/06/19 16:24:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7024) Rocksdb state directory should be created before opening the DB - posted by "Bhagya Lakshmi Gummalla (JIRA)" <ji...@apache.org> on 2018/06/19 16:37:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/19 18:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7074) Race condition between Kafka log deletion and compaction - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/19 18:28:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6314) Add a tool to delete kafka based consumer offsets for a given group - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/19 18:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6344) 0.8.2 clients will store invalid configuration in ZK for Kafka 1.0 brokers - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/19 18:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7064) "Unexpected resource type GROUP" when describing broker configs using latest admin client - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/06/19 20:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7066) Make Streams Runtime Error User Friendly in Case of Serialisation exception - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/19 21:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7072) Kafka Streams may drop rocksb window segments before they expire - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/19 22:02:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6881) Kafka 1.1 Broker version crashes when deleting log - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/19 22:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/19 22:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6809) connections-created metric does not behave as expected - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/19 23:23:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6836) Upgrade metrics library - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/19 23:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5975) No response when deleting topics and delete.topic.enable=false - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/19 23:24:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5975) No response when deleting topics and delete.topic.enable=false - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/19 23:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7076) Broker startup could be inefficient when using old message format - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/20 00:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7076) Broker startup could be inefficient when using old message format - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/20 00:36:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7076) Broker startup could be inefficient when using old message format - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/20 00:38:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/20 00:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7077) producerProps.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "5") producerProps.put(ProducerConfig.ENABLE_IDEMPOTENCE, true) - posted by "Stephane Maarek (JIRA)" <ji...@apache.org> on 2018/06/20 06:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7077) producerProps.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "5") producerProps.put(ProducerConfig.ENABLE_IDEMPOTENCE, true) - posted by "Stephane Maarek (JIRA)" <ji...@apache.org> on 2018/06/20 06:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent - posted by "Stephane Maarek (JIRA)" <ji...@apache.org> on 2018/06/20 06:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6697) JBOD configured broker should not die if log directory is invalid - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/20 08:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log - posted by "xiaojing zhou (JIRA)" <ji...@apache.org> on 2018/06/20 08:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/20 09:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6594) 第二次启动kafka是报错00000000000000000000.timeindex: 另一个程序正在使用此文件，进程无法访问。 - posted by "CHIH-HUNG CHIEN (JIRA)" <ji...@apache.org> on 2018/06/20 09:38:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6594) 第二次启动kafka是报错00000000000000000000.timeindex: 另一个程序正在使用此文件，进程无法访问。 - posted by "CHIH-HUNG CHIEN (JIRA)" <ji...@apache.org> on 2018/06/20 09:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7079) ValueTransformer#transform does not pass the key - posted by "Hashan Gayasri Udugahapattuwa (JIRA)" <ji...@apache.org> on 2018/06/20 12:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7080) WindowStoreBuilder incorrectly initializes CachingWindowStore - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/20 17:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2018/06/20 17:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7079) ValueTransformer#transform does not pass the key - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/20 17:23:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-7080) WindowStoreBuilder incorrectly initializes CachingWindowStore - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/20 17:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6546) Add ENDPOINT_NOT_FOUND_ON_LEADER error code for missing listener - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/20 17:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6783) consumer poll(timeout) blocked infinitely when no available bootstrap server - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/20 17:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2435) More optimally balanced partition assignment strategy - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/20 17:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7081) Add describe all topics API to AdminClient - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/20 17:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7081) Add describe all topics API to AdminClient - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/20 17:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7081) Add describe all topics API to AdminClient - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/20 18:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7081) Add describe all topics API to AdminClient - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/20 18:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6080) Transactional EoS for source connectors - posted by "Sönke Liebau (JIRA)" <ji...@apache.org> on 2018/06/20 18:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7082) Concurrent createTopics calls may throw NodeExistsException - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/20 20:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7082) Concurrent createTopics calls may throw NodeExistsException - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/20 20:34:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks - posted by "Nikki Thean (JIRA)" <ji...@apache.org> on 2018/06/20 21:06:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks - posted by "Nikki Thean (JIRA)" <ji...@apache.org> on 2018/06/20 21:36:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-7074) Race condition between Kafka log deletion and compaction - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/20 21:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5764) KafkaShortnamer should allow for case-insensitive matches - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/20 23:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store - posted by "Nishanth Pradeep (JIRA)" <ji...@apache.org> on 2018/06/21 01:40:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7072) Kafka Streams may drop rocksb window segments before they expire - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/21 01:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/06/21 01:58:01 UTC, 1 replies.
- [jira] [Created] (KAFKA-7083) maxTickMessages in ConsumerGroup option - posted by "Rahul (JIRA)" <ji...@apache.org> on 2018/06/21 06:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7083) maxTickMessages in ConsumerGroup option - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/21 07:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7084) NewTopicBuilder#config should accept Map rather than Map - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/06/21 08:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7084) NewTopicBuilder#config should accept Map rather than Map - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 09:41:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-7085) Producer hangs on TimeoutException: Failed to update metadata after 60000 ms. - posted by "Martin Vysny (JIRA)" <ji...@apache.org> on 2018/06/21 11:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7086) Kafka server process dies after try deleting old log files under Windows 10 - posted by "Cezary Wagner (JIRA)" <ji...@apache.org> on 2018/06/21 11:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7086) Kafka server process dies after try deleting old log files under Windows 10 - posted by "Cezary Wagner (JIRA)" <ji...@apache.org> on 2018/06/21 11:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7087) Option in TopicCommand to report not preferred leaders - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2018/06/21 13:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init - posted by "Lukasz Gluchowski (JIRA)" <ji...@apache.org> on 2018/06/21 14:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init - posted by "Lukasz Gluchowski (JIRA)" <ji...@apache.org> on 2018/06/21 15:05:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/21 16:01:00 UTC, 10 replies.
- [jira] [Assigned] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/21 17:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7089) Extend `kafka-consumer-groups.sh` to show "beginning offsets" - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/21 17:46:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7089) Extend `kafka-consumer-groups.sh` to show "beginning offsets" - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/06/21 17:49:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/21 20:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 23:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7089) Extend `kafka-consumer-groups.sh` to show "beginning offsets" - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/06/21 23:21:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-7082) Concurrent createTopics calls may throw NodeExistsException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 23:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7082) Concurrent createTopics calls may throw NodeExistsException - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/21 23:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active (KIP-211) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 00:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4217) KStream.transform equivalent of flatMap - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 09:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7090) Zookeeper client setting in server-properties - posted by "Christian Tramnitz (JIRA)" <ji...@apache.org> on 2018/06/22 11:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7079) ValueTransformerWithKeySupplier is not mentioned in the documentation - posted by "Hashan Gayasri Udugahapattuwa (JIRA)" <ji...@apache.org> on 2018/06/22 12:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init - posted by "Lukasz Gluchowski (JIRA)" <ji...@apache.org> on 2018/06/22 14:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7087) Option in TopicCommand to report not preferred leaders - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 15:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/22 18:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 18:47:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/23 10:14:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-7092) Multiple topics (including __consumer_offsets) have not been cleaned for a few months - posted by "Noam Berman (JIRA)" <ji...@apache.org> on 2018/06/24 15:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7093) Kafka warn messages after upgrade from 0.11.0.1 to 1.1.0 - posted by "Suleyman (JIRA)" <ji...@apache.org> on 2018/06/24 18:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7094) Variate should unify code style in one method, and use camel name - posted by "Matt Wang (JIRA)" <ji...@apache.org> on 2018/06/25 10:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7094) Variate should unify code style in one method, and use camel name - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/25 10:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7094) Variate should unify code style in one method, and use camel name - posted by "Matt Wang (JIRA)" <ji...@apache.org> on 2018/06/25 10:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6717) TopicPartition Assined twice to a consumer group for 2 consumer instances - posted by "Steven Aerts (JIRA)" <ji...@apache.org> on 2018/06/25 14:49:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group - posted by "Steven Aerts (JIRA)" <ji...@apache.org> on 2018/06/25 14:50:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers - posted by "Steven Aerts (JIRA)" <ji...@apache.org> on 2018/06/25 15:05:00 UTC, 8 replies.
- [jira] [Comment Edited] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers - posted by "Steven Aerts (JIRA)" <ji...@apache.org> on 2018/06/25 15:07:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-7095) Low traffic consumer is not consuming messages after the offsets is deleted by Kafka - posted by "Aldo Sinanaj (JIRA)" <ji...@apache.org> on 2018/06/25 16:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7095) Low traffic consumer is not consuming messages after the offsets is deleted by Kafka - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/25 16:40:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7092) Multiple topics (including __consumer_offsets) have not been cleaned for a few months - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/25 17:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7096) Consumer should drop the data for unassigned topic partitions - posted by "Mayuresh Gharat (JIRA)" <ji...@apache.org> on 2018/06/25 17:38:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps - posted by "Collin Scangarella (JIRA)" <ji...@apache.org> on 2018/06/25 18:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7097) VerifiableProducer does not work properly with --message-create-time argument - posted by "Jasper Knulst (JIRA)" <ji...@apache.org> on 2018/06/25 19:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7096) Consumer should drop the data for unassigned topic partitions - posted by "Mayuresh Gharat (JIRA)" <ji...@apache.org> on 2018/06/25 20:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6978) Make Streams Window retention time strict - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/25 21:50:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-6978) Make Streams Window retention time strict - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/25 21:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6591) Move check for super user in SimpleAclProvider before ACL evaluation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/25 22:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6098) Delete and Re-create topic operation could result in race condition - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/06/25 23:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7098) Improve accuracy of the log cleaner throttle rate - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/26 01:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7097) VerifiableProducer does not work properly with --message-create-time argument - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 02:09:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group - posted by "Narayan Periwal (JIRA)" <ji...@apache.org> on 2018/06/26 04:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6949) alterReplicaLogDirs() should grab partition lock when accessing log of the future replica - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 06:42:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6944) Add system tests testing the new throttling behavior using older clients/brokers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 07:33:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-2215) Improve Randomness for ConsoleConsumer - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/26 09:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2488) System tests: updated console_consumer.py to support new consumer - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/26 09:57:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7028) super.users doesn't work with custom principals - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/26 10:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6809) connections-created metric does not behave as expected - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/26 10:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5080) Convert ProducerBounceTest to use the new KafkaConsumer - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/26 11:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5079) ProducerBounceTest fails occasionally with a SocketTimeoutException - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/26 11:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6211) PartitionAssignmentState is protected whereas KafkaConsumerGroupService.describeGroup() returns PartitionAssignmentState Object - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/26 11:54:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6211) PartitionAssignmentState is protected whereas KafkaConsumerGroupService.describeGroup() returns PartitionAssignmentState Object - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/26 11:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4513) Support migration of old consumers to new consumers without downtime - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/26 12:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7095) Low traffic consumer is not consuming messages after the offsets is deleted by Kafka - posted by "Aldo Sinanaj (JIRA)" <ji...@apache.org> on 2018/06/26 12:07:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7099) KafkaLog4jAppender - not sending any message with level DEBUG - posted by "Vincent Lebreil (JIRA)" <ji...@apache.org> on 2018/06/26 13:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7093) Kafka warn messages after upgrade from 0.11.0.1 to 1.1.0 - posted by "Suleyman (JIRA)" <ji...@apache.org> on 2018/06/26 14:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7100) kafka.tools.GetOffsetShell with enable Kerberos Security on Kafka1.0 - posted by "abdullah toraman (JIRA)" <ji...@apache.org> on 2018/06/26 14:32:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6964) Add ability to print all internal topic names - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/06/26 14:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7099) KafkaLog4jAppender - not sending any message with level DEBUG - posted by "Bastien Bussy (JIRA)" <ji...@apache.org> on 2018/06/26 14:57:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-7100) kafka.tools.GetOffsetShell with enable Kerberos Security on Kafka1.0 - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/26 15:02:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7099) KafkaLog4jAppender - not sending any message with level DEBUG - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/26 15:11:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/26 15:16:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6964) Add ability to print all internal topic names - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/26 15:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/26 15:30:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7101) Session Window store should set topic policy `compact,cleanup` - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/26 18:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7102) Error in fetch kafka.server.ReplicaFetcherThread$FetchRequest@10c8df20 - posted by "sankar (JIRA)" <ji...@apache.org> on 2018/06/26 18:56:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6268) Tools should now swallow exceptions like resolving network names - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/26 19:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7103) Use bulkloading for RocksDBSegmentedBytesStore during init - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2018/06/26 20:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7104) ReplicaFetcher thread may die because of inconsistent log start offset in fetch response - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2018/06/26 20:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7105) Refactor RocksDBSegmentsBatchingRestoreCallback and RocksDBBatchingRestoreCallback into a single class - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2018/06/26 20:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7101) Session Window store should set topic policy `compact,cleanup` - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 21:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7106) Remove segment/segmentInterval from Window definition - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/26 21:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7107) Ability to configure state store for JoinWindows in KStream-KStream join - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/26 21:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6587) Kafka Streams hangs when not able to access internal topics - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/26 23:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7107) Ability to configure state store for JoinWindows in KStream-KStream join - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/26 23:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7106) Remove segment/segmentInterval from Window definition - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/26 23:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/26 23:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7104) ReplicaFetcher thread may die because of inconsistent log start offset in fetch response - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2018/06/26 23:38:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/27 00:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/27 00:47:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7108) "Exactly-once" stream breaks production exception handler contract - posted by "Anna O (JIRA)" <ji...@apache.org> on 2018/06/27 06:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7108) "Exactly-once" stream breaks production exception handler contract - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/27 07:42:00 UTC, 9 replies.
- [jira] [Comment Edited] (KAFKA-7108) "Exactly-once" stream breaks production exception handler contract - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/27 07:44:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/27 08:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1368) Upgrade log4j - posted by "moshe blumberg (JIRA)" <ji...@apache.org> on 2018/06/27 09:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7104) ReplicaFetcher thread may die because of inconsistent log start offset in fetch response - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 15:22:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-6880) Zombie replicas must be fenced - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/27 15:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7109) KafkaConsumer should close its incremental fetch sessions on close - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/06/27 16:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7108) "Exactly-once" stream breaks production exception handler contract - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/27 16:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6177) kafka-mirror-maker.sh RecordTooLargeException - posted by "jason wang (JIRA)" <ji...@apache.org> on 2018/06/27 19:12:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7110) Windowed changelog keys not deserialized properly by TimeWindowedSerde - posted by "Shawn Nguyen (JIRA)" <ji...@apache.org> on 2018/06/27 19:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7110) Windowed changelog keys not deserialized properly by TimeWindowedSerde - posted by "Shawn Nguyen (JIRA)" <ji...@apache.org> on 2018/06/27 19:28:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-7110) Windowed changelog keys not deserialized properly by TimeWindowedSerde - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/27 20:11:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7090) Zookeeper client setting in server-properties - posted by "Bhagya Lakshmi Gummalla (JIRA)" <ji...@apache.org> on 2018/06/27 20:25:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6177) kafka-mirror-maker.sh RecordTooLargeException - posted by "jason wang (JIRA)" <ji...@apache.org> on 2018/06/27 21:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7111) Review the NetworkClient log level used - posted by "Luan Cestari (JIRA)" <ji...@apache.org> on 2018/06/27 22:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/06/27 23:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7112) StreamThread does not check for state again after pollRequests() - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/28 00:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7112) StreamThread does not check for state again after pollRequests() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/28 00:40:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-7110) Windowed changelog keys not deserialized properly by TimeWindowedSerde - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/28 01:00:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7112) StreamThread does not check for state again after pollRequests() - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/06/28 03:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7104) ReplicaFetcher thread may die because of inconsistent log start offset in fetch response - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/28 04:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7113) AdminClient.create has an infinite retry loop bug - posted by "02tmqrmje9 (JIRA)" <ji...@apache.org> on 2018/06/28 05:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7113) AdminClient.create has an infinite retry loop bug - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/28 05:49:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7111) Review the NetworkClient log level used - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/28 07:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7114) Kafka Not sending few partitions messages to consumers - posted by "Gnanasoundari (JIRA)" <ji...@apache.org> on 2018/06/28 10:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7099) KafkaLog4jAppender - not sending any message with level DEBUG - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/28 10:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6268) Tools should now swallow exceptions like resolving network names - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/28 11:12:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7111) Review the NetworkClient log level used - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/28 11:15:00 UTC, 9 replies.
- [jira] [Created] (KAFKA-7115) InMemoryKeyValueLoggedStore does not flush the changelog - posted by "Hashan Gayasri Udugahapattuwa (JIRA)" <ji...@apache.org> on 2018/06/28 11:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6809) connections-created metric does not behave as expected - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/28 13:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6969) AdminClient should provide a way to get the version of a node - posted by "Bhagya Lakshmi Gummalla (JIRA)" <ji...@apache.org> on 2018/06/28 14:45:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6968) Call RebalanceListener in MockConsumer - posted by "Bhagya Lakshmi Gummalla (JIRA)" <ji...@apache.org> on 2018/06/28 14:46:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6939) Change the default of log.message.timestamp.difference.max.ms to 500 years - posted by "Bhagya Lakshmi Gummalla (JIRA)" <ji...@apache.org> on 2018/06/28 14:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6992) Configuring the batch.size to zero won't disable the batching entirely - posted by "Bhagya Lakshmi Gummalla (JIRA)" <ji...@apache.org> on 2018/06/28 14:54:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6980) Recommended MaxDirectMemorySize for consumers - posted by "Bhagya Lakshmi Gummalla (JIRA)" <ji...@apache.org> on 2018/06/28 14:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6621) Update Streams docs with details for UncaughtExceptionHandler - posted by "Bhagya Lakshmi Gummalla (JIRA)" <ji...@apache.org> on 2018/06/28 14:57:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7106) Remove segment/segmentInterval from Window definition - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/06/28 15:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7116) Provide separate SSL configs for Kafka Broker replication - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2018/06/28 16:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7116) Provide separate SSL configs for Kafka Broker replication - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/28 16:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7116) Provide separate SSL configs for Kafka Broker replication - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2018/06/28 17:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7117) Allow AclCommand to use AdminClient API - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/28 18:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing - posted by "Shun Guan (JIRA)" <ji...@apache.org> on 2018/06/28 19:23:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6788) Grouping consumer requests per consumer coordinator in admin client - posted by "Shun Guan (JIRA)" <ji...@apache.org> on 2018/06/28 20:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7097) VerifiableProducer does not work properly with --message-create-time argument - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/28 21:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7115) InMemoryKeyValueLoggedStore does not flush the changelog - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/28 23:22:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6039) Improve TaskAssignor to be more load balanced - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/28 23:43:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6944) Add system tests testing the new throttling behavior using older clients/brokers - posted by "Jon Lee (JIRA)" <ji...@apache.org> on 2018/06/28 23:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7118) Currently, it was discovered that KafkaConsumer's close() method might not be multi-thread safe when multiple cores are calling the same consumer. - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/06/29 03:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7118) KafkaConsumer#close() is not thread safe - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/06/29 03:32:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-7059) Offer new constructor on ProducerRecord - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/06/29 05:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7118) Make KafkaConsumer compatible with multiple threads - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/06/29 05:41:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-7115) InMemoryKeyValueLoggedStore does not flush the changelog - posted by "Hashan Gayasri Udugahapattuwa (JIRA)" <ji...@apache.org> on 2018/06/29 06:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6582) Partitions get underreplicated, with a single ISR, and doesn't recover. Other brokers do not take over and we need to manually restart the broker. - posted by "Megha Gupta (JIRA)" <ji...@apache.org> on 2018/06/29 08:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7028) super.users doesn't work with custom principals - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/29 13:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7119) Intermittent test failure with GSSAPI authentication failure - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/29 13:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7112) StreamThread does not check for state again after pollRequests() - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/29 14:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7111) Review the NetworkClient log level used - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/29 14:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6268) Tools should now swallow exceptions like resolving network names - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/29 14:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6268) Tools should now swallow exceptions like resolving network names - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/06/29 15:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6690) Priorities for Source Topics - posted by "Nick Afshartous (JIRA)" <ji...@apache.org> on 2018/06/29 19:17:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6690) Priorities for Source Topics - posted by "Nick Afshartous (JIRA)" <ji...@apache.org> on 2018/06/29 19:17:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7120) When Connect throws CONFLICT error for REST requests, it will help to see more details - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2018/06/29 19:54:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6690) Priorities for Source Topics - posted by "Nick Afshartous (JIRA)" <ji...@apache.org> on 2018/06/29 20:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6986) Export Admin Client metrics through Stream Threads - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/29 20:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/29 20:47:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/29 20:50:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7121) Intermittently, Connectors fail to assign tasks and keep retrying every second forever. - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2018/06/29 21:06:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7121) Intermittently, Connectors fail to assign tasks and keep retrying every second forever. - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2018/06/29 21:07:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-7121) Intermittently, Connectors fail to assign tasks and keep retrying every second forever. - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2018/06/29 21:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6767) OffsetCheckpoint write assumes parent directory exists - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/06/29 21:40:00 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6788) Grouping consumer requests per consumer coordinator in admin client - posted by "Shun Guan (JIRA)" <ji...@apache.org> on 2018/06/29 21:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null - posted by "Yishun Guan (JIRA)" <ji...@apache.org> on 2018/06/29 22:01:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed - posted by "James T Sweet (JIRA)" <ji...@apache.org> on 2018/06/29 22:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7122) Data is lost when ZooKeeper times out - posted by "Nick Lipple (JIRA)" <ji...@apache.org> on 2018/06/29 22:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7122) Data is lost when ZooKeeper times out - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2018/06/29 23:56:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7121) Intermittently, Connectors fail to assign tasks and keep retrying every second forever. - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/30 02:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7121) Intermittently, Connectors fail to assign tasks and keep retrying every second forever. - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/30 02:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7120) When Connect throws CONFLICT error for REST requests, it will help to see more details - posted by "lambdaliu (JIRA)" <ji...@apache.org> on 2018/06/30 08:59:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-7120) When Connect throws CONFLICT error for REST requests, it will help to see more details - posted by "lambdaliu (JIRA)" <ji...@apache.org> on 2018/06/30 09:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7120) When Connect throws CONFLICT error for REST requests, it will help to see more details - posted by "lambdaliu (JIRA)" <ji...@apache.org> on 2018/06/30 11:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7123) Documentation: broken link http://confluent.io/docs/current/kafka-rest/docs/intro.html - posted by "Vitaliy Fedoriv (JIRA)" <ji...@apache.org> on 2018/06/30 13:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7123) Documentation: broken link http://confluent.io/docs/current/kafka-rest/docs/intro.html - posted by "Vitaliy Fedoriv (JIRA)" <ji...@apache.org> on 2018/06/30 13:33:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null - posted by "Yishun Guan (JIRA)" <ji...@apache.org> on 2018/06/30 15:05:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6758) Default "" consumer group tracks committed offsets, but is otherwise not a real group - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/30 15:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6758) Default "" consumer group tracks committed offsets, but is otherwise not a real group - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2018/06/30 15:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7123) Documentation: broken link http://confluent.io/docs/current/kafka-rest/docs/intro.html - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2018/06/30 21:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7123) Documentation: broken link http://confluent.io/docs/current/kafka-rest/docs/intro.html - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2018/06/30 21:41:00 UTC, 0 replies.