Path to this page:
Subject: CVS commit: pkgsrc/devel/kafka
From: Filip Hajny
Date: 2018-03-07 12:50:57
Message id: 20180307115057.AC4E4FB40@cvs.NetBSD.org
Log Message:
devel/kafka: Update to 1.0.1.
Improvement
- Kafka metrics templates used in document generation should maintain
order of tags
- Consolidate MockTime implementations between connect and clients
- Fix repeated words words in JavaDoc and comments.
- Cache lastEntry in TimeIndex to avoid unnecessary disk access
- AbstractIndex should cache index file to avoid unnecessary disk
access during resize()
- Have State Stores Restore Before Initializing Toplogy
- SSLTransportLayer should keep reading from socket until either the
buffer is full or the socket has no more data
- Improve KTable Source state store auto-generated names
Bug
- QueryableStateIntegrationTest.concurrentAccess is failing
occasionally in jenkins builds
- KafkaProducer is not joining its IO thread properly
- Kafka connect: error with special characters in connector name
- Streams metrics tagged incorrectly
- ClassCastException in BigQuery connector
- ClientQuotaManager threads prevent shutdown when encountering an
error loading logs
- Streams configuration requires consumer. and producer. in order to
be read
- Timestamp on streams directory contains a colon, which is an illegal
character
- Add methods in Options classes to keep binary compatibility with
0.11
- RecordQueue.clear() does not clear MinTimestampTracker's maintained
list
- Selector memory leak with high likelihood of OOM in case of down
conversion
- GlobalKTable never finishes restoring when consuming transactional
messages
- IllegalArgumentException if 1.0.0 is used for
inter.broker.protocol.version or log.message.format.version
- Using standby replicas with an in memory state store causes Streams
to crash
- Issues with protocol version when applying a rolling upgrade to
1.0.0
- A metric named 'XX' already exists, can't register another one.
- Flaky Unit test:
KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache
- AbstractCoordinator not clearly handles NULL Exception
- Request logging throws exception if acks=0
- KTable state restore fails after rebalance
- Make loadClass thread-safe for class loaders of Connect plugins
- Inconsistent protocol type for empty consumer groups
- Broken symlink interrupts scanning the plugin path
- NetworkClient should not return internal failed api version
responses from poll
- Topic can not be recreated after it is deleted
- mBeanName should be removed before returning from
JmxReporter#removeAttribute()
- Connect: Struct equals/hashCode method should use Arrays#deep*
methods
- kafka-acls regression for comma characters (and maybe other
characters as well)
- punctuate with WALL_CLOCK_TIME triggered immediately
- Update KStream JavaDoc with regard to KIP-182
- StackOverflowError in kafka-coordinator-heartbeat-thread
- Fix StateRestoreListener To Use Correct Batch Ending Offset
- NullPointerException on KStream-GlobalKTable leftJoin when
KeyValueMapper returns null
- Non-aggregation KTable generation operator does not construct value
getter correctly
- When enable trace level log in mirror maker, it will throw null
pointer exception and the mirror maker will shutdown
- Enforce layout of dependencies within a Connect plugin to be
deterministic
- Connect: Some per-task-metrics not working
- Broker leaks memory and file descriptors after sudden client
disconnects
Test
- KafkaStreamsTest fails in trunk
- SelectorTest may fail with ConcurrentModificationException
Files: